支持泛化调用么 about starlight HOT 4 CLOSED

public interface GenericService {
    
    Object $invoke(String serviceName, String methodName, String[] parameterTypes, Object[] args) throws RuntimeException;
    
    Future<Object> $invokeAsync(String serviceName, String methodName, String[] parameterTypes, Object[] args) throws RuntimeException;
}

public class RpcClientTest {
    
    public static void main(String[] args) {
        RpcClientOptions clientOption = new RpcClientOptions();
        clientOption.setProtocolType(Options.ProtocolType.PROTOCOL_BAIDU_STD_VALUE);
        clientOption.setWriteTimeoutMillis(1000);
        clientOption.setReadTimeoutMillis(1000);
        clientOption.setMaxTotalConnections(1000);
        clientOption.setMinIdleConnections(10);
//        clientOption.setIoThreadNum(40);
        clientOption.setLoadBalanceType(LoadBalanceStrategy.LOAD_BALANCE_FAIR);
        clientOption.setCompressType(Options.CompressType.COMPRESS_TYPE_NONE);
        
        String serviceUrl = "list://127.0.0.1:8002";
        if (args.length == 1) {
            serviceUrl = args[0];
        }
        
        List<Interceptor> interceptors = new ArrayList<Interceptor>();
        interceptors.add(new CustomInterceptor());
        
        // build request
        Map<String, Object> request = new HashMap<>();
        request.put("message", "hellooooooooooooooooooooooooooooooooooooooooooooooooooooooooooooooooooo");
        
        // async call
        RpcClient rpcClient = new RpcClient(serviceUrl, clientOption, interceptors);
        RpcCallback<EchoResponse> callback = new RpcCallback<EchoResponse>() {
            @Override
            public void success(EchoResponse response) {
                if (response != null) {
                    System.out.printf("async call EchoService.echo success, response=%s\n",
                            response.getMessage());
                } else {
                    System.out.println("async call failed, service=EchoService.echo");
                }
            }
            
            @Override
            public void fail(Throwable e) {
                System.out.printf("async call EchoService.echo failed, %s\n", e.getMessage());
            }
        };
        GenericService asyncEchoService = BrpcProxy.getProxy(rpcClient, GenericService.class);
        try {
            Future<Object> future = asyncEchoService.$invokeAsync("com.baidu.brpc.example.jprotobuf.EchoServiceAsync",
                    "echo",
                    new String[]{"com.baidu.brpc.example.jprotobuf.EchoRequest", "com.baidu.brpc.client.RpcCallback"},
                    new Object[]{request, callback});
            try {
                if (future != null) {
                    future.get();
                }
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        } catch (RpcException ex) {
            System.out.println("rpc send failed, ex=" + ex.getMessage());
        }
        rpcClient.stop();
        System.out.println("brpc client finished...");
    }
    
}