跨语言微服务平台试用

import grpc
from concurrent import futures
import example_pb2
import example_pb2_grpc

class ExampleServicer(example_pb2_grpc.ExampleServicer):
    def SayHello(self, request, context):
        return example_pb2.HelloReply(message='Hello, %s!' % request.name)

def serve():
    server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
    example_pb2_grpc.add_ExampleServicer_to_server(ExampleServicer(), server)
    server.add_insecure_port('[::]:50051')
    server.start()
    server.wait_for_termination()

if __name__ == '__main__':
    serve()

import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;
import example.ExampleGrpc;
import example.ExampleOuterClass;

public class ExampleClient {
    public static void main(String[] args) {
        ManagedChannel channel = ManagedChannelBuilder.forAddress("localhost", 50051)
                .usePlaintext()
                .build();
        ExampleGrpc.ExampleBlockingStub stub = ExampleGrpc.newBlockingStub(channel);
        ExampleOuterClass.HelloReply response = stub.sayHello(ExampleOuterClass.HelloRequest.newBuilder().setName("World").build());
        System.out.println("Response: " + response.getMessage());
        channel.shutdown();
    }
}