C# 連結Golang的Grpc Server

Grpc Client專案要如何設定，請參考之前的文章
這裡主要說明的是如何使用C# .NetCore作為Client連結Golang的Grpc Server。

Golang Grpc Server proto調整

syntax = "proto3";  // 定義要使用的 protocol buffer 版本

option csharp_namespace = "GrpcTestApi";

package grpcServer;  // for name space
//option go_package = "./;grpcServer";  // generated code 的 full Go import path

message SumRequest {
  repeated int64 input = 1 [packed=true];
}

message SumResponse {
  int64 result = 1;
}

message RemainderRequest{
  int64 a = 1;
  int64 b = 2;
}

message RemainderResponse {
  int64 result = 1;
}

service grpcService {
  rpc Sum(SumRequest) returns (SumResponse) {};
  rpc Remainder(RemainderRequest) returns (RemainderResponse) {};
}

連線Grpc Client Help物件

public class GrpcServerConnectHelp
{
    private string serverUrl;
    private grpcService.grpcServiceClient client;

    public string ServerUrl { get { return serverUrl; } }

    public GrpcServerConnectHelp()
    {
        Init(System.Configuration.ConfigurationManager.AppSettings.Get("GrpcServerUrl"));
    }

    public void Init(string url = null)
    {
        if (string.IsNullOrEmpty(url))
            return;

        serverUrl = url;
        //.NetCore 3.*版本必須加入此行，否則會錯誤。
        AppContext.SetSwitch("System.Net.Http.SocketsHttpHandler.Http2UnencryptedSupport", true);
        var channel = GrpcChannel.ForAddress(serverUrl);
        client = new grpcService.grpcServiceClient(channel);
    }

    public string CommonApi(string method, string input)
    {
        string resp = "查無此函式";

        if (method.Equals("Sum"))
        {
            return Sum(input);
        }

        if(method.Equals("Remainder"))
        {
            return Remainder(input);
        }

        return resp;
    }

    private string Sum(string input)
    {
        dynamic dyn = JsonConvert.DeserializeObject(input);
        SumRequest request = new SumRequest();

        foreach(var value in dyn.Input)
        {
            long temp = Convert.ToInt64(value);
            request.Input.Add(temp);
        }
        var reply = client.Sum(request);
        return reply.Result.ToString();
    }

    private string Remainder(string input)
    {
        dynamic dyn = JsonConvert.DeserializeObject(input);
        RemainderRequest request = new RemainderRequest();
        request.A = dyn.A;
        request.B = dyn.B;

        var reply = client.Remainder(request);
        return reply.Result.ToString();
    }
}

AppContext.SetSwitch("System.Net.Http.SocketsHttpHandler.Http2UnencryptedSupport", true);

重點在於.Net Core 3.*的版本再傳入URL前，必須加入上面的語法，否則會產生錯誤。

C# Grpc Server&Client範例

使用Grpc的預設專案，建立一個C#的GrpcServer+Client在同一個專案下。

 所以大致有以下三個動作：

1. 建立範例Grpc Server專案
2. 在同一個方案內建立Grpc Client專案
3. 將共用的.proto檔案copy到Client中
4. 測試專案

建立Grpc Server

• 建立Grpc服務專案

• 設定專案名稱

• 選擇 .Net Core 3.1版本

• Server的方案總管畫面

• 更名Server專案名稱

• 更改資料夾名稱

• 編輯方案檔

• 改寫Server專案路徑

GrpcDemo\Grpc.Server.csproj => Grpc.Server\Grpc.Server.cspro

• 加入第三方套件參考

Server設定完成，執行沒有問題。

建立Grpc Client

• 在同一方案中加入新專案(Client)

• 專案類型選擇主控台

• 設定專案名稱

• 同樣選擇 .Net Core 3.1版本
• 專案建置完成的方案總管截圖

• 將Proto檔Copy到此

• 改寫 .proto檔案內容

Server端：改寫option內容
GrpcDemo => Grpc.Server

Server端：加入參考

Client端：改寫option內容
GrpcDemo => Grpc.Client

• 調整Grpc.Client.csproj

• 重建方案
• 修改Client程式碼

static async Task Main(string[] args)
{
await Task.Delay(3000);
using var channel = GrpcChannel.ForAddress("https://localhost:5001");
var client = new Greeter.GreeterClient(channel);
Console.WriteLine("請輸入你的名字...");
string name = Console.ReadLine();
var reply = client.SayHello(new HelloRequest { Name = name });
Console.WriteLine("問候語 : " + reply.Message);
await channel.ShutdownAsync();
Console.WriteLine("按任何一個鍵退出...");
Console.ReadKey();
}

• 從方案屬性調整起始專案

• 開始測試

測試成功！！！