From 2244a9b079f11d2171309e9bce9d4ff1edf7f8dd Mon Sep 17 00:00:00 2001 From: lipanpan03 <656461146@qq.com> Date: Wed, 15 Jan 2025 20:56:09 +0800 Subject: [PATCH 1/2] setMaxTotalConnections 1000 --- .../src/main/java/com/antgroup/tugraph/TuGraphDbRpcClient.java | 1 + 1 file changed, 1 insertion(+) diff --git a/rpc-client/src/main/java/com/antgroup/tugraph/TuGraphDbRpcClient.java b/rpc-client/src/main/java/com/antgroup/tugraph/TuGraphDbRpcClient.java index 92be758..7891792 100644 --- a/rpc-client/src/main/java/com/antgroup/tugraph/TuGraphDbRpcClient.java +++ b/rpc-client/src/main/java/com/antgroup/tugraph/TuGraphDbRpcClient.java @@ -363,6 +363,7 @@ private static class TuGraphSingleRpcClient { public TuGraphSingleRpcClient(String url, String user, String pass) { RpcClientOptions options = new RpcClientOptions(); + options.setMaxTotalConnections(1000); options.setProtocolType(Options.ProtocolType.PROTOCOL_BAIDU_STD_VALUE); options.setLoadBalanceType(LoadBalanceStrategy.LOAD_BALANCE_FAIR); options.setWriteTimeoutMillis(TIMEOUTINMS); From fa104f55764112ae0f871158e62e4816533584be Mon Sep 17 00:00:00 2001 From: lipanpan03 <656461146@qq.com> Date: Thu, 16 Jan 2025 11:11:53 +0800 Subject: [PATCH 2/2] setMaxTotalConnections 100 --- .../src/main/java/com/antgroup/tugraph/TuGraphDbRpcClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rpc-client/src/main/java/com/antgroup/tugraph/TuGraphDbRpcClient.java b/rpc-client/src/main/java/com/antgroup/tugraph/TuGraphDbRpcClient.java index 7891792..325c718 100644 --- a/rpc-client/src/main/java/com/antgroup/tugraph/TuGraphDbRpcClient.java +++ b/rpc-client/src/main/java/com/antgroup/tugraph/TuGraphDbRpcClient.java @@ -363,7 +363,7 @@ private static class TuGraphSingleRpcClient { public TuGraphSingleRpcClient(String url, String user, String pass) { RpcClientOptions options = new RpcClientOptions(); - options.setMaxTotalConnections(1000); + options.setMaxTotalConnections(100); options.setProtocolType(Options.ProtocolType.PROTOCOL_BAIDU_STD_VALUE); options.setLoadBalanceType(LoadBalanceStrategy.LOAD_BALANCE_FAIR); options.setWriteTimeoutMillis(TIMEOUTINMS);