Skip to content

Commit 42fe0c8

Browse files
committed
add connectionPool
1 parent 8afa0eb commit 42fe0c8

File tree

1 file changed

+9
-5
lines changed

1 file changed

+9
-5
lines changed

07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/client/RpcfxInvocationHandler.java

Lines changed: 9 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -2,15 +2,13 @@
22

33
import com.alibaba.fastjson.JSON;
44
import io.kimmking.rpcfx.api.*;
5-
import okhttp3.MediaType;
6-
import okhttp3.OkHttpClient;
7-
import okhttp3.Request;
8-
import okhttp3.RequestBody;
5+
import okhttp3.*;
96

107
import java.io.IOException;
118
import java.lang.reflect.InvocationHandler;
129
import java.lang.reflect.Method;
1310
import java.util.List;
11+
import java.util.concurrent.TimeUnit;
1412

1513
public class RpcfxInvocationHandler implements InvocationHandler {
1614

@@ -75,7 +73,13 @@ public Object invoke(Object proxy, Method method, Object[] params) throws Throwa
7573
return JSON.parse(response.getResult().toString());
7674
}
7775

78-
OkHttpClient client = new OkHttpClient();
76+
OkHttpClient client = new OkHttpClient.Builder()
77+
.connectionPool(new ConnectionPool(128, 60, TimeUnit.SECONDS))
78+
// .dispatcher(dispatcher)
79+
// .readTimeout(httpClientConfig.getReadTimeout(), TimeUnit.SECONDS)
80+
// .writeTimeout(httpClientConfig.getWriteTimeout(), TimeUnit.SECONDS)
81+
// .connectTimeout(httpClientConfig.getConnectTimeout(), TimeUnit.SECONDS)
82+
.build();
7983

8084
private RpcfxResponse post(RpcfxRequest req, String url) throws IOException {
8185
String reqJson = JSON.toJSONString(req);

0 commit comments

Comments
 (0)