欢迎光临
我的个人博客网站

Dapr + .NET Core实战(十二)服务调用之GRPC


什么是GRPC

gRPC 是一种与语言无关的高性能远程过程调用 (RPC) 框架。

gRPC 的主要优点是:

  • 高性能轻量级 RPC 框架。
  • 协定优先 API 开发,默认使用协议缓冲区,允许与语言无关的实现。
  • 可用于多种语言的工具,以生成强类型服务器和客户端。
  • 支持客户端、服务器和双向流式处理调用。
  • 使用 Protobuf 二进制序列化减少对网络的使用。

这些优点使 gRPC 适用于:

  • 效率至关重要的轻量级微服务。
  • 需要多种语言用于开发的系统。
  • 需要处理流式处理请求或响应的点对点实时服务。

Dapr中的GRPC

Dapr中的GRPC与我们通常情况下使用GRPC大致是一致的,唯一的不同是Dapr中的GRPC会固定调用接口/dapr.proto.runtime.v1.AppCallback/OnInvoke,因此我们在Dapr中使用GRPC时,proto文件中不需要再定义service节点中的rpc接口,只需要定义交互使用的序列化结构体即可。

项目实战

我们继续使用FrontEnd+BackEnd项目,首先需要将BackEnd中的监听协议切换成https,因为GRPC是基于HTTP2实现的,传输层使用TLS。

        public static IHostBuilder CreateHostBuilder(string[] args) =>             Host.CreateDefaultBuilder(args)                 .ConfigureWebHostDefaults(webBuilder =>                 {                     webBuilder.UseStartup<Startup>().UseUrls("https://*:5000");                 });

BackEnd

1.为BackEnd引入Nuget包

  • Dapr.AspNetCore
  • Grpc.AspNetCore

2.在BackEnd中新建Protos/greet.proto文件,定义交互的结构体

syntax = "proto3"; option csharp_namespace = "GrpcGreeter"; package greet;  message HelloRequest {   string name = 1; }  message HelloReply {   string message = 1; }

注意:不需要定义service.rpc接口,因为Dapr中的GRPC固定调用接口/dapr.proto.runtime.v1.AppCallback/OnInvoke。

3.修改项目文件BackEnd.csproj

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

4.新增接口类Services/HelloService

    public class HelloService : AppCallback.AppCallbackBase     {         public override async Task<InvokeResponse> OnInvoke(InvokeRequest request, ServerCallContext context)         {             var response = new InvokeResponse();             switch (request.Method)             {                 case "sayhi":                     var input = request.Data.Unpack<HelloRequest>();                     response.Data = Any.Pack(new HelloReply { Message = "ok" });                     break;             }             return response;         }     }

HelloService中我们只需要定义OnInvoke方法,通过request.Method来实现不同业务的代码编写。

5.为grpc注入类

 services.AddGrpc();

6.为grpc新增终结点映射

endpoints.MapGrpcService<HelloService>();

FrontEnd

1.为FrontEnd引入Nuget包

  • Google.Protobuf
  • Grpc.Net.Client
  • Grpc.Tools

2.新增Protos/greet.proto文件

syntax = "proto3"; option csharp_namespace = "GrpcGreeter"; package greet;  message HelloRequest {   string name = 1; }  message HelloReply {   string message = 1; }

3.修改FrontEnd.csproj文件

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

4.在DaprController中新增接口

     [HttpGet("grpc")]         public async Task<ActionResult> GrpcAsync()         {             using var daprClient = new DaprClientBuilder().Build();             var result = await daprClient.InvokeMethodGrpcAsync<HelloRequest, HelloReply>("backend", "sayhi", new HelloRequest { Name = "aaa" });             return Ok(result);         }

测试

1.运行BackEnd

dapr run --dapr-http-port 3511 --app-port 5000 --app-id backend  --app-protocol grpc  dotnet  .BackEndbinDebugnet5.0BackEnd.dll --app-ssl

我们通过–app-protocol grpc指明了使用grpc,通过–app-ssl指明了开启tls

2.运行FrontEnd

dapr run --dapr-http-port 3501 --app-port 5001  --app-id frontend dotnet  .FrontEndbinDebugnet5.0FrontEnd.dll

3.调用FrontEnd的dapr/grpc接口进行测试,调用成功!!

Dapr + .NET Core实战(十二)服务调用之GRPC

 

 

 

 

Dapr + .NET Core实战(十二)服务调用之GRPC

 

赞(0) 打赏
未经允许不得转载:张拓的天空 » Dapr + .NET Core实战(十二)服务调用之GRPC
分享到: 更多 (0)

评论 抢沙发

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址

专业的IT技术经验分享 更专业 更方便

联系我们本站主机

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

微信扫一扫打赏