grpc callback 异步方式调用 java 实现

使用 gRPC Callback 可以实现异步方法调用，下面是一个简单的示例代码：

服务端实现：

public class AsyncGreeterImpl extends GreeterGrpc.GreeterImplBase {

    @Override
    public void sayHello(HelloRequest request, StreamObserver<HelloReply> responseObserver) {
        // 异步处理请求，并使用回调函数处理返回结果
        new Thread(() -> {
            String message = "Hello, " + request.getName() + "!";
            HelloReply reply = HelloReply.newBuilder().setMessage(message).build();
            responseObserver.onNext(reply);
            responseObserver.onCompleted();
        }).start();
    }
}

客户端调用：

public class AsyncGreeterClient {
    private final GreeterGrpc.GreeterStub stub;

    public AsyncGreeterClient(Channel channel) {
        stub = GreeterGrpc.newStub(channel);
    }

    public void sayHello(String name, StreamObserver<HelloReply> observer) {
        HelloRequest request = HelloRequest.newBuilder().setName(name).build();
        // 调用异步方法，使用回调函数处理返回结果
        stub.sayHello(request, observer);
    }
}

在客户端中，可以创建 StreamObserver 对象作为回调函数处理异步返回结果，示例代码如下：

AsyncGreeterClient client = new AsyncGreeterClient(channel);
client.sayHello("World", new StreamObserver<HelloReply>() {
    @Override
    public void onNext(HelloReply value) {
        System.out.println(value.getMessage());
    }
    @Override
    public void onError(Throwable t) {
        t.printStackTrace();
    }
    @Override
    public void onCompleted() {
        // 完成调用
    }
});

以上就是使用 gRPC Callback 实现服务端异步调用的简单示例。