gRPC搭建使用方式-有解無憂

gRpc 官網鏈接

新建服務端專案

在服務端內先撰寫一個 .proto 檔案

greet.proto

syntax = "proto3";

service Greeter {
  rpc SayHello (HelloRequest) returns (HelloReply);
}

message HelloRequest {
  string name = 1;
}

message HelloReply {
  string message = 1;
}

服務端生成 .proto 代碼為 C# NutGet Install-Package Grpc.Tools

找到tools 從里面選擇自己電腦的版本

把 protoc.exe 、 grpc_csharp_plugin.exe 復制出來和 .proto 檔案放在一起

撰寫一個 .cmd 檔案和 .proto 檔案放在一起，插入生成代碼的指令，（注意 greet.proto 這是 .proto 檔案名）

protoc -I . --csharp_out . --grpc_out . --plugin=protoc-gen-grpc=grpc_csharp_plugin.exe greet.proto

點擊cmd 生成會獲得兩個C#檔案，

新建類GreeterService

并在使用客戶端之前啟動（啟動服務端之前，要先排除與.Net 無關的.proto檔案，不然直接運行會報錯的）

public class GreeterService : Greeter.GreeterBase
{
    private readonly ILogger<GreeterService> _logger;

    public GreeterService(ILogger<GreeterService> logger)
    {
        _logger = logger;
    }

    public override Task<HelloReply> SayHello(HelloRequest request,
        ServerCallContext context)
    {
        _logger.LogInformation("Saying hello to {Name}", request.Name);
        return Task.FromResult(new HelloReply 
        {
            Message = "Hello " + request.Name
        });
    }　　
}
 class Program
 {

     const int Port = 2020;

     static void Main(string[] args)
     {
         Server server = new Server
     　　 {
            Services = { Greeter.BindService(new GreeterService()) },
            Ports = { new ServerPort("127.0.0.1", 2020, ServerCredentials.Insecure) }
         };
         server.Start();
         Console.WriteLine("127.0.0.1");
         Console.WriteLine("GrpcService server listening on port " + Port);
         Console.WriteLine("任意鍵退出...");
         Console.ReadKey();
     }
}

新建控制臺客戶端專案

客戶端呼叫服務端

namespace gRPCClient
{
    class Program
    {
        static void Main(string[] args)
        {
      
            // The port number(5001) must match the port of the gRPC server.
            Channel channel = new Channel("127.0.0.1", 2020, ChannelCredentials.Insecure);
            var client = new Greeter.GreeterClient(channel).WithHost("127.0.0.1");
            
            try
            {
                var reply = client.SayHelloAsync(new HelloRequest { Name = "Zhang San" });
                Console.WriteLine("來自" + reply.ResponseAsync.Result);

                channel.ShutdownAsync().Wait();
                Console.WriteLine("Greeting: " + reply.ResponseAsync.Result);
                Console.WriteLine("Press any key to exit...");
                Console.ReadKey();
            }
            catch (Exception ex)
            {

                throw ex;
            }
 
           
        }
    }
}

轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/55336.html

標籤：其他

上一篇：IEnumerable、ICollection、IList、List關系和區別

下一篇：C# MVC 中自定義權限特性[Authorize]中對于Ajax訪問的處理