寻求Helidon Nima集成gRPC的可行示例及实现指引

一、Project Loom迁移建议 #

从时间线来看，明年初Project Loom很大概率已经正式GA（当前Loom处于预览阶段，成熟度接近稳定）。结合你们项目的基础设施属性——代码结构相对规整、重写风险可控，等Loom稳定后迁移是合理的方向。

开发阶段建议：

• 现阶段基于标准gRPC Java SDK开发，尽量避免硬编码依赖特定线程模型的逻辑（比如自定义线程池、直接操作ThreadLocal）。
• 遵循gRPC的异步/同步编程规范，保持代码模块化，后续切换到虚拟线程时，仅需调整服务器端的线程池配置为虚拟线程池即可，迁移成本极低。

二、Helidon Nima gRPC可运行示例搭建步骤 #

以下是完整的本地搭建流程：

1. 创建Maven项目并配置依赖 #

在pom.xml中添加Helidon Nima的BOM及gRPC相关依赖，同时配置Protobuf编译插件：

<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>example</groupId>
    <artifactId>helidon-nima-grpc-demo</artifactId>
    <version>1.0-SNAPSHOT</version>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>io.helidon.nima</groupId>
                <artifactId>helidon-nima-bom</artifactId>
                <version>4.0.6</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <dependencies>
        <dependency>
            <groupId>io.helidon.nima.grpc</groupId>
            <artifactId>helidon-nima-grpc-server</artifactId>
        </dependency>
        <dependency>
            <groupId>io.helidon.nima.grpc</groupId>
            <artifactId>helidon-nima-grpc-client</artifactId>
        </dependency>
        <dependency>
            <groupId>io.grpc</groupId>
            <artifactId>grpc-protobuf</artifactId>
        </dependency>
        <dependency>
            <groupId>io.grpc</groupId>
            <artifactId>grpc-stub</artifactId>
        </dependency>
        <dependency>
            <groupId>io.grpc</groupId>
            <artifactId>grpc-protobuf-java</artifactId>
        </dependency>
    </dependencies>

    <build>
        <extensions>
            <extension>
                <groupId>kr.motd.maven</groupId>
                <artifactId>os-maven-plugin</artifactId>
                <version>1.7.1</version>
            </extension>
        </extensions>
        <plugins>
            <plugin>
                <groupId>org.xolstice.maven.plugins</groupId>
                <artifactId>protobuf-maven-plugin</artifactId>
                <version>0.6.1</version>
                <configuration>
                    <protocArtifact>com.google.protobuf:protoc:3.24.4:exe:${os.detected.classifier}</protocArtifact>
                    <pluginId>grpc-java</pluginId>
                    <pluginArtifact>io.grpc:protoc-gen-grpc-java:1.59.0:exe:${os.detected.classifier}</pluginArtifact>
                </configuration>
                <executions>
                    <execution>
                        <goals>
                            <goal>compile</goal>
                            <goal>compile-custom</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.11.0</version>
                <configuration>
                    <source>17</source>
                    <target>17</target>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>

2. 定义gRPC协议文件 #

在src/main/proto目录下创建hello.proto：

syntax = "proto3";

package example;

service HelloService {
  rpc SayHello (HelloRequest) returns (HelloResponse);
}

message HelloRequest {
  string name = 1;
}

message HelloResponse {
  string message = 1;
}

3. 实现gRPC服务类 #

编译Protobuf后（执行mvn compile），编写服务实现类：

package example;

import io.helidon.nima.grpc.server.ServiceDescriptor;
import io.grpc.stub.StreamObserver;

public class HelloServiceImpl extends HelloServiceGrpc.HelloServiceImplBase {
    @Override
    public void sayHello(HelloRequest request, StreamObserver<HelloResponse> responseObserver) {
        String message = "Hello, " + request.getName() + "!";
        responseObserver.onNext(HelloResponse.newBuilder().setMessage(message).build());
        responseObserver.onCompleted();
    }

    public static ServiceDescriptor create() {
        return ServiceDescriptor.builder(HelloServiceGrpc.SERVICE_NAME)
                .unaryMethod("SayHello", HelloServiceGrpc.getSayHelloMethod(), new HelloServiceImpl()::sayHello)
                .build();
    }
}

4. 编写Nima服务器启动类 #

package example;

import io.helidon.nima.grpc.server.GrpcRouting;
import io.helidon.nima.webserver.WebServer;

public class GrpcServerMain {
    public static void main(String[] args) {
        GrpcRouting grpcRouting = GrpcRouting.builder()
                .register(HelloServiceImpl.create())
                .build();

        WebServer server = WebServer.builder()
                .port(50051)
                .addRouting("/grpc", grpcRouting)
                .build()
                .start();

        System.out.println("gRPC server running on port: " + server.port());
    }
}

5. 编写gRPC客户端 #

package example;

import io.helidon.nima.grpc.client.GrpcClient;
import io.helidon.nima.grpc.client.GrpcClientBuilder;

public class GrpcClientMain {
    public static void main(String[] args) {
        try (GrpcClient client = GrpcClientBuilder.forTarget("http://localhost:50051/grpc")
                .build()) {

            HelloServiceGrpc.HelloServiceBlockingStub stub = HelloServiceGrpc.newBlockingStub(client.channel());
            HelloResponse response = stub.sayHello(HelloRequest.newBuilder().setName("World").build());

            System.out.println("Received: " + response.getMessage());
        }
    }
}

6. 运行验证 #

1. 执行mvn compile生成Protobuf代码。
2. 启动GrpcServerMain，控制台输出服务端口信息。
3. 运行GrpcClientMain，将收到Received: Hello, World!的响应。

内容的提问来源于stack exchange，提问作者eof