经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置:技术经验 » 程序设计 » ASP.net » 查看文章
gRPC之.Net6中的初步使用介绍
来源:cnblogs  作者:Qubernet  时间:2023/3/14 8:48:17  对本文有异议

1、??介绍

GRPC是一个高性能、通用的开源远程过程调用(RPC)框架,基于底层HTTP/2协议标准协议层Protobuf序列化协议开发,支持众多的开发语言,由Google开源。

gRPC也是基于以下理念:定义一个服务,指定其能够被远程调用的方法(包含参数和返回类型)。在服务端实现这个接口,并运行一个 gRPC服务器来处理客户端调用。在客户端拥有一个存根能够像服务端一样的方法。

特点:

  • 跨语言,多种语言的类库实现;

  • 基于HTTP/2之上的二进制协议;

  • Protobuf序列化机制,比JSON体积小,网络传输快;

  • 一个连接上可以多路复用,并发处理多个请求和响应;

  • 服务定义文件和自动代码生成(.proto 文件和 Protobuf 编译工具);

  • 适合高性能轻量的微服务,一般对外的接口用Restful API,内部服务的调用用gRPC。gRPC是一个分布式服务框架,和以前的WebService,WCF类似;

  • gRPC还提供了很多扩展点,用于对框架进行功能定制和扩展,例如,通过开放负载均衡接口可以无缝的与第三方组件进行集成对接(Zookeeper、域名解析服务、SLB 服务等)。


2、??创建gRPC服务端

2.1、??创建gRPC服务端项目

打开VS2022,新建项目,在输入框中输入gRPC关键字,选中gRPC项目模板,然后点击下一步,如下图所示:

image

输入项目名称“Quber.Grpc.Service”,然后点击下一步,如下图所示:

image

选中.Net6,最后点击创建按钮,如下图所示:

image

默认项目文件结构,如下图所示:

image

2.2、??文件说明

  • appsettings.json
    我们打开appsettings.json文件,其中有一个Protocols属性,代表基于Http2进行通信。

    image

  • Protos
    在创建的项目中,我们会看到有一个名称为Protos的文件夹,该文件夹用于存放proto协议文件,其中的greet.proto是项目默认给我们创建的一个示例文件,它会根据协议自动生成需要的类文件。该协议文件中的具体说明如下图所示:

    image

  • Services
    在创建的项目中,我们会看到有一个名称Services的文件夹,该文件夹用于存放具体的业务实现类(即:服务类),其中的GreeterService.cs是项目默认给我们创建的一个示例文件,具体说明如下图所示:

    image

    上述图中的Greeter.GreeterBase来自greet.proto文件生成的类文件,具体位置如下图所示:

    image

  • 注册服务

    最后我们打开Program.cs文件,需要添加gRPC服务,同时需要将所有的业务服务进行注册,如下图所示:

    image

2.3、??创建自定义服务

接下来我们就以获取用户信息为例创建一个名称为user.proto的协议文件进行讲解。

  • 创建user.proto协议文件

    新建user.proto协议文件,如下图所示:

    image

    image

    该协议文件的内容如下所示:

    1. //proto版本
    2. syntax = "proto3";
    3. //命名空间
    4. option csharp_namespace = "Quber.Grpc.Service.Protos";
    5. //包名
    6. package user;
    7. //服务名称
    8. service User{
    9. //方法名称
    10. rpc GetUserInfo (UserInfoRequest) returns (UserInfoResult);
    11. }
    12. //请求的参数对象
    13. message UserInfoRequest{
    14. string UserName = 1;
    15. int32 UserAge = 2;
    16. }
    17. //请求响应的对象
    18. message UserInfoResult{
    19. string UserName = 1;
    20. int32 UserAge = 2;
    21. string Address = 3;
    22. }
  • 添加user.proto协议文件的关联配置

    我们双击项目Quber.Grpc.Service打开项目的编辑文件,在ItemGroup节点中增加如下配置:

    image

    1. <ItemGroup>
    2. <Protobuf Include="Protos\user.proto" GrpcServices="Server" />
    3. </ItemGroup>

    接下来我们生成一下项目,就会发现在\obj\Debug\net6.0\Protos目录下多了2个user.proto协议文件对应的类文件了,如下图所示:

    image

  • 实现定义的服务

    创建UserService.cs类文件,具体代码如下所示:

    image

    1. using Grpc.Core;
    2. using Quber.Grpc.Service.Protos;
    3. namespace Quber.Grpc.Service.Services
    4. {
    5. public class UserService : User.UserBase
    6. {
    7. private readonly ILogger<GreeterService> _logger;
    8. public UserService(ILogger<GreeterService> logger)
    9. {
    10. _logger = logger;
    11. }
    12. /// <summary>
    13. /// 实现了user.proto协议文件中定义的GetUserInfo方法
    14. /// </summary>
    15. /// <param name="request"></param>
    16. /// <param name="context"></param>
    17. /// <returns></returns>
    18. public override Task<UserInfoResult> GetUserInfo(UserInfoRequest request, ServerCallContext context)
    19. {
    20. //return base.GetUserInfo(request, context);
    21. //返回了user.proto协议文件中GetUserInfo方法定义的响应对象:UserInfoResult
    22. return Task.FromResult(new UserInfoResult
    23. {
    24. UserName = $"姓名:{request.UserName}",
    25. UserAge = request.UserAge + 10,
    26. Address = "地址:四川省成都市"
    27. });
    28. }
    29. }
    30. }

    继承的User.UserBase是user.proto协议文件生成的类文件中的。

  • 注册UserService服务

    我们需要将新建的UserService服务在启动文件中进行注册,如下所示:

    image

  • 启动服务

    到此,gRPC服务端就新建配置完成了,此时我们就可以启动该项目让其运行起来,如下图所示:

    image

    在上图中,我们发现有2个地址http://localhost:5201https://localhost:7288,这2个地址是我们在创建项目的时候,在launchSettings.json配置中自动给我们配置的,后面gRPC客户端会使用到这2个地址,目的是给客户端请求提供监听的地址。

    image


