grpc client server Callback方式 异步调用 Java 实现

gRPC 是一个高性能、开源和通用的 RPC 框架，支持多种语言。在 Java 中，gRPC 提供了基于异步调用的 API，其中包括 Callback 方式。

在 gRPC 中，客户端和服务端之间的通信是通过 gRPC Stub 和 gRPC Server 实现的。客户端通过 Stub 发送请求，服务端通过 Server 处理请求并返回响应。

对于异步调用，客户端先创建一个异步 stub，然后通过该 stub 发送请求，服务端收到请求后异步处理，处理完成后通过回调方式通知客户端。客户端通过回调函数来处理返回结果。

下面是一个简单的 gRPC Callback 示例，包括客户端和服务端的实现。

1. 客户端

// 创建异步 stub
ManagedChannel channel = ManagedChannelBuilder.forAddress("localhost", 50051)
        .usePlaintext()
        .build();
AsyncGreeterGrpc.AsyncGreeterStub stub = AsyncGreeterGrpc.newStub(channel);

// 构造请求
HelloRequest request = HelloRequest.newBuilder().setName("world").build();

// 发送请求并注册回调
stub.sayHello(request, new StreamObserver<HelloReply>() {
    @Override
    public void onNext(HelloReply reply) {
        // 处理响应
        System.out.println(reply.getMessage());
    }

    @Override
    public void onError(Throwable t) {
        // 处理错误
    }

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

2. 服务端

// 实现异步服务
public void sayHello(HelloRequest request, StreamObserver<HelloReply> responseObserver) {
    // 处理请求
    String message = "Hello " + request.getName() + "!";
    HelloReply reply = HelloReply.newBuilder().setMessage(message).build();

    // 异步返回响应
    responseObserver.onNext(reply);
    responseObserver.onCompleted();
}

// 启动服务
Server server = ServerBuilder.forPort(50051)
        .addService(new GreeterImpl())
        .build();
server.start();

在客户端的示例代码中，我们创建了一个异步的 gRPC stub，并发送了一个异步请求。在 `sayHello()` 方法中，我们注册了一个回调函数，用于处理服务端返回的结果。当服务端处理请求完成后，会调用回调函数中的 `onNext()` 方法，并将结果传递给客户端。如果发生错误，则调用 `onError()` 方法；如果处理完成，则调用 `onCompleted()` 方法。

在服务端的示例代码中，我们实现了一个异步的 gRPC 服务，并注册了一个处理请求的方法 `sayHello()`。当服务端收到客户端的请求后，会调用该方法进行异步处理，并通过回调函数返回结果。

需要注意的是，在 gRPC 中，客户端和服务端之间的通信是基于 HTTP/2 的，因此可以实现双向流、流控制和多路复用等功能。同时，gRPC 也支持使用 SSL/TLS 加密通信，确保通信的安全性。