使用Java连接AWS EKS上的gRPC微服务：实践指南

syntax = "proto3"; // 指定使用Protocol Buffers v3语法

option java_multiple_files = true; // 为每个顶级消息和枚举生成单独的Java文件
option java_package = "io.grpc.examples.helloworld"; // 指定生成的Java类的包名
option java_outer_classname = "HelloWorldProto"; // 指定包含所有其他类的Java外部类的名称

package helloworld; // 定义协议缓冲区包名

// Greeter服务定义
service Greeter {
  // 定义一个SayHello方法，接收HelloRequest并返回HelloReply
  rpc SayHello (HelloRequest) returns (HelloReply) {}
}

// HelloRequest消息定义
message HelloRequest {
  string name = 1; // 字段1，类型为字符串，字段名为name
}

// HelloReply消息定义
message HelloReply {
  string message = 1; // 字段1，类型为字符串，字段名为message
}

<dependencies>
    <!-- gRPC Core -->
    <dependency>
        <groupId>io.grpc</groupId>
        <artifactId>grpc-netty-shaded</artifactId>
        <version>1.59.0</version> <!-- 请使用最新稳定版本 -->
    </dependency>
    <dependency>
        <groupId>io.grpc</groupId>
        <artifactId>grpc-protobuf</artifactId>
        <version>1.59.0</version>
    </dependency>
    <dependency>
        <groupId>io.grpc</groupId>
        <artifactId>grpc-stub</artifactId>
        <version>1.59.0</version>
    </dependency>
    <!-- 用于日志记录，可选 -->
    <dependency>
        <groupId>javax.annotation</groupId>
        <artifactId>javax.annotation-api</artifactId>
        <version>1.3.2</version>
    </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.0:exe:${os.detected.classifier}</protocArtifact>
                <pluginId>grpc-java</pluginId>
                <pluginArtifact>io.grpc:protoc-gen-grpc-java:1.59.0:exe:${os.detected.classifier}</pluginArtifact>
                <protoSourceRoot>src/main/proto</protoSourceRoot> <!-- .proto文件存放路径 -->
                <outputDirectory>${project.build.directory}/generated-sources/protobuf/java</outputDirectory>
                <clearOutputDirectory>false</clearOutputDirectory>
            </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.8.1</version>
            <configuration>
                <source>1.8</source>
                <target>1.8</target>
            </configuration>
        </plugin>
    </plugins>
</build>

package io.grpc.examples.helloworld;

import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;
import io.grpc.StatusRuntimeException;
import java.util.concurrent.TimeUnit;
import java.util.logging.Level;
import java.util.logging.Logger;

public class HelloWorldClient {
    private static final Logger logger = Logger.getLogger(HelloWorldClient.class.getName());

    private final ManagedChannel channel;
    private final GreeterGrpc.GreeterBlockingStub blockingStub; // 阻塞式存根

    /**
     * 构造客户端，用于访问指定主机和端口的Greeter服务。
     * @param host gRPC服务的主机名或IP地址。
     * @param port gRPC服务的端口。
     */
    public HelloWorldClient(String host, int port) {
        // 构建ManagedChannel。
        // .usePlaintext() 表示使用非加密连接，适用于测试环境。
        // 生产环境应配置TLS/SSL加密：.useTransportSecurity() 并配置证书。
        this(ManagedChannelBuilder.forAddress(host, port)
                .usePlaintext()
                .build());
    }

    HelloWorldClient(ManagedChannel channel) {
        this.channel = channel;
        // 创建阻塞式存根，可以同步地调用RPC方法。
        blockingStub = GreeterGrpc.newBlockingStub(channel);
    }

    /**
     * 关闭客户端通道，释放资源。
     * @throws InterruptedException 如果在等待关闭时线程被中断。
     */
    public void shutdown() throws InterruptedException {
        channel.shutdown().awaitTermination(5, TimeUnit.SECONDS);
    }

    /**
     * 向服务器发送“Hello”请求。
     * @param name 要问候的名字。
     */
    public void greet(String name) {
        logger.info("尝试向 " + name + " 发送问候...");
        // 构建请求消息
        HelloRequest request = HelloRequest.newBuilder().setName(name).build();
        HelloReply response;
        try {
            // 调用RPC方法
            response = blockingStub.sayHello(request);
        } catch (StatusRuntimeException e) {
            logger.log(Level.WARNING, "RPC 调用失败: {0}", e.getStatus());
            return;
        }
        logger.info("收到问候: " + response.getMessage());
    }

    public static void main(String[] args) throws Exception {
        // TODO: 替换为您的EKS gRPC服务的主机和端口
        // 这可能是EKS LoadBalancer的DNS名称、NodePort的IP和端口，或内部ClusterIP（如果客户端也在EKS内部）
        String targetHost = "your-eks-grpc-service-host"; // 例如: a1234567890abcdef.elb.us-east-1.amazonaws.com
        int targetPort = 50051; // 您的gRPC服务实际监听的端口，默认为50051

        HelloWorldClient client = new HelloWorldClient(targetHost, targetPort);
        try {
            String user = "world";
            if (args.length > 0) {
                user = args[0];
            }
            client.greet(user);
        } finally {
            // 确保在程序结束时关闭通道
            client.shutdown();
        }
    }
}