Closed baiyin1115 closed 5 years ago
// serialize request byte[] requestBytes = xxlRpcReferenceBean.getSerializer().serialize(xxlRpcRequest); // httpclient HttpClient httpClient = getJettyHttpClient(xxlRpcReferenceBean.getInvokerFactory()); // request Request request = httpClient.newRequest(reqURL); request.method(HttpMethod.POST); request.timeout(xxlRpcReferenceBean.getTimeout() + 500, TimeUnit.MILLISECONDS); // async, not need timeout request.content(new BytesContentProvider(requestBytes)); // invoke request.send(new BufferingResponseListener() {
你好,rpc场景不建议传输大数据包,会阻塞请求。如果由特殊需求,可以自行定制,也欢迎PR啊。