.NET Core Grpc 实现通信

Posted 2021-04-20 DotNet

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了.NET Core Grpc 实现通信相关的知识，希望对你有一定的参考价值。

来源：蜗牛丨

cnblogs.com/alan-lin/p/9000642.html

现在系统都服务化，.NET Core 实现服务化的方式有很多，我们通过grpc实现客户端、服务端通信。

grpc是google发布的一个开源、高性能、通用RPC（Remote Procedure Call）框架，使用HTTP/2协议并用ProtoBuf作为序列化工具，提供跨语言、跨平台支持。下面以.net core演示如何使用grpc框架实现通信。

软件版本

.net core:2.0
grpc:1.11.0

项目结构

InstallGrpc .net framework类库只为得到生成协议代码工具protoc.exe、grpc_csharp_plugin.exe，没有其他作用，如果已有工具，可以不用

Snai.GrpcClient 客户端 .net core 2.0控制台程序

Snai.GrpcService.Hosting 服务端 .net core 2.0控制台程序

Snai.GrpcService.Impl 协议方法实现 .net standard 2.0类库

Snai.GrpcService.Protocol 生成协议方法 .net standard 2.0类库

运行结果

服务端

.NET Core Grpc 实现通信

客户端

.NET Core Grpc 实现通信

客户端调用服务端求和方法成功。

项目实现

一、服务端

新建Snai.GrpcService解决方案

1、编写协议

新建 Snai.GrpcService.Protocol协议类库项目，在依赖项右击管理NuGet程序包浏览找到 Grpc.Core 版本1.11.0，Google.Protobuf 版本3.5.1 包下载安装

在项目根目录下新建一个 msg.proto 文件，打开 msg.proto 文件，在其中编写基于proto3语言的协议，用于自动生成到各语言，如果需要更深入的学习proto3语言可以打开该网站Proto3语言指南。

msg.proto 代码如下，定义当前使用的是proto3语言并且包名（生成为C#则为命名空间）：

syntax = "proto3";

package Snai.GrpcService.Protocol;

定义了1个服务，且有1个方法：

service MsgService{

rpc GetSum(GetMsgNumRequest) returns (GetMsgSumReply){}

}

方法的接收参数和返回参数

message GetMsgNumRequest {

int32 Num1 = 1;

int32 Num2 = 2;

}

message GetMsgSumReply {

int32 Sum = 1;

}

2、将协议生成C#代码

生成协议代码需 protoc.exe、grpc_csharp_plugin.exe工具，在.net framework 项目下引用安装 Grpc.Tools 会得到protoc.exe、grpc_csharp_plugin.exe，但.net core 项目引用安装是不会下载工具到项目目录的，所以我们需要建一个.net framework项目，我建了个 InstallGrpc .net framework类库用于引用安装得到工具。

这里得到工具有个小插曲，引用Grpc.Tools版本1.11.0得到protoc.exe、grpc_csharp_plugin.exe 拷到 Snai.GrpcService.Protocol 目录下生成不了，我再引用Google.Protobuf.Tools版本3.5.1里面有 protoc.exe，用 Grpc.Tools下的 grpc_csharp_plugin.exe, Google.Protobuf.Tools下protoc.exe 根据当前系统选择，拷贝到 Snai.GrpcService.Protocol 目录下。

先用Grpc.Tools 下的，如果生成不了，再用 Grpc.Tools下的 grpc_csharp_plugin.exe, Google.Protobuf.Tools下protoc.exe

然后在项目中新建一个名为ProtocGenerate.cmd的文件，在其中输入以下指令：

protoc -I . --csharp_out . --grpc_out . --plugin=protoc-gen-grpc=grpc_csharp_plugin.exe msg.proto

然后直接双击运行，项目下生成了“Msg.cs”和“MsgGrpc.cs”两个文件，这样协议部分的所有工作就完成了，最终项目结构如下：

.NET Core Grpc 实现通信

3、编写实现代码

新建Snai.GrpcService.Impl实现类库项目，在依赖项下载安装Grpc.Core 包，项目引用Snai.GrpcService.Protocol

在项目根目录下新建 MsgServiceImpl.cs 类文件，继承 MsgService.MsgServiceBase 协议类，实现服务方法，代码如下：

using Grpc.Core;

using Snai.GrpcService.Protocol;

using System;

using System.Collections.Generic;

using System.Text;

using System.Threading.Tasks;

namespace Snai.GrpcService.Impl

{

public class MsgServiceImpl: MsgService.MsgServiceBase

{

public MsgServiceImpl()

{

}

public override async Task<GetMsgSumReply> GetSum(GetMsgNumRequest request, ServerCallContext context)

{

var result = new GetMsgSumReply();

result.Sum = request.Num1 + request.Num2;

return result;

}

}

}

using Grpc.Core;

using Snai.GrpcService.Protocol;

using System;

using System.Collections.Generic;

using System.Text;

namespace Snai.GrpcService.Impl

{

public static class RpcConfig

{

private static Server _server;

public static void Start()

{

_server = new Server

{

Services = { MsgService.BindService(new MsgServiceImpl()) },

Ports = { new ServerPort("localhost", 40001, ServerCredentials.Insecure) }

};

_server.Start();

Console.WriteLine("grpc ServerListening On Port 40001");

Console.WriteLine("任意键退出...");

Console.ReadKey();

_server?.ShutdownAsync().Wait();

}

}

}

最终项目结构如下：

.NET Core Grpc 实现通信

4、编写服务端启动程序

新建Snai.GrpcService.Hosting 控制台程序，项目引用Snai.GrpcService.Impl

打开 Program.cs 文件，修改 Main 方法，加入服务启动，代码如下：

using Snai.GrpcService.Impl;

using System;

namespace Snai.GrpcService.Hosting

{

class Program

{

static void Main(string[] args)

{

RpcConfig.Start();

}

}

}

最终项目结构如下：

.NET Core Grpc 实现通信

到此服务端所有代码已编写完成，下面开始编写客户端。

二、客户端

新建Snai.GrpcClient 控制台程序，在依赖项下载安装Grpc.Core 包，项目引用Snai.GrpcService.Protocol

using Grpc.Core;

using Snai.GrpcService.Protocol;

using System;

using System.Collections.Generic;

using System.Text;

namespace Snai.GrpcClient

{

public static class MsgServiceClient

{

private static Channel _channel;

private static MsgService.MsgServiceClient _client;

static MsgServiceClient()

{

_channel = new Channel("127.0.0.1:40001", ChannelCredentials.Insecure);

_client = new MsgService.MsgServiceClient(_channel);

}

public static GetMsgSumReply GetSum(int num1, int num2)

{

return _client.GetSum(new GetMsgNumRequest

{

Num1 = num1,

Num2 = num2

});

}

}

}

打开 Program.cs 文件，修改 Main 方法，得到服务端返回结果，显示结果，代码如下：

using Snai.GrpcService.Protocol;

using System;

namespace Snai.GrpcClient

{

class Program

{

static void Main(string[] args)

{

GetMsgSumReply msgSum = MsgServiceClient.GetSum(10, 2);

Console.WriteLine("grpc Client Call GetSum():" + msgSum.Sum);

Console.WriteLine("任意键退出...");

Console.ReadKey();

}

}

}