优化RPC连接

This commit is contained in:
GoEdgeLab
2020-11-13 18:22:56 +08:00
parent d2b88abb8f
commit 332632ab9f
2 changed files with 9 additions and 0 deletions

View File

@@ -190,6 +190,11 @@ func (this *RPCClient) pickConn() *grpc.ClientConn {
if len(availableConns) > 0 {
return availableConns[rands.Int(0, len(availableConns)-1)]
}
// 关闭
for _, conn := range this.conns {
_ = conn.Close()
}
}
// 重新初始化