.Net Core中使用Grpc的方法 |
|
一、Grpc概述 gRPC 基于如下思想：定义一个服务， 指定其可以被远程调用的方法及其参数和返回类型 。gRPC 默认使用protocol buffers作为接口定义语言，来描述服务接口和有效载荷消息结构 。如果有需要的话，可以使用其他替代方案 。 定义的服务分为4中类型：
二、.Net Core中使用Grpc 使用Grpc 就三步：定义Grpc服务、实现Grpc服务、调用Grpc服务 。 2.1 定义Grpc服务 1、在VS中选择.Net Core创建类库 2、引入Google.Protobuf、Grpc.Core包 3、创建proto文件，定义一个SsmServer服务，服务中提供两个方法，一个最简单的单项RPC方法，一个双向流式RPC 。后面这个文件会生成一个同名的C#类文件 。
syntax = "proto3"; //语法指定proto3
package ShenDa.SSM.Grpc; //后面生成C#文件的命名空间
import "Protos/Common.proto";
import "Protos/Health.proto";
import "Protos/User.proto";//指定定义服务中使用的参数的位置
service SsmService{
//健康检查 单项 RPC
rpc Health(EmptyRequest) returns (HealthResponse){}
//双向流
rpc User_Add(stream UserAddRequest) returns(stream UserAddResponse){}
}
定义的Health.proto文件
syntax = "proto3";
package ShenDa.SSM.Grpc;
message HealthResponse{ //返回参数
bool Success=1; //每个字段必须要指定序号
string Message=2;
}
以上服务就定义完成了 。现在需要将这个proto文件生成C#文件，可以使用命令，也可以使用工具 。在这里我使用工具生成 。 5、引用Grpc.Tools ，然后在工程文件中指定要生成的proto文件 。 <ItemGroup> <Protobuf Include="ProtosUser.proto" /> <Protobuf Include="ProtosHealth.proto" /> <Protobuf Include="ProtosCommon.proto" /> <Protobuf Include="ProtosSsmService.proto" /> </ItemGroup> 生成项目，就会在 obj文件夹中生成对应的C#文件 。其他文件都是生成对应的实体类，但是定义的服务的proto文件，比较特殊，它会生成一个同名的类文件，类中包含
以上所有的Grpc服务都已经定义完了 。因为客户端不可能每个都通过添加应用项目的方式使用，所以我们还需要打包客户端Nuget包 。 6、生成Nuget包，提供给客户端使用 通过VS设置打包生成Nuget包，生成Grpc客户端Nuget包 。 2.2 实现Grpc服务 通过VS的GRPC模板创建项目，定义实现类并继承上面生成的抽象类，然后重写我们定义的方法 。
public partial class SsmServiceImpl : SsmService.SsmServiceBase
{
public override async Task<HealthResponse> Health(EmptyRequest request, ServerCallContext context)
{
var response = new HealthResponse()
{
Message = string.Empty,
Success = true
};
return await Task.FromResult(response);
}
}
配置Grpc服务
public void ConfigureServices(IServiceCollection services)
{
services.AddGrpc();
}
public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
{
app.UseEndpoints(endpoints =>
{
endpoints.MapGrpcService<SsmServiceImpl>();//注入服务的实现 。
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");
});
});
}
项目结构截图：
2.3 客户端调用Grpc 1、添加引用Google.Protobuf、Grpc.Core、Grpc.Net.Client 还有刚才生成的Nuget包ShenDa.SSM.Grpc 2、调用
class Program
{
static async Task Main(string[] args)
{
var channel = GrpcChannel.ForAddress("https://localhost:5001");
var client = new SsmServiceClient(channel);
await HealthCheck(client);
}
public static async Task HealthCheck(SsmServiceClient client)
{
var response = await client.HealthAsync(new EmptyRequest());
System.Console.WriteLine(response.Success ? "健康" : "连接失败");
}
}
总结 到此这篇关于.Net Core中使用Grpc的方法的文章就介绍到这了,更多相关.Net Core使用Grpc内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！ |
