grpc server client callbac 异步调用 Java 实现

在 Java 中，可以使用 gRPC 框架实现异步的 Server-Client 回调调用。下面是一个简单的示例：

1. 定义 gRPC 服务

在.proto文件中定义服务接口和参数：

syntax = "proto3";

package com.example.grpc;

service MyService {
  rpc myMethod(RequestMessage) returns (stream ResponseMessage) {}
}

message RequestMessage {
  string message = 1;
}

message ResponseMessage {
  string message = 1;
}

2. 生成代码

使用 protoc 工具生成 Java 代码：

protoc --java_out=./src/main/java/ ./src/main/proto/my_service.proto

3. 实现服务接口

编写服务实现类 MyServiceImpl.java：

package com.example.grpc;

import io.grpc.stub.StreamObserver;

public class MyServiceImpl extends MyServiceGrpc.MyServiceImplBase {

    @Override
    public void myMethod(RequestMessage request, StreamObserver<ResponseMessage> responseObserver) {
        // 处理请求
        String requestMessage = request.getMessage();
        String responseMessage = "Hello, " + requestMessage + "!";
        ResponseMessage response = ResponseMessage.newBuilder().setMessage(responseMessage).build();

        // 发送响应
        responseObserver.onNext(response);
        responseObserver.onCompleted();
    }
}

4. 编写客户端代码

package com.example.grpc;

import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;
import io.grpc.stub.StreamObserver;

public class MyClient {

    public static void main(String[] args) {
        // 创建 channel
        ManagedChannel channel = ManagedChannelBuilder.forAddress("localhost", 8080).usePlaintext().build();

        // 创建 stub
        MyServiceGrpc.MyServiceStub stub = MyServiceGrpc.newStub(channel);

        // 创建 request
        RequestMessage request = RequestMessage.newBuilder().setMessage("World").build();

        // 发送请求
        stub.myMethod(request, new StreamObserver<ResponseMessage>() {

            @Override
            public void onNext(ResponseMessage response) {
                // 处理响应
                String responseMessage = response.getMessage();
                System.out.println(responseMessage);
            }

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

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

5. 运行程序

启动 gRPC 服务端和客户端程序，即可进行异步的 Server-Client 回调调用。