3、??创建gRPC客户端

3.1、??创建gRPC客户端项目

我们以创建控制台应用程序为例,新建一个名称为Quber.Grpc.Client的控制台程序,并添加如下引用:

  1. Google.Protobuf
  2. Grpc.Net.Client
  3. Grpc.Tools
  4. Grpc.Net.ClientFactory

3.2、??复制proto协议文件

将服务端项目Quber.Grpc.Service中的user.proto协议文件复制过来,如下图所示:

image

3.3、??编辑客户端配置

我们双击项目Quber.Grpc.Client打开项目的编辑文件,在ItemGroup节点中增加如下配置:

image

  1. <ItemGroup>
  2. <Protobuf Include="Protos\user.proto" GrpcServices="Client" />
  3. </ItemGroup>

此时我们生成一下客户端项目,会发现在obj\Debug\net6.0\Protos目录下也生成了user.proto协议文件对应的2个类文件,如下图所示:

image

3.4、??gRPC服务的https调用

在gRPC服务端项目中,给我们提供了2个地址的调用,一个是https的https://localhost:7288,另一个是http的http://localhost:5201,此处我们演示调用https。

在客户端项目中我们新建类文件UserTest.cs,具体代码如下所示:

image

  1. using Grpc.Net.Client;
  2. using Quber.Grpc.Service.Protos;
  3. namespace Quber.Grpc.Client
  4. {
  5. public class UserTest
  6. {
  7. public void GetUserInfo()
  8. {
  9. //使用https
  10. const string urlHttps = "https://localhost:7288";
  11. using (var channel = GrpcChannel.ForAddress(urlHttps))
  12. {
  13. var client = new User.UserClient(channel);
  14. var userInfo = client.GetUserInfo(new UserInfoRequest()
  15. {
  16. UserName = "Quber",
  17. UserAge = 32
  18. });
  19. //打印服务方法返回的结果
  20. Console.WriteLine($"{userInfo.UserName},{userInfo.UserAge},{userInfo.Address}");
  21. }
  22. Console.ReadKey();
  23. }
  24. }
  25. }

然后我们在启动文件中进行调用并运行该客户端项目,如下图所示:

image

到此,调用gRPC服务端提供的https地址就成功了。

3.5、??gRPC服务的http调用

相比https的调用,我们只需要在调用前加上如下代码即可:

  1. AppContext.SetSwitch("System.Net.Http.SocketsHttpHandler.Http2UnencryptedSupport", true);

UserTest.cs中的具体代码如下所示:

image

  1. using Grpc.Net.Client;
  2. using Quber.Grpc.Service.Protos;
  3. namespace Quber.Grpc.Client
  4. {
  5. public class UserTest
  6. {
  7. public void GetUserInfo()
  8. {
  9. //使用http
  10. AppContext.SetSwitch("System.Net.Http.SocketsHttpHandler.Http2UnencryptedSupport", true);
  11. const string urlHttp = "http://localhost:5201";
  12. using (var channel = GrpcChannel.ForAddress(urlHttp))
  13. {
  14. var client = new User.UserClient(channel);
  15. var userInfo = client.GetUserInfo(new UserInfoRequest()
  16. {
  17. UserName = "Quber",
  18. UserAge = 32
  19. });
  20. //打印服务方法返回的结果
  21. Console.WriteLine($"{userInfo.UserName},{userInfo.UserAge},{userInfo.Address}");
  22. }
  23. Console.ReadKey();
  24. }
  25. }
  26. }

