计划重构后端服务的时候,看到 .NET Core 3.0 的发布,包含了 Grpc,尝试了一下。
一开始,可能是新鲜吧,总觉得还不错。把后台相对比较独立的地区服务,改用 Grpc 的形式,发布出来,发现并没有想象那么好的性能,也甩不开 WebAPI 啊。总觉得应该是哪里不对,但又说不上来,毕竟是跟着官方步骤,一步一步弄出来的,不应该啊???!!!
后来发现,之所以慢,关键问题就是出现跟着微软的步骤走,性能提不起来,极大概率出现在微软的二次封装上。
看来,为了整合进 .NET Core,微软可谓煞费苦心。
本文基于此而发。
BTW. 具体的 Grpc 和 WebAPI 的性能差别,网查自行查看,很多。
微软官方步骤:单击查看
优点:微软的讲解很完善,很好的整合到了 .NET Core,使用起来非常方便,VS 2019 直接可以使用模板创建 Grpc 服务端。
缺点:性能差,很多时候,连 WebAPI 都不如。不知道微软后续是否会为此改进。
谷歌实现方案:单击查看
优点:性能好,绝大部分情况下,快 WebAPI 2~3 倍,即便最差的情况,也和 WebAPI 持平。
缺点:看需求,如果要整合到 .NET Core 中,我建议还是按照微软官方步骤走吧,省很多事。但如果像我这里的需求一样,完全为内部系统提供服务,不需要复杂的鉴权的情况下,我觉得没必要整合到 .NET Core,反正公司的 Windows 服务器也不少,直接用 .NET Framework 也挺好的。
最终,我这里采用了谷歌的方案。服务端和客户端,都只引用了三个包
Google.Protobuf
Grpc.Core
Grpc.Tools
// 注意,Grpc.Tools 只是在开发过程中,根据 proto 生成 C-Sharp 代码用,发布后,不再需要了。
// 所以,引用后,在项目文件中,会添加 <PrivateAssets>all</PrivateAssets> 标识。
简单说一下谷歌的方案:
服务端核心代码(用 Windows 服务实现的,创建 Windows 服务的步骤省略)
using Grpc.Core;
public partial class Service1 : ServiceBase
{
private Server _server;
public Service1()
{
InitializeComponent();
}
protected override void OnStart(string[] args)
{
_server = new Server
{
Services =
{
// …… 其它 proto 生成的服务代码
User.BindService(new UserService()),
Role.BindService(new RoleService())
// …… 其它 proto 生成的服务代码
},
Ports =
{
// 绑定到主机的 5001、5002 端口
{ "0.0.0.0", 5001, ServerCredentials.Insecure },
{ "0.0.0.0", 5002, ServerCredentials.Insecure }
}
}
_server.Start();
}
protected override void OnStop()
{
_server.ShutdownAsync().Wait();
}
}
客户端核心代码(用 ASP.NET Core 实现的,以下是 Index.cshtml.cs 核心代码)
using Google.Protobuf.WellKnownTypes;
using Grpc.Core;
public async Task<ActionResult> OnGetAsync()
{
// 最好不要在循环体内反复创建 Channel 和 Client(尤其是 Channel,成本较大)
// 注意:Channel 是 Grpc.Core 命名空间下的
var chn1 = new Channel("localhost:5001", ChannelCredentials.Insecure);
var cli1 = new User.UserClient(chn1);
var users1 = await cli1.GetUsersAsync(new Empty());
var roles1 = await cli1.GetRolesAsync(new Empty());
// 可带自定义参数
var header = new Metadata
{
new Metadata.Entry("id", "123"),
new Metadata.Entry("ip", "127.0.0.1")
};
var chn2 = new Channel("localhost:5002", ChannelCredentials.Insecure);
var cli2 = new User.UserClient(chn2);
var users2 = await cli2.GetUsersAsync(new Empty(), header);
return Page();
}