减少rpc client的写管道大小

2026-02-03 22:45:13 +08:00 · 2021-06-29 16:00:14 +08:00
parent a41547f121
commit 745caa88de
1 changed files with 1 additions and 1 deletions
--- a/rpc/client.go
+++ b/rpc/client.go
@@ -47,7 +47,7 @@ func (client *Client) Connect(id int,addr string) error {
 	client.callRpcTimeout = 15*time.Second
 	client.ConnNum = 1
 	client.ConnectInterval = time.Second*2
-	client.PendingWriteNum = 2000000
+	client.PendingWriteNum = 200000
 	client.AutoReconnect = true
 	client.LenMsgLen = 2
 	client.MinMsgLen = 2