diff --git a/internal/rpc/rpc_client.go b/internal/rpc/rpc_client.go index 84c30cc..f34eed7 100644 --- a/internal/rpc/rpc_client.go +++ b/internal/rpc/rpc_client.go @@ -231,8 +231,8 @@ func (this *RPCClient) init() error { // 随机选择一个连接 func (this *RPCClient) pickConn() *grpc.ClientConn { - this.locker.RLock() - defer this.locker.RUnlock() + this.locker.Lock() + defer this.locker.Unlock() // 检查连接状态 if len(this.conns) > 0 {