杭州.net培训
达内杭州.net培训中心

13732203138

热门课程

.NET Core Grpc 实现通信

  • 时间:2018-05-25 14:13
  • 发布:杭州.NET培训
  • 来源:疑难解答

项目结构

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类库

运行结果

服务端

客户端

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

项目实现

一、服务端

新建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”两个文件,这样协议部分的所有工作就完成了,最终项目结构如下:

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 GetSum(GetMsgNumRequest request, ServerCallContext context)

{

var result = new GetMsgSumReply();

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

return result;

}

}

}

在项目根目录下新建 RpcConfig.cs 类文件,编写绑定服务到服务端,服务端 地址 端口 等信息,实现启动方法,代码如下:

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();

}

}

}

最终项目结构如下:

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();

}

}

}

最终项目结构如下:

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

二、客户端

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

在项目根目录下新建 MsgServiceClient.cs 类文件,编写与服务端通信的 地址 端口 等信息,并调用服务端方法,代码如下:

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();

}

}

}

最终项目结构如下:

到此所有代码都已编写完成

上一篇:ASP.NET Core 学习手册
下一篇:.Net 分布式系统架构的思路
选择城市和中心
贵州省

广西省

海南省