From 06ec4d3fba13c388596a9ac619875f6f7ba42f82 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= <iwind.liu@gmail.com>
Date: Thu, 17 Nov 2022 10:38:20 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/rpc/rpc_client.go | 17 +----------------
 1 file changed, 1 insertion(+), 16 deletions(-)

diff --git a/internal/rpc/rpc_client.go b/internal/rpc/rpc_client.go
index 64b61fc..37dcba6 100644
--- a/internal/rpc/rpc_client.go
+++ b/internal/rpc/rpc_client.go
@@ -218,12 +218,12 @@ func (this *RPCClient) pickConn() *grpc.ClientConn {
 
 	// 检查连接状态
 	if len(this.conns) > 0 {
-		var availableConns = []*grpc.ClientConn{}
 		for _, stateArray := range [][2]connectivity.State{
 			{connectivity.Ready, connectivity.Idle}, // 优先Ready和Idle
 			{connectivity.Connecting, connectivity.Connecting},
 			{connectivity.TransientFailure, connectivity.TransientFailure},
 		} {
+			var availableConns = []*grpc.ClientConn{}
 			for _, conn := range this.conns {
 				var state = conn.GetState()
 				if state == stateArray[0] || state == stateArray[1] {
@@ -234,21 +234,6 @@ func (this *RPCClient) pickConn() *grpc.ClientConn {
 				return this.randConn(availableConns)
 			}
 		}
-
-		if len(availableConns) > 0 {
-			return this.randConn(availableConns)
-		}
-	}
-
-	// 重新初始化
-	err := this.init()
-	if err != nil {
-		// 错误提示已经在构造对象时打印过，所以这里不再重复打印
-		return nil
-	}
-
-	if len(this.conns) == 0 {
-		return nil
 	}
 
 	return this.randConn(this.conns)