GrpcをC#で実装するには

syntax = "proto3";

package Grpctst;

service GrpcTest{
    rpc TestRun (TestRequest) returns (TestResponse) {}
}

message TestRequest{
    string request = 1; 
}

message TestResponse {
    string response = 1;
}

上記のファイルの意味
syntax：決まり文句みたいなもの
package:対象のnamespaceみたいなもの
service サービス名：サービスの名前とメソッドの定義引数と戻りを定義できる。
message メッセージ名:引数や戻り値の情報を定義する箇所
        stringやintなどの型を定義する。
        1は割り当てているIDみたいなものである。
        複数記載することも可能。

public class GrpcTestReceive
{
  const int Port = 50051;

  public void Run()
  {
    Server server = new Server
    {
      Ports = { new ServerPort("localhost", Port, ServerCredentials.Insecure) }
    };

  var grpcTest = GrpcTest
      .BindService(new GrpcTestImpl())
      .Intercept(new GrpcInterceptor());
  server.Services.Add(grpcTest);

  var reflectionService = ServerReflection
      .BindService(new ReflectionServiceImpl(GrpcTest.Descriptor))
      .Intercept(new GrpcInterceptor());
  server.Services.Add(reflectionService);

  server.Start();
}

public class GrpcInterceptor : Interceptor
{
  public override Task<TResponse> ClientStreamingServerHandler<TRequest, TResponse>(
    IAsyncStreamReader<TRequest> requestStream
    , ServerCallContext context
    , ClientStreamingServerMethod<TRequest, TResponse> continuation
    )
  {
    return base.ClientStreamingServerHandler(requestStream, context, continuation);
  }

 public override Task DuplexStreamingServerHandler<TRequest, TResponse>(
    IAsyncStreamReader<TRequest> requestStream
    , IServerStreamWriter<TResponse> responseStream
    , ServerCallContext context
    , DuplexStreamingServerMethod<TRequest, TResponse> continuation
    )
  {
    return base.DuplexStreamingServerHandler(requestStream, responseStream, context, continuation);
  }

  public override Task ServerStreamingServerHandler<TRequest, TResponse>(
    TRequest request
    , IServerStreamWriter<TResponse> responseStream
    , ServerCallContext context
    , ServerStreamingServerMethod<TRequest, TResponse> continuation
    )
  {
    return base.ServerStreamingServerHandler(request, responseStream, context, continuation);
  }

  public override Task<TResponse> UnaryServerHandler<TRequest, TResponse>(
    TRequest request
    , ServerCallContext context
    , UnaryServerMethod<TRequest, TResponse> continuation
    )
  {
    foreach (var header in context.RequestHeaders)
    {
      Console.WriteLine(header);
    }

    var tokenHeader = context.RequestHeaders.FirstOrDefault((entry) => entry.Key == "token");
    if (tokenHeader == null)
    {
      context.Status = new Status(StatusCode.Unauthenticated, "ヘッダーにトークン情報がありません.");
    }
    return base.UnaryServerHandler(request, context, continuation);
  }
}