.Net Core微服务rpc框架GRPC通信如何运用

发布时间:2022-01-11 13:40:31 作者:iii
来源:亿速云 阅读:150

本文小编为大家详细介绍“.Net Core微服务rpc框架GRPC通信如何运用”,内容详细,步骤清晰,细节处理妥当,希望这篇“.Net Core微服务rpc框架GRPC通信如何运用”文章能帮助大家解决疑惑,下面跟着小编的思路慢慢深入,一起来学习新知识吧。

服务端

首先要拿出之前写好的proto文件,然后修改两个属性:

Build Action => Protobuf compiler

gRpc Stub Classes => Server only

如图:

.Net Core微服务rpc框架GRPC通信如何运用

当然也可以在项目文件里看到它:

.Net Core微服务rpc框架GRPC通信如何运用

然后重新生成项目 ,会自动根据proto文件生成server端的文件。

引用

经过刚才,已经生成了对应的服务,我们可以直接在代码里调用。

这是之前写好的proto:

syntax = "proto3";

option csharp_namespace = "gRPCApiDemo.Protos";

package Demo;

service MyMath{
    rpc MathAdd (AddRequest) returns (AddRespones) {}
}

message AddRequest{
    int32 a=1;
    int32 b=2;
}

message AddRespones{
    int32 a=1;
}

生成以后,会有一个MyMath.MyMathBase这个类,我们来继承一下:

.Net Core微服务rpc框架GRPC通信如何运用

注意看命名空间,这是刚才项目生成以后根据proto生成的。

现在来重写一下里面的方法(下图是生成,也可以手动写):

.Net Core微服务rpc框架GRPC通信如何运用

根据proto文件可知:

AddRequest包含两个int参数:A、B

AddRespones包含一个名为A的int参数

那我们把AB相加然后返回:

using Grpc.Core;
using gRPCApiDemo.Protos;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;

namespace gRPCApiDemo.Grpc
{
    public class GrpcServiceMath : MyMath.MyMathBase
    {
        public override Task<AddRespones> MathAdd(AddRequest request, ServerCallContext context)
        {
            var respones = new AddRespones
            {
                A = request.A + request.B
            };
            return Task.FromResult(respones);
        }
    }
}

再然后进入StartUp设置一下:

 app.UseHttpsRedirection();

app.UseEndpoints(endpoints =>
{
    endpoints.MapGrpcService<MathServices>();
});

服务端到这里就写完了。

如果写了更多service,那就需要在这里声明更多的实现类;而且https是必须的。

客户端

我准备了一个空白项目。接下来你可以把之前服务端的proto文件拷贝过来,或者选择重新写一份,然后修改属性以后生成一下项目:

.Net Core微服务rpc框架GRPC通信如何运用

其实还有一个选项是Client and Server,一次生成客户端和服务端。

接下来注入灵魂:

services.AddGrpcClient<MyMath.MyMathClient>(o => o.Address = new Uri("https://localhost:5001"));

MyMath是proto里声明的服务,MyMathClient是刚才生成的,里面的Uri是服务端所在的域名。

因为gRpc是基于http/2,而想要以http/2访问有个比较麻烦的证书要搞,如果不想搞证书可以接着添加这一行:

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

当然,别忘了下面https的设置。

再接着我们新建一个controller,直接调用方法:

public class IndexController : Controller
    {
        private readonly MyMath.MyMathClient _client;

        public IndexController(MyMath.MyMathClient client)
        {
            this._client = client;
        }

        public async Task<int> Add(int a, int b)
        {
            var respones = await _client.MathAddAsync(new AddRequest()
            {
                A = a,
                B = b
            });
            return respones.A;
        }
    }

MyMathClient就和MyMathBase一样,也是自动生成的。而且现在这个版本会自动生成rpc调用的异步版本,就像代码里的MathAddAsync。

我们跑一下看看:

.Net Core微服务rpc框架GRPC通信如何运用

完美。

源码地址

最后小小的提醒一下,server和client端必须要有https,不然的话:

.Net Core微服务rpc框架GRPC通信如何运用

读到这里,这篇“.Net Core微服务rpc框架GRPC通信如何运用”文章已经介绍完毕,想要掌握这篇文章的知识点还需要大家自己动手实践使用过才能领会,如果想了解更多相关内容的文章,欢迎关注亿速云行业资讯频道。

推荐阅读:
  1. python使用rpc框架gRPC的方法
  2. .Net Core中如何使用Grpc

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

core grpc

上一篇:python怎么把数据写入列表并导出折线图

下一篇:MybatisPlus LambdaQueryWrapper使用int默认值的坑及解决方法是什么

相关阅读

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

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