.Net Core中如何使用Grpc

发布时间:2020-10-27 23:39:22 作者:Leah
来源:亿速云 阅读:200

本篇文章给大家分享的是有关.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="Protos\User.proto" />
  <Protobuf Include="Protos\Health.proto" />
  <Protobuf Include="Protos\Common.proto" />
  <Protobuf Include="Protos\SsmService.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/&#63;linkid=2086909");
    });
   });
  }

项目结构截图:

.Net Core中如何使用Grpc

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 &#63; "健康" : "连接失败");
  }
 }

以上就是.Net Core中如何使用Grpc,小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注亿速云行业资讯频道。

推荐阅读:
  1. .Net Core中怎么使用Grpc
  2. gRPC如何在ASP.NET Core 3.0项目中使用

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

grpc gr

上一篇:使用PowerShell如何实现自动设置安卓手机wifi代理

下一篇:VUE中插值语法的使用

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》