这篇文章主要介绍。网络核心中怎么使用Grpc,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们一定要看完!
<强>一、Grpc概述强>
Grpc基于如下思想:定义一个服务,指定其可以被远程调用的方法及其参数和返回类型.gRPC默认使用协议缓冲区作为接口定义语言,来描述服务接口和有效载荷消息结构。如果有需要的话,可以使用其他替代方案。
定义的服务分为4中类型:
- <李>
单项RPC,即客户端发送一个请求给服务端,从服务端获取一个应答,就像一次普通的函数调用。这种最常用。
李> <李>服务端流式RPC,即客户端发送一个请求给服务端,可获取一个数据流用来读取一系列消息。客户端从返回的数据流里一直读取直到没有更多消息为止。
李> <李>客户端流式RPC,即客户端用提供的一个数据流写入并发送一系列消息给服务端。一旦客户端完成消息写入,就等待服务端读取这些消息并返回应答。
李> <李>双向流式RPC,即两边都可以分别通过一个读写数据流来发送一系列消息。这两个数据流操作是相互独立的,所以客户端和服务端能按其希望的任意顺序读写,例如:服务端可以在写应答前等待所有的客户端消息,或者它可以先读一个消息再写一个消息,或者是读写相结合的其他方式。每个数据流里消息的顺序会被保持。
李><强>二,。净核心中使用Grpc 强>
使用Grpc就三步:定义Grpc服务,实现Grpc服务,调用Grpc服务。
<强> 2.1定义Grpc服务强>
1,在大战中选择。核心网创建类库
2,引入Google.Protobuf, Grpc。核心包
3,创建原型文件,定义一个SsmServer服务,服务中提供两个方法,一个最简单的单项RPC方法,一个双向流式RPC。后面这个文件会生成一个同名的c#类文件。
syntax =,“proto3",,//语法指定proto3 package ShenDa.SSM.Grpc,//后面生成c#文件的命名空间 import “原型/Common.proto",, import “原型/Health.proto"; import “原型/User.proto";//指定定义服务中使用的参数的位置 service SsmService { ,//健康检查,单项,RPC ,rpc 健康(EmptyRequest), returns (HealthResponse) {} ,//双向流 ,rpc User_Add (stream UserAddRequest),返回(stream UserAddResponse) {} }
定义的健康。原型文件
syntax =,“proto3"; package ShenDa.SSM.Grpc; HealthResponse {message //返回参数 ,bool 成功=1;//每个字段必须要指定序号 ,string 消息=2; }
以上服务就定义完成了。现在需要将这个原型文件生成c#文件,可以使用命令,也可以使用工具。在这里我使用工具生成。
5,引用Grpc。工具,然后在工程文件中指定要生成的原型文件。
, & lt; ItemGroup> & lt;才能Protobuf 包括=霸蚛 User.proto",/比; & lt;才能Protobuf 包括=霸蚛 Health.proto",/比; & lt;才能Protobuf 包括=霸蚛 Common.proto",/比; & lt;才能Protobuf 包括=霸蚛 SsmService.proto",/比; ,& lt;/ItemGroup>
生成项目,就会在obj文件夹中生成对应的c#文件。其他文件都是生成对应的实体类,但是定义的服务的原型文件,比较特殊,它会生成一个同名的类文件,类中包含
- <李>
一个抽象类,名称为服务名+基地。其中包含我们定义的虚两个方法
李> <李>一个部分的类,名称为服务名+客户端,继承ClientBase<服务名Client>
李>以上所有的Grpc服务都已经定义完了。因为客户端不可能每个都通过添加应用项目的方式使用,所以我们还需要打包客户端Nuget包。
<强> 6,生成Nuget包,提供给客户端使用强>
通过VS设置打包生成Nuget包,生成Grpc客户端Nuget包。
2.2实现Grpc服务
通过VS的Grpc模板创建项目,定义实现类并继承上面生成的抽象类,然后重写我们定义的方法。
, public partial class SsmServiceImpl : SsmService.SsmServiceBase ,{ public 才能override async  Tasknet核心中怎么使用Grpc