转载请注明出处:
service 的定义方式如下:
service MyService {
rpc MyMethod(MyRequest) returns (MyResponse);
}
在 Java 中,使用 protoc 工具生成代码后,可以通过继承自动生成的 MyServiceGrpc 类来实现服务端和客户端。
例如,服务端可以创建一个继承自 MyServiceGrpc.MyServiceImplBase 的类,实现 MyMethod 方法,处理客户端发送过来的 MyRequest 消息,并返回 MyResponse 响应消息。示例代码如下:
class MyServerImpl extends MyServiceGrpc.MyServiceImplBase { @Override public void myMethod(MyRequest request, StreamObserver responseObserver) { // 处理请求消息 ... // 发送响应消息 MyResponse response = MyResponse.newBuilder().build(); responseObserver.onNext(response); responseObserver.onCompleted(); } }
然后在启动服务器时将该服务添加到 ServerBuilder 中即可,示例代码如下:
Server server = ServerBuilder.forPort(PORT) .addService(new MyServerImpl()) .build(); server.start();
在客户端中,通过创建一个 MyServiceGrpc.MyBlockingStub 或 MyServiceGrpc.MyStub 对象来调用 MyMethod 方法。MyBlockingStub 提供了同步的阻塞式调用方式,而 MyStub 提供了异步的非阻塞式调用方式。示例代码如下:
ManagedChannel channel = ManagedChannelBuilder.forAddress(address, port).usePlaintext().build(); MyServiceGrpc.MyBlockingStub blockingStub = MyServiceGrpc.newBlockingStub(channel); MyServiceGrpc.MyStub asyncStub = MyServiceGrpc.newStub(channel); MyRequest request = MyRequest.newBuilder().build(); MyResponse response = blockingStub.myMethod(request); asyncStub.myMethod(request, new StreamObserver() { @Override public void onNext(MyResponse response) { // 处理响应消息 } @Override public void onError(Throwable t) { // 处理异常 } @Override public void onCompleted() { // 完成回调 } });
在服务端接收到请求时,会根据请求消息里的方法名称调用相应的处理方法,并将请求消息作为参数传递给该方法提取所需信息并进行处理,然后返回所需的响应消息。整个过程中,双方都需要遵守相应的协议和格式规范。
如果 proto 文件中没有定义 service,则使用 protoc 直接生成 Java 文件时并不会生成 gRPC 相关的类和方法。
gRPC 的实现是基于 proto 文件中所定义的 Service,因此必须在 proto 文件中定义 Service 才能生成 gRPC 相关的类。
proto 文件中service的示例:
syntax = "proto3"; package example; message Greeting { string name = 1; } // 添加新的服务 Greeter service Greeter { rpc SayHello(Greeting) returns (Greeting) {} }
服务器托管,北京服务器托管,服务器租用 http://www.fwqtg.net
机房租用,北京机房租用,IDC机房托管, http://www.fwqtg.net
一个人真正的成长一定是极其不容易的,如果想通过一两本书,一两个鸡汤文案,一两场培训就能够获得成长,那简直是痴人说梦,真正的成长一定不会是轻松的,一定是经过一次又一次的跌倒,然后爬起,对所做过的事,所经历的事进行一次又一次的复盘,总结,思考,最终才能慢慢认识到事…