grpc java中的低级事件

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

public class GrpcClient {
    public static void main(String[] args) {
        ManagedChannel channel = ManagedChannelBuilder.forAddress("localhost", 50051)
                .usePlaintext()
                .build();

        // 启用低级事件日志
        channel.intercept(new LoggingInterceptor());

        // 创建服务存根并调用远程方法
        MyServiceGrpc.MyServiceBlockingStub stub = MyServiceGrpc.newBlockingStub(channel);
        try {
            MyResponse response = stub.myMethod(MyRequest.newBuilder().build());
            System.out.println("Response: " + response);
        } catch (StatusRuntimeException e) {
            System.err.println("RPC failed: " + e.getStatus());
        }

        channel.shutdown();
    }
}

class LoggingInterceptor implements ClientInterceptor {
    @Override
    public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(MethodDescriptor<ReqT, RespT> method,
                                                             CallOptions callOptions, Channel next) {
        return new ForwardingClientCall.SimpleForwardingClientCall<ReqT, RespT>(next.newCall(method, callOptions)) {
            @Override
            public void start(Listener<RespT> responseListener, Metadata headers) {
                super.start(new ForwardingClientCallListener.SimpleForwardingClientCallListener<RespT>(responseListener) {
                    @Override
                    public void onReady() {
                        System.out.println("Call is ready");
                        super.onReady();
                    }

                    @Override
                    public void onClose(Status status, Metadata trailers) {
                        System.out.println("Call closed with status: " + status);
                        super.onClose(status, trailers);
                    }
                }, headers);
            }
        };
    }
}