gRPC Spring Boot Starter实战指南
// 假设已经定义了GreeterServiceGrpc.GreeterImplBase的实现类GreeterServiceImpl
import my.example.grpc.service.GreeterServiceGrpc;
@GrpcService
public class GreeterServiceImpl extends GreeterServiceGrpc.GreeterImplBase {
@Override
public void sayHello(HelloRequest request, StreamObserver<HelloReply> responseObserver) {
HelloReply reply = HelloReply.newBuilder().setMessage("Hello " + request.getName()).build();
responseObserver.onNext(reply);
responseObserver.onCompleted();
}
}
这段代码展示了如何在Spring Boot应用中使用@GrpcService
注解来注册gRPC服务端。GreeterServiceImpl
类继承自自动生成的GreeterServiceGrpc.GreeterImplBase
类,并覆盖了sayHello
方法。当客户端发起RPC调用时,服务端的sayHello
方法会被调用,并返回一个包含问候信息的响应。
评论已关闭