快捷導(dǎo)航

.Net?Core微服務(wù)rpc框架GRPC通信實(shí)際運(yùn)用

更新時(shí)間：2022年01月11日 11:47:12 作者：老馬-Max

這篇文章介紹了.Net?Core微服務(wù)rpc框架GRPC通信實(shí)際運(yùn)用，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

序

上一篇博客把grpc的概念說(shuō)了個(gè)大概，介紹了proto的數(shù)據(jù)類(lèi)型，基本語(yǔ)法，也寫(xiě)了個(gè)小demo，是不是沒(méi)那么難？

今天要從理論到實(shí)際，寫(xiě)兩個(gè)微服務(wù)，并利用grpc完成兩者之間的通信。只是作為demo寫(xiě)的話會(huì)十分簡(jiǎn)單，畢竟理解為主。

服務(wù)端

首先要拿出之前寫(xiě)好的proto文件，然后修改兩個(gè)屬性：

Build Action => Protobuf compiler

gRpc Stub Classes => Server only

如圖：

當(dāng)然也可以在項(xiàng)目文件里看到它：

然后重新生成項(xiàng)目，會(huì)自動(dòng)根據(jù)proto文件生成server端的文件。

引用

經(jīng)過(guò)剛才，已經(jīng)生成了對(duì)應(yīng)的服務(wù)，我們可以直接在代碼里調(diào)用。

這是之前寫(xiě)好的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;
}

生成以后，會(huì)有一個(gè)MyMath.MyMathBase這個(gè)類(lèi)，我們來(lái)繼承一下：

注意看命名空間，這是剛才項(xiàng)目生成以后根據(jù)proto生成的。

現(xiàn)在來(lái)重寫(xiě)一下里面的方法（下圖是生成，也可以手動(dòng)寫(xiě)）：

根據(jù)proto文件可知：

AddRequest包含兩個(gè)int參數(shù)：A、B

AddRespones包含一個(gè)名為A的int參數(shù)

那我們把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);
        }
    }
}

再然后進(jìn)入StartUp設(shè)置一下：

　app.UseHttpsRedirection();

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

服務(wù)端到這里就寫(xiě)完了。

如果寫(xiě)了更多service，那就需要在這里聲明更多的實(shí)現(xiàn)類(lèi)；而且https是必須的。

客戶(hù)端

我準(zhǔn)備了一個(gè)空白項(xiàng)目。接下來(lái)你可以把之前服務(wù)端的proto文件拷貝過(guò)來(lái)，或者選擇重新寫(xiě)一份，然后修改屬性以后生成一下項(xiàng)目：

其實(shí)還有一個(gè)選項(xiàng)是Client and Server，一次生成客戶(hù)端和服務(wù)端。

接下來(lái)注入靈魂：

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

MyMath是proto里聲明的服務(wù)，MyMathClient是剛才生成的，里面的Uri是服務(wù)端所在的域名。

因?yàn)間Rpc是基于http/2，而想要以http/2訪問(wèn)有個(gè)比較麻煩的證書(shū)要搞，如果不想搞證書(shū)可以接著添加這一行：

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

當(dāng)然，別忘了下面https的設(shè)置。

再接著我們新建一個(gè)controller，直接調(diào)用方法：

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一樣，也是自動(dòng)生成的。而且現(xiàn)在這個(gè)版本會(huì)自動(dòng)生成rpc調(diào)用的異步版本，就像代碼里的MathAddAsync。

我們跑一下看看：