优化RPC调用

internal/iplibrary/manager_ip_list.go

@@ -53,6 +53,7 @@ func (this *IPListManager) Start() {
 	events.On(events.EventQuit, func() {
 		ticker.Stop()
 	})
+	countErrors := 0
 	for {
 		select {
 		case <-ticker.C:
@@ -60,15 +61,20 @@ func (this *IPListManager) Start() {
 		}
 		err := this.loop()
 		if err != nil {
+			countErrors++
+
 			logs.Println("IP_LIST_MANAGER", err.Error())
 
-			// 方便立即重试
+			// 连续错误小于3次的我们立即重试
+			if countErrors <= 3 {
 				select {
 				case IPListUpdateNotify <- true:
 				default:
-
 				}
 			}
+		} else {
+			countErrors = 0
+		}
 	}
 }
 

internal/rpc/rpc_client.go

@@ -181,11 +181,16 @@ func (this *RPCClient) pickConn() *grpc.ClientConn {
 	// 检查连接状态
 	if len(this.conns) > 0 {
 		availableConns := []*grpc.ClientConn{}
+		for _, state := range []connectivity.State{connectivity.Ready, connectivity.Idle, connectivity.Connecting} {
 			for _, conn := range this.conns {
-			if conn.GetState() == connectivity.Ready {
+				if conn.GetState() == state {
 					availableConns = append(availableConns, conn)
 				}
 			}
+			if len(availableConns) > 0 {
+				break
+			}
+		}
 
 		if len(availableConns) > 0 {
 			return availableConns[rands.Int(0, len(availableConns)-1)]