运行效果如下:

image

3.6、??依赖注入方式调用gRPC

我们在客户端项目中新建UserTestIoc.cs类文件,具体代码如下所示:

image

  1. using Quber.Grpc.Service.Protos;
  2. namespace Quber.Grpc.Client
  3. {
  4. public class UserTestIoc
  5. {
  6. /// <summary>
  7. /// 定义gRPC客户端服务对象
  8. /// </summary>
  9. private readonly User.UserClient _userClient;
  10. public UserTestIoc(User.UserClient userClient)
  11. {
  12. _userClient = userClient;
  13. }
  14. public void GetUserInfo()
  15. {
  16. var userInfo = _userClient.GetUserInfo(new UserInfoRequest()
  17. {
  18. UserName = "Quber - IOC",
  19. UserAge = 20
  20. });
  21. Console.WriteLine($"{userInfo.UserName},{userInfo.UserAge},{userInfo.Address}");
  22. Console.ReadKey();
  23. }
  24. }
  25. }

然后我们在启动文件Program.cs中进行相应的依赖注入配置并调用,具体代码如下所示:

image

  1. #region 使用IOC注入的方式调用gRPC
  2. //引入命名空间
  3. using Microsoft.Extensions.DependencyInjection;
  4. using Quber.Grpc.Client;
  5. using Quber.Grpc.Service.Protos;
  6. IServiceCollection services = new ServiceCollection();
  7. //注册UserTestIoc服务
  8. services.AddTransient<UserTestIoc>();
  9. #region gRPC Client注册
  10. //调用http时启用该设置
  11. //AppContext.SetSwitch("System.Net.Http.SocketsHttpHandler.Http2UnencryptedSupport", true);
  12. //添加gRPC客户端服务
  13. services.AddGrpcClient<User.UserClient>(options =>
  14. {
  15. //设置gRPC的https服务调用地址
  16. options.Address = new Uri("https://localhost:7288");
  17. }).ConfigureChannel(grpcOptions =>
  18. {
  19. });
  20. #endregion
  21. //构建容器
  22. IServiceProvider serviceProvider = services.BuildServiceProvider();
  23. //解析UserTestIoc服务
  24. var grpcRequestTest = serviceProvider.GetService<UserTestIoc>();
  25. //调用UserTestIoc服务中的GetUserInfo方法
  26. grpcRequestTest.GetUserInfo();
  27. #endregion

最后我们运行客户端,效果如下所示:

image


4、??WebApi中使用gRPC

通常情况下,我们会使用WebApi对外提供数据接口服务,如果我们想在WebApi中使用gRPC该怎么做呢?

4.1、??新建ASP.NET Core Web 应用

这里我们新建一个名称为Quber.Grpc.Web的项目(该项目类型为ASP.NET Core Web 应用,方便测试),如下图所示:

image

image

image

4.2、??添加Grpc.AspNetCore包

添加Grpc.AspNetCore依赖包,如下图所示:

image

4.3、??添加Proto文件

此时我们可以直接将Quber.Grpc.Service项目中的文件复制过来即可,如下图所示:

image

需要注意的是:复制过来后,需要在Web项目的配置中添加如下节点配置,如果已经有了请忽略:

image

  1. <ItemGroup>
  2. <Protobuf Include="Protos\user.proto" GrpcServices="Server" />
  3. </ItemGroup>

此时我们同样可以生成下Quber.Grpc.Web项目,会发现在obj\Debug\net6.0\Protos目录下也生成了user.proto协议文件对应的2个类文件,如下图所示:

image

4.4、??添加Services服务

同理,我们可以直接将Quber.Grpc.Service项目中的文件复制过来即可,如下图所示:

image

4.5、??注册gRPC服务

在启动文件中,我们需要注册gRPC服务和UserService服务,如下图所示:

image

到此,在Web项目中添加gRPC就完成了。

4.6、??验证服务

在此,我们启动Quber.Grpc.Web项目,如下图所示就代表启动正常:

image

此时,我们就可以使用客户端Quber.Grpc.Client项目进行验证,启动Quber.Grpc.Client项目前,我们需要先修改gRPC的连接地址(因为我们新建的Web项目提供的地址和端口号不一样)

image

这样,我们就成功的使用Web项目对外提供WebApi数据接口服务,同时又对内提供了gRPC服务

原文链接:https://www.cnblogs.com/qubernet/p/17210812.html

 友情链接:直通硅谷  点职佳  北美留学生论坛

本站QQ群:前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

W3xue 的所有内容仅供测试,对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接(目前9元/月)请联系QQ:27243702 沸活量
皖ICP备17017327号-2 皖公网安备34020702000426号