使用注解@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();
    }
}