【SpringBoot3】结合 gRpc 通过 proto文件生成Java代码

在SpringBoot3项目中，你可以使用gRPC来定义服务并使用Protocol Buffers (proto文件)来序列化你的数据。以下是一个简单的步骤，用于生成Java代码并与SpringBoot3项目集成。

1. 定义你的proto文件。例如，hello.proto：

syntax = "proto3";
 
option java_package = "com.example.grpc";
option java_outer_classname = "HelloProto";
option java_multiple_files = false;
 
service Greeter {
  rpc SayHello (HelloRequest) returns (HelloReply) {}
}
 
message HelloRequest {
  string name = 1;
}
 
message HelloReply {
  string message = 1;
}

2. 使用protobuf编译器生成Java代码。确保已安装protoc编译器。

protoc -I=/path/to/your/proto --java_out=/path/to/your/java /path/to/your/proto/hello.proto

3. 在你的SpringBoot3项目中添加必要的依赖。在pom.xml中添加：

<dependencies>
  <!-- 添加gRPC和Netty依赖 -->
  <dependency>
    <groupId>io.grpc</groupId>
    <artifactId>grpc-netty-shaded</artifactId>
    <version>Your-gRPC-Version</version>
  </dependency>
  <dependency>
    <groupId>io.grpc</groupId>
    <artifactId>grpc-protobuf</artifactId>
    <version>Your-gRPC-Version</version>
  </dependency>
  <dependency>
    <groupId>io.grpc</groupId>
    <artifactId>grpc-stub</artifactId>
    <version>Your-gRPC-Version</version>
  </dependency>
</dependencies>

4. 实现gRPC服务端和客户端。

服务端示例：

@Bean
public Server grpcServer() throws IOException {
    int port = 50051; // 设置gRPC服务端口
    Server server = ServerBuilder.forPort(port)
            .addService(new GreeterImpl())
            .build()
            .start();
    return server;
}
 
private class GreeterImpl extends GreeterGrpc.GreeterImplBase {
    @Override
    public void sayHello(HelloRequest request, StreamObserver<HelloReply> responseObserver) {
        HelloReply response = HelloReply.newBuilder().setMessage("Hello " + request.getName()).build();
        responseObserver.onNext(response);
        responseObserver.onCompleted();
    }
}

客户端示例：

@Bean
public GreeterGrpc.GreeterBlockingStub greeterBlockingStub(ManagedChannel channel) {
    return GreeterGrpc.newBlockingStub(channel);
}
 
@Bean
public ManagedChannel managedChannel() {
    return ManagedChannelBuilder.forAddress("localhost", 50051)
            .usePlaintext()
            .build();
}
 
public void greet(String name) {
    HelloRequest