c#通过grpc和protobuf实现读取文件解析成list集合，并返回给客户端

Question

c#通过grpc和protobuf实现读取文件解析成list集合，并返回给客户端

Protobuf文件：
service Protobuf {
  rpc GetFiles(msgRequest) returns(msgData){}
  }

Grpc
[System.Obsolete]
        public override Task<msgDatas> GetFile(msgRequest request, ServerCallContext context)
        {
            try
            {
                return Task.FromResult(Service.GetCommObservable(request.Note).FirstOrDefault());
            }
            catch (TaskCanceledException TCex)
            {
              
            }
        }
  
  public msgDatas GetFile(string pCondition)
        {
            var call = gRPCclient.GetFiles(new msgRequest() { Note = pCondition });
            return call;
        }
  
  public List<msgData> GetFileData(string pCondition)
        {
            List<msgData> rtnValue = new List<msgData>();
            
                string LocalDestinationFolder = System.Threading.Thread.GetDomain().BaseDirectory.TrimEnd('\\');//download to local path
                string[] datStr = File.ReadAllLines(LocalDestinationFolder + "\\" + "20231011153021.dat");//largeBytes
                var lists = new List<List<string>>();//lists
                 string tmpStr = string.Empty;//marker
                var tmpLst = new List<string>();//tmpLst
                foreach (var datstr in datStr)
                {
                    if (datstr == tmpStr)
                    {
                        lists.Add(tmpLst);
                        tmpLst = new List<string>();
                    }
                    else
                    {
                        tmpLst.Add(datstr);
                    }
                }
                lists.Add(tmpLst);
                foreach (var list in lists)
                {
                    xxx = list[0].ToString(); 
                    xxx = list[1];
                    xxx = list[2];
                    xxx = list[3];
                    stringBuilder.Clear();
                    for (int n = 5; n < list.Count; n++)
                    {
                        stringBuilder.Append(list[n]).Append("\n");
                    }

                    text = stringBuilder.ToString();
                    rtnValue.Add(new msgData()
                    {
                        xxx = xxx,
                        xxx = xxx,
                        xxx = xxx,
                        xxx = xxx,
                        xxx = xxx
                    });
                }
            }
            catch (Exception ex)
            {
                _logger.Info(ex);
            }
            return rtnValue;
}

Answer 1

【以下回答由 GPT 生成】

首先，需要确保已安装gRPC和Protobuf的C#库。可以使用以下命令来安装它们：

dotnet add package Grpc.Net.Client
dotnet add package Google.Protobuf
dotnet add package Grpc.Tools

接下来，需要创建一个.proto文件，定义gRPC服务和消息类型。在你的例子中，已经创建了一个.proto文件，但是需要做一些更改以正确定义服务。以下是更新后的.proto文件示例：

syntax = "proto3";

option csharp_namespace = "YourNamespaceName";

package myservice;

service Protobuf {
  rpc GetFiles(msgRequest) returns (msgData){}
}

message msgRequest {
  // 添加所需的请求字段
  string note = 1;
}

message msgData {
  // 添加所需的响应字段
  string data = 1;
}

接下来，使用以下命令将.proto文件编译为C#类：

protoc -I . --csharp_out . --grpc_out . --plugin=protoc-gen-grpc=path/to/grpc_csharp_plugin yourproto.proto

完成后，将生成两个文件：yourproto.cs和yourproto.grpc.cs。将这两个文件添加到你的项目中。

修改你的Grpc服务类以正确实现gRPC服务：

public class ProtobufService : Protobuf.ProtobufBase
{
    public override async Task<msgData> GetFiles(msgRequest request, ServerCallContext context)
    {
        List<msgData> dataList = GetFileData(request.Note);
        foreach (var data in dataList)
        {
            await Task.Delay(100); // 模拟处理每个数据的时间
            await responseStream.WriteAsync(data);
        }
        return new msgData(); // 返回空的msgData对象作为结束标志
    }
}

接下来，创建客户端代码来调用gRPC服务：

static async Task Main(string[] args)
{
    var channel = GrpcChannel.ForAddress("https://localhost:5001");
    var client = new Protobuf.ProtobufClient(channel);

    using (var call = client.GetFiles(new msgRequest {Note = "your_condition"}))
    {
        while (await call.ResponseStream.MoveNext())
        {
            var data = call.ResponseStream.Current.Data;
            // 处理返回的数据
            Console.WriteLine(data);
        }
    }
}

最后，修改你的GetFileData方法以将文件内容解析为List：

public List<msgData> GetFileData(string pCondition)
{
    List<msgData> rtnValue = new List<msgData>();

    string LocalDestinationFolder = System.Threading.Thread.GetDomain().BaseDirectory.TrimEnd('\\');
    string filePath = Path.Combine(LocalDestinationFolder, "20231011153021.dat");

    string[] datStr = File.ReadAllLines(filePath);

    msgData currentData = null;
    foreach (var dat in datStr)
    {
        if (string.IsNullOrEmpty(dat))
        {
            if (currentData != null)
            {
                rtnValue.Add(currentData);
                currentData = null;
            }
        }
        else
        {
            if (currentData == null)
            {
                currentData = new msgData();
            }
            currentData.Data += dat;
        }
    }
    if (currentData != null)
    {
        rtnValue.Add(currentData);
    }

    return rtnValue;
}

这样，你就可以通过gRPC和Protobuf读取文件并将其解析为List集合，并将结果返回给客户端了。请确保使用正确的命名空间和文件路径以适应你的项目。

【相关推荐】

• 这篇文章：3、grpc和protobuf入门 也许能够解决你的问题，你可以看下
• 您还可以看一下 熊文武老师的rpc王者—gRPC框架课程中的 grpc和protobuf安装小节, 巩固相关知识点
  

如果你已经解决了该问题, 非常希望你能够分享一下解决方案, 写成博客, 将相关链接放在评论区, 以帮助更多的人 ^-^