当前位置：首页 > article >正文

C# 实现 gRPC 进程间通讯：两台设备的数据交换之道

article 2025/1/10 0:59:59

标题：C#上位机通信救星！gRPC助力打造高效稳定通信架构，告别传统通信泥潭！

引言：

作为一名C#上位机开发老鸟，你是否还在为以下问题焦头烂额？

两台工控机之间数据交互慢如蜗牛，实时性？不存在的！
进程间通信代码堪比天书，调试维护？想哭！
传统通信方式面对高并发、大数据量直接躺平，性能？呵呵！

别慌，gRPC驾到，专治各种通信不服！

什么是gRPC？

gRPC是一个由Google开源的高性能、开源、通用的RPC框架，基于HTTP/2协议，采用Protocol Buffers作为接口描述语言。它拥有以下优势：

高性能： 基于HTTP/2的多路复用、头部压缩等特性，传输效率极高。
跨平台： 支持多种编程语言和平台，方便不同系统之间的集成。
简单易用： 使用IDL定义服务接口，代码自动生成，开发效率高。
功能强大： 支持双向流、身份验证、负载均衡等高级特性。

gRPC在C#上位机编程中的实战应用：

1. 环境准备

安装.NET SDK 5.0或更高版本。
安装Visual Studio 2019或更高版本。
安装protoc编译器。

2. 定义gRPC服务

创建一个名为service.proto的文件，定义服务接口和消息类型：

syntax = "proto3";

option csharp_namespace = "GrpcService";

package greet;

// The greeting service definition.
service Greeter {
  // Sends a greeting
  rpc SayHello (HelloRequest) returns (HelloReply);
}

// The request message containing the user's name.
message HelloRequest {
  string name = 1;
}

// The response message containing the greetings.
message HelloReply {
  string message = 1;
}

3. 生成C#代码

使用protoc编译器将.proto文件编译成C#代码：

protoc --csharp_out=. --grpc_out=. --plugin=protoc-gen-grpc=grpc_csharp_plugin service.proto

这将生成两个文件：Service.cs和ServiceGrpc.cs。

4. 实现gRPC服务

创建一个新的C#类库项目，并将生成的Service.cs和ServiceGrpc.cs文件添加到项目中。然后，实现GreeterBase类：

using Grpc.Core;
using System.Threading.Tasks;

namespace GrpcService
{
    public class GreeterService : Greeter.GreeterBase
    {
        public override Task<HelloReply> SayHello(HelloRequest request, ServerCallContext context)
        {
            return Task.FromResult(new HelloReply
            {
                Message = "Hello " + request.Name
            });
        }
    }
}

5. 创建gRPC服务器

创建一个新的控制台应用程序项目，并添加对gRPC服务类库项目的引用。然后，创建gRPC服务器：

using Grpc.Core;
using GrpcService;
using System;

namespace GrpcServer
{
    class Program
    {
        const int Port = 50051;

        public static void Main(string[] args)
        {
            Server server = new Server
            {
                Services = { Greeter.BindService(new GreeterService()) },
                Ports = { new ServerPort("localhost", Port, ServerCredentials.Insecure) }
            };

            server.Start();

            Console.WriteLine("Greeter server listening on port " + Port);
            Console.WriteLine("Press any key to stop the server...");
            Console.ReadKey();

            server.ShutdownAsync().Wait();
        }
    }
}

6. 创建gRPC客户端

创建另一个控制台应用程序项目，并添加对gRPC服务类库项目的引用。然后，创建gRPC客户端：

using Grpc.Core;
using GrpcService;
using System;
using System.Threading.Tasks;

namespace GrpcClient
{
    class Program
    {
        static async Task Main(string[] args)
        {
            Channel channel = new Channel("127.0.0.1:50051", ChannelCredentials.Insecure);

            var client = new Greeter.GreeterClient(channel);

            var reply = await client.SayHelloAsync(new HelloRequest { Name = "World" });
            Console.WriteLine("Greeting: " + reply.Message);

            await channel.ShutdownAsync();

            Console.WriteLine("Press any key to exit...");
            Console.ReadKey();
        }
    }
}