grpc server client callback 方式异步调用 java 实现

在 gRPC 中，可以通过服务端回调（Server-side Callbacks）和客户端回调（Client-side Callbacks）来实现异步调用。

Java 实现方式如下：

1. 服务端回调

在服务端实现异步回调，需要定义一个回调接口，并在服务端实现该接口。例如：

service MyService {
  rpc MyMethod(MyRequest) returns (stream MyResponse) {}
}

message MyRequest {
  string request = 1;
}

message MyResponse {
  string response = 1;
}

service MyCallbackService {
  rpc MyCallbackMethod(MyCallbackRequest) returns (MyCallbackResponse) {}
}

message MyCallbackRequest {
  string response = 1;
}

message MyCallbackResponse {}

在服务端实现 MyService 的 MyMethod 方法时，可以通过异步方式调用 MyCallbackService 的 MyCallbackMethod 方法，并将回调结果返回给客户端：

public void myMethod(MyRequest request, StreamObserver<MyResponse> responseObserver) {
  // 异步调用回调方法
  myCallbackService.myCallbackMethod(MyCallbackRequest.newBuilder().setResponse("callback").build(),
    new StreamObserver<MyCallbackResponse>() {
      @Override
      public void onNext(MyCallbackResponse value) {
        // 处理回调结果
        responseObserver.onNext(MyResponse.newBuilder().setResponse(value.getResponse()).build());
      }

      @Override
      public void onError(Throwable t) {
        responseObserver.onError(t);
      }

      @Override
      public void onCompleted() {
        responseObserver.onCompleted();
      }
    });
}

2. 客户端回调

在客户端实现异步回调，需要定义一个回调接口，并在客户端中实现该接口。例如：

service MyService {
  rpc MyMethod(MyRequest) returns (stream MyResponse) {}
}

message MyRequest {
  string request = 1;
}

message MyResponse {
  string response = 1;
}

service MyCallbackService {
  rpc MyCallbackMethod(MyCallbackRequest) returns (MyCallbackResponse) {}
}

message MyCallbackRequest {
  string response = 1;
}

message MyCallbackResponse {}

在客户端调用 MyService 的 MyMethod 方法时，可以通过异步方式处理服务端返回的数据，并在回调方法中处理结果：

public void myMethod() {
  myServiceStub.myMethod(MyRequest.newBuilder().setRequest("request").build(),
    new StreamObserver<MyResponse>() {
      @Override
      public void onNext(MyResponse value) {
        // 处理服务端返回的结果
      }

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

      @Override
      public void onCompleted() {
        // 处理服务端通知数据流结束的情况
      }
    });
}