grpc callback 方式异步调用 server Java 实现

在 gRPC 中，异步调用可以通过使用回调函数实现。以下是在 Java 中实现 gRPC 回调的步骤：

1. 创建一个异步客户端

ManagedChannel channel = ManagedChannelBuilder.forAddress(host, port).usePlaintext().build();
MyServiceGrpc.MyServiceStub stub = MyServiceGrpc.newStub(channel);

2. 实现回调方法

StreamObserver<MyResponse> responseObserver = new StreamObserver<MyResponse>() {
    @Override
    public void onNext(MyResponse response) {
        // 处理响应
    }

    @Override
    public void onError(Throwable t) {
        // 处理异常
    }

    @Override
    public void onCompleted() {
        // 处理完成事件
    }
};

3. 创建请求并发送

MyRequest request = MyRequest.newBuilder().build();
stub.myMethod(request, responseObserver);

在上面的代码中，`myMethod` 是异步方法，`request` 是请求对象，`responseObserver` 是回调对象。

当服务端响应请求时，`onNext` 方法会被调用，可以在此方法中处理响应。如果出现异常，则会调用 `onError` 方法，如果请求完成，则会调用 `onCompleted` 方法。