diff --git a/internal/nodes/client_conn.go b/internal/nodes/client_conn.go index b0e58f3..885c540 100644 --- a/internal/nodes/client_conn.go +++ b/internal/nodes/client_conn.go @@ -129,9 +129,8 @@ func (this *ClientConn) Close() error { err := this.rawConn.Close() // 单个服务并发数限制 - if this.hasLimit { - sharedClientConnLimiter.Remove(this.rawConn.RemoteAddr().String()) - } + // 不能加条件限制,因为服务配置随时有变化 + sharedClientConnLimiter.Remove(this.rawConn.RemoteAddr().String()) return err }