grpc callback 方式异步调用 Java 实现

在 Java 中使用 gRPC 调用时，可以通过异步方式进行回调。下面是一个简单的示例代码，演示了如何使用回调方式进行异步调用：

public class GrpcClient {

    private final ManagedChannel channel;
    private final GreeterGrpc.GreeterStub stub;

    public GrpcClient(String host, int port) {
        channel = ManagedChannelBuilder.forAddress(host, port)
                .usePlaintext()
                .build();
        stub = GreeterGrpc.newStub(channel);
    }

    public void greet(String name, StreamObserver<GreeterOuterClass.HelloReply> responseObserver) {
        GreeterOuterClass.HelloRequest request = GreeterOuterClass.HelloRequest.newBuilder().setName(name).build();
        stub.sayHello(request, responseObserver);
    }

    public void shutdown() throws InterruptedException {
        channel.shutdown().awaitTermination(5, TimeUnit.SECONDS);
    }

    public static void main(String[] args) throws InterruptedException {
        GrpcClient client = new GrpcClient("localhost", 50051);

        StreamObserver<GreeterOuterClass.HelloReply> responseObserver = new StreamObserver<GreeterOuterClass.HelloReply>() {
            @Override
            public void onNext(GreeterOuterClass.HelloReply value) {
                System.out.println("Received response: " + value.getMessage());
            }

            @Override
            public void onError(Throwable t) {
                System.err.println("Error: " + t.getMessage());
            }

            @Override
            public void onCompleted() {
                System.out.println("Completed.");
            }
        };

        client.greet("world", responseObserver);

        Thread.sleep(1000);

        client.shutdown();
    }
}

在上面的代码中，我们创建了一个 `GrpcClient` 类，用于与 gRPC 服务进行通信。`greet` 方法用于发送请求，并将回调对象 `responseObserver` 作为参数传递给 `stub.sayHello` 方法。`responseObserver` 对象包含三个方法：`onNext`、`onError` 和 `onCompleted`，用于处理服务端的响应。

在 `main` 方法中，我们首先创建了一个 `GrpcClient` 对象，并创建了一个 `responseObserver` 对象，用于处理服务端的响应。然后我们调用 `greet` 方法发送请求，并在 1 秒后关闭客户端。

注意，这里使用了 `Thread.sleep` 方法来模拟异步回调的情况，实际应用中应该使用更加高效和灵活的方式进行异步回调。