微服务高性能通信技术-gRPC实战落地

syntax = "proto3";

option csharp_namespace = "MyGrpcService";

// 定义消息

message HelloRequest {

string greeting = 1;

}

message HelloReply {

string message = 1;

}

// 定义服务

service Greeter {

rpc SayHello (HelloRequest) returns (HelloReply);

}

protoc -I . --csharp_out=. --grpc_out=. --plugin=protoc-gen-grpc=`which grpc_csharp_plugin` ./hello.proto

using Grpc.Core;

using MyGrpcService;

public class GreeterServiceImpl : Greeter.GreeterBase

{

public override Task SayHello(HelloRequest request, ServerCallContext context)

{

var reply = new HelloReply { Message = "Hello " + request.Greeting };

return Task.FromResult(reply);

}

}

using Grpc.Core;

using System;

class Program

{

const int Port = 50051;

public static void Main(string[] args)

{

Grpc.Core.Server server = new Grpc.Core.Server

{

Services = { Greeter.BindService(new GreeterServiceImpl()) },

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();

}

}

using Grpc.Core;

using MyGrpcService;

using System;

class Program

{

static void Main(string[] args)

{

Channel channel = new Channel("127.0.0.1:50051", ChannelCredentials.Insecure);

var client = new Greeter.GreeterClient(channel);

String user = "world";

var reply = client.SayHello(new HelloRequest { Greeting = user });

Console.WriteLine("Greeting: " + reply.Message);

channel.ShutdownAsync().Wait();

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

Console.ReadKey();

}

}