微服务-基于Grpc的进程通信-简单使用(4-1)

项目中，在微服务内部通信使用Grpc来实现。Grpc和WebApi相比有以下特点：基于Http/2,

支持C++,Python,Ruby,Golang,java，nodejs,C# 等主流开发语言,Protobuf的格式比Json在数据传输上的性能更高。

下面介绍Grpc的使用：

服务端 ：

(1).创建服务端，新建Grpc服务MicService.GrpcServer

 

 

默认会生成以下几个文件 greet.proto和GreeterService

 

greet.proto内容如下：

syntax = "proto3";

option csharp_namespace = "MicService.GrpcServer";

package greet;

// The greeting service definition.
service Greeter {
  // Sends a greeting
  rpc SayHello (HelloRequest) returns (HelloReply);
}

// The request message containing the user's name.
message HelloRequest {
  string name = 1;
}

// The response message containing the greetings.
message HelloReply {
  string message = 1;
}

 

GreeterService.cs内容如下：

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)
        {
            return Task.FromResult(new HelloReply
            {
                Message = "Hello " + request.Name
            });
        }
    }

 

(2)Startup配置

可以看到在“ConfigureServices.cs”中增加了services.AddGrpc();

public void ConfigureServices(IServiceCollection services)
{
    services.AddGrpc();
}

在Configure中添加EndPoint

public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
{
    if (env.IsDevelopment())
    {
        app.UseDeveloperExceptionPage();
    }

    app.UseRouting();

    app.UseEndpoints(endpoints =>
    {
        endpoints.MapGrpcService<GreeterService>();

        endpoints.MapGet("/", async context =>
        {
            await context.Response.WriteAsync("Communication with gRPC endpoints must be made through a gRPC client. To learn how to create a client, visit: https://go.microsoft.com/fwlink/?linkid=2086909");
        });
    });
}

 

(3)项目文件配置：

注意：GrpcServices服务端为Server

  <ItemGroup>
    <Protobuf Include="Protosgreet.proto" GrpcServices="Server" />
  </ItemGroup>

 

客户端：

这里创建一个控制台程序MicService.GrpcClient

(1)引入三个Nuget包

Google.Protobuf

Grpc.Net.Client

Grpc.Tools

 

(2)将服务端的Proto文件拷贝至项目中，并修改项目文件配置

注意：GrpcServices客户端为Client

  <ItemGroup> 
    <Protobuf Include="Protosgreet.proto" GrpcServices="Client" />
  </ItemGroup>

 

(3)和服务端通信

 //创建通道 基于grpc地址
using var channel = GrpcChannel.ForAddress("https://localhost:5001");

//创建客户端代理
var client = new GreeterClient(channel);

//服务端调用
var reply = await client.SayHelloAsync(new HelloRequest { Name = "客户端传参" });

////客户端等待返回结果
Console.WriteLine(reply.Message);

Console.ReadKey();

 

开始测试：

配置多个项目启动项，其中服务端要优先于客户端

结果如下：

注：可能会发生的错误

不能创建SSL连接

Grpc.Core.RpcException:“Status(StatusCode="Unavailable", Detail="Error starting gRPC call. HttpRequestException: An error occurred while sending the request. IOException: The response ended prematurely.", 

解决方案：在客户端设置允许不安全的HTTP2支持

AppContext.SetSwitch("System.Net.Http.SocketsHttpHandler.Http2UnencryptedSupport", true);

 附源码：

链接：https://pan.baidu.com/s/19gGkpevQH-EJaJJ1XTT5sg
提取码：h18f
 

以上，仅用于学习和总结！