第41篇 Grpc实现客户端与服务端高效通信

grpc简直是如今最流行的跨平台间的通信技术。远不止.net上使用。grpc是谷歌公司推出的跨语言平台之间的通信技术。和webapi差别的是，可以使用自己的语言和另一种语言举行通信。

简单来讲就是首先使用一种Proto的协议文件，可以天生客户端和服务端两种文件。客户端和服务端可以使用任意的语言。grpc工具会将proto编译成任何一种语言。
比方说c#和java举行通讯。这时首先确认谁作server谁做client。然后使用grpc tools编译成c#类库和java的jar包，再引入到各自的项目，这时在c#引用的grpc tools天生的dll里就有proto文件中天生的方法。而java中的jar包也会有对应的方法。当然在这之前需要在proto中规定两端使用的api方法。也就是先天生proto文件约定两端之间调用的方法名称，参数，及参数类型。然后就可以完成跨语言之间的协同开辟。可以一个java server端，对应于多个差别语言的client端，如python、nodejs、c#等。也可以一个server端如rust server端，对应多个相同的客户端如php等。非常的灵活。
grpc可以说是一种非常高效的跨平台的通讯方案。由于它已经支持是http2。将来会支持基于udp的http3真正实现异步io。
下面我通过一个框架搭建的demo举行演示
1.GrpcProject项目框架

框架分为客户端和服务端，以及一些公共类库，使得框架完善

1.1 GrpcClient_Console客户端，采用控制台

通过客户端连接服务端，发送数据
主要代码实现如下

1. public class Program
2.         {
3.                 static async Task Main(string[] args)
4.                 {
5.                         Channel channel = new("localhost:5099", ChannelCredentials.Insecure);
7.                         try
8.                         {
9.                                 Console.WriteLine("这个应用是客户端，正在连接远程服务端...");
10.                                 await channel.ConnectAsync();
11.                                 Console.WriteLine("服务端连接成功");
12.                                 Console.WriteLine("Successfully connected to the server!");
14.                                 Console.WriteLine("First name?");
15.                                 var name = Console.ReadLine();
17.                                 Console.WriteLine("Last name? ");
18.                                 var lastName = Console.ReadLine();
20.                                 var request = new CreatePersonRequest
21.                                 {
22.                                         FirstName = name,
23.                                         LastName = lastName
24.                                 };
26.                                 var client = new PeopleService.PeopleServiceClient(channel);
28.                                 var response = await client.CreatePersonAsync(request);
30.                                 Console.WriteLine($"{response.FirstName} {response.LastName} has been created " +
31.                                         $"on the server! (id = {response.Id})");
33.                                 Console.WriteLine("Press enter to close the client");
34.                                 Console.ReadLine();
35.                         }
36.                         catch (Exception ex)
37.                         {
38.                                 Console.WriteLine("An error occurred: " + ex.ToString());
39.                                 Console.ReadLine();
40.                         }
41.                         finally
42.                         {
43.                                 if (channel is not null)
44.                                 {
45.                                         await channel.ShutdownAsync();
46.                                 }
47.                         }
48.                 }
49.         }

复制代码

2.GrpcServer_Console服务端，采用控制台

服务端可以接送客户端发送消息，并写入数据库
主要是这三个类Program，PeopleServiceImpl，ServerDbContext
通过这三个类之间的调用，可以天生数据库，数据写入库，数据库采用sqlite

1. internal class Program
2.         {
3.                 static async Task Main(string[] args)
4.                 {
5.                         new ServerDbContext().Database.EnsureCreated();
7.                         Server server = new()
8.                         {
9.                                 Ports = { new ServerPort("localhost", 5099, ServerCredentials.Insecure) },
10.                                 Services = { PeopleService.BindService(new PeopleServiceImpl()) }
11.                         };
13.                         try
14.                         {
15.                                 Console.WriteLine("这应用是服务端，正在启动服务端...");
16.                                 server.Start();
17.                                 Console.WriteLine("服务端启动成功");
18.                                 Console.WriteLine("Press enter to close the server");
19.                                 Console.ReadLine();
20.                         }
21.                         catch (Exception ex)
22.                         {
23.                                 Console.WriteLine("An error occurred: " + ex.ToString());
24.                         }
25.                         finally
26.                         {
27.                                 if (server is not null)
28.                                 {
29.                                         await server.ShutdownAsync();
30.                                 }
31.                         }
32.                 }
33.         }
36. public class PeopleServiceImpl : PeopleServiceBase
37.         {
38.                 public override async Task<Person> CreatePerson(
39.                         CreatePersonRequest request,
40.                         ServerCallContext context)
41.                 {
42.                         using var ctx = new ServerDbContext();
44.                         var dbPerson = new Person
45.                         {
46.                                 LastName = request.LastName,
47.                                 FirstName = request.FirstName
48.                         };
49.                         ctx.People.Add(dbPerson);
51.                         await ctx.SaveChangesAsync();
53.                         return new Person
54.                         {
55.                                 LastName = request.LastName,
56.                                 FirstName = request.FirstName,
57.                                 Id = dbPerson.Id
58.                         };
60.                 }
61.         }
64. public class ServerDbContext : DbContext
65.         {
66.                 public DbSet<Person> People { get; set; }
68.                 protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
69.                 {
70.                         optionsBuilder.UseSqlite("Filename = data.db");
71.                 }
72.         }

复制代码

3.共用类库

GrpcProtos ：用于存放Proto文件
AbstractDAL ：用于数据库操作抽象类
DBEntity ： 存放数据库表实体
EntityMap ：用于grpc通信实体与数据库实体之间相互转换的帮助类
GrpcEntity ：存放grpc通信的参数实体，相应返回实体等；
4.demo启动演示

先启动服务端：

再启动客户端，如果客户端连上了服务端，效果如下

分别按指示输入：

服务端的数据库会新增people数据

到此，演示算成功，客户端与服务端成功通信，并且操作数据可以落库。
感兴趣的朋友可以访问我的gitee代码库：https://gitee.com/chenshibao/grpc-project

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。