华域联盟 .Net .Net Core中使用Grpc的方法

.Net Core中使用Grpc的方法

.Net Core中使用Grpc的方法
 更新时间:2020年10月16日 14:18:46   作者:MicroHeart!  

这篇文章主要介绍了.Net Core中使用Grpc的方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下

一、Grpc概述
  gRPC 基于如下思想:定义一个服务, 指定其可以被远程调用的方法及其参数和返回类型。gRPC 默认使用protocol buffers作为接口定义语言,来描述服务接口和有效载荷消息结构。如果有需要的话,可以使用其他替代方案。
定义的服务分为4中类型:

单项 RPC,即客户端发送一个请求给服务端,从服务端获取一个应答,就像一次普通的函数调用。这种最常用。
服务端流式 RPC,即客户端发送一个请求给服务端,可获取一个数据流用来读取一系列消息。客户端从返回的数据流里一直读取直到没有更多消息为止。
客户端流式 RPC,即客户端用提供的一个数据流写入并发送一系列消息给服务端。一旦客户端完成消息写入,就等待服务端读取这些消息并返回应答。
双向流式 RPC,即两边都可以分别通过一个读写数据流来发送一系列消息。这两个数据流操作是相互独立的,所以客户端和服务端能按其希望的任意顺序读写,例如:服务端可以在写应答前等待所有的客户端消息,或者它可以先读一个消息再写一个消息,或者是读写相结合的其他方式。每个数据流里消息的顺序会被保持。

二、.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文件,比较特殊,它会生成一个同名的类文件,类中包含

一个抽象类,名称为服务名+Base。其中包含我们定义的虚两个方法
一个部分类,名称为服务名+Client,继承ClientBase<服务名Client>

以上所有的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: 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("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内容请搜索华域联盟以前的文章或继续浏览下面的相关文章希望大家以后多多支持华域联盟!

您可能感兴趣的文章:ASP.NET Core 3.0 gRPC拦截器的使用ASP.NET Core 3.0使用gRPC的具体方法图析ASP.NET Core引入gRPC服务模板如何在.NET Core中为gRPC服务设计消息文件(Proto)

.Net
Core
Grpc

相关文章
在.NET Core中用最原生的方式读取Nacos的配置方法(推荐)这篇文章主要介绍了在.NET Core中用最原生的方式读取Nacos的配置方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下 2020-04-04
asp.net表单提交时防重复提交并执行前台的JS验证今天遇到这样的一个情况,就是用户重复提交。当然这个不能怪用户,只能怪.NET或者服务器反应迟钝,下面有个不错的教程,大家可以参考下 2013-10-10
ASP.NET用户注册实战(第11节)这篇文章主要介绍了ASP.NET用户注册实战,巩固前10小节所学的全部知识,需要的朋友可以参考下 2015-08-08
.Net Core 集成 Kafka的步骤这篇文章主要介绍了.Net Core 集成 Kafka的实现步骤,帮助大家更好的理解和学习使用.net技术,感兴趣的朋友可以了解下 2021-04-04
asp.net中Session缓存与Cache缓存的区别分析实现数据的缓存有很多种方法,有客户端的Cookie,有服务器端的Session和Application
2013-02-02
ASP.NET中DataTable与DataSet之间的转换示例如果你的数据不需要做关系映射,直接用DataTable效率比较高,下面有个不错的示例,感兴趣的朋友可以参考下 2013-09-09
ADO.NET获取数据(DataSet)同时获取表的架构实例下面小编就为大家分享一篇ADO.NET获取数据(DataSet)同时获取表的架构实例,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧 2017-12-12
JavaScript系列之―同步还是异步?JavaScript系列之―同步还是异步?... 2007-03-03
ASP.NET显示渐变图片实现方法用ASP.NET编写能够显示图标渐变的效果,简单实用,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下 2015-09-09
mssql 存储过程调用C#编写的DLL文件有时候,我们会遇到这样需求:存储过程要调用外部的动态链接库文件,来实现某个功能。 2009-05-05

最新评论

本文由 华域联盟 原创撰写:华域联盟 » .Net Core中使用Grpc的方法

转载请保留出处和原文链接:https://www.cnhackhy.com/5045.htm

本文来自网络,不代表华域联盟立场,转载请注明出处。

作者:

发表回复

联系我们

联系我们

2551209778

在线咨询: QQ交谈

邮箱: [email protected]

工作时间:周一至周五,9:00-17:30,节假日休息

关注微信
微信扫一扫关注我们

微信扫一扫关注我们

关注微博
返回顶部