From fd6fa929de62bae2018f7ab5e93f7c53406507e5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= Date: Mon, 25 Jul 2022 19:48:03 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E8=BF=9E=E6=8E=A5=E6=95=B0?= =?UTF-8?q?=E9=99=90=E5=88=B6=E8=AE=A1=E7=AE=97=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/nodes/client_conn.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) 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 }