fix: 修复 switchServerAsync 在重连进行中导致的阻塞问题

xiaomudk · xiaomudk · commit aced6b664b0a · 2026-01-05T21:22:33.000+08:00
diff --git a/common/remote/rpc/rpc_client.go b/common/remote/rpc/rpc_client.go
@@ -407,7 +407,12 @@ func (r *RpcClient) RegisterConnectionListener(listener IConnectionEventListener
 }
 
 func (r *RpcClient) switchServerAsync(recommendServerInfo ServerInfo, onRequestFail bool) {
-	r.reconnectionChan <- ReconnectContext{serverInfo: recommendServerInfo, onRequestFail: onRequestFail}
+	select {
+	case r.reconnectionChan <- ReconnectContext{serverInfo: recommendServerInfo, onRequestFail: onRequestFail}:
+	default:
+		logger.Warnf("reconnection already in progress, skip this request")
+	}
+
 }
 
 func (r *RpcClient) reconnect(serverInfo ServerInfo, onRequestFail bool) {

Original file line number	Diff line number	Diff line change
`@@ -407,7 +407,12 @@ func (r *RpcClient) RegisterConnectionListener(listener IConnectionEventListener`
`407`	`407`	`}`
`408`	`408`
`409`	`409`	`func (r *RpcClient) switchServerAsync(recommendServerInfo ServerInfo, onRequestFail bool) {`
`410`		`- r.reconnectionChan <- ReconnectContext{serverInfo: recommendServerInfo, onRequestFail: onRequestFail}`
	`410`	`+ select {`
	`411`	`+ case r.reconnectionChan <- ReconnectContext{serverInfo: recommendServerInfo, onRequestFail: onRequestFail}:`
	`412`	`+ default:`
	`413`	`+ logger.Warnf("reconnection already in progress, skip this request")`
	`414`	`+ }`
	`415`	`+`
`411`	`416`	`}`
`412`	`417`
`413`	`418`	`func (r *RpcClient) reconnect(serverInfo ServerInfo, onRequestFail bool) {`