使用注解@GrpcService在Spring Boot 中开始使用gRPC

import io.grpc.ServerBuilder;
import io.grpc.stub.StreamObserver;
import net.devh.boot.grpc.server.service.GrpcService;
 
import java.io.IOException;
import java.util.concurrent.TimeUnit;
 
@GrpcService
public class YourGrpcService extends YourServiceGrpc.YourServiceImplBase {
 
    @Override
    public void yourMethod(YourRequest request, StreamObserver<YourResponse> responseObserver) {
        // 实现你的业务逻辑
        YourResponse response = YourResponse.newBuilder().setMessage("Hello gRPC").build();
        responseObserver.onNext(response);
        responseObserver.onCompleted();
    }
 
    public static void main(String[] args) throws IOException, InterruptedException {
        YourGrpcService service = new YourGrpcService();
        Server server = ServerBuilder.forPort(50051).addService(service).build().start();
        System.out.println("gRPC server started on port 50051");
        Runtime.getRuntime().addShutdownHook(new Thread(() -> {
            System.err.println("Shutting down gRPC server since JVM is shutting down");
            try {
                server.shutdown().awaitTermination(30, TimeUnit.SECONDS);
            } catch (InterruptedException e) {
                e.printStackTrace(System.err);
                Thread.currentThread().interrupt();
            }
        }));
        server.awaitTermination();
    }
}

在这个代码实例中，我们定义了一个名为YourGrpcService的类，它扩展了由proto文件生成的服务实现类YourServiceGrpc.YourServiceImplBase。我们覆盖了yourMethod方法，并实现了具体的业务逻辑。在main方法中，我们启动了一个gRPC服务器，监听在端口50051上的请求。这个例子展示了如何在Spring Boot应用中使用注解@GrpcService来简化gRPC服务的创建和启动过程。