diff --git a/cluster/cluster.go b/cluster/cluster.go index 58299d8..2192d8e 100644 --- a/cluster/cluster.go +++ b/cluster/cluster.go @@ -116,6 +116,9 @@ func (slf *CCluster) ConnService() error { //连接集群服务器 for _, nodeList := range slf.cfg.mapClusterNodeService { for _, node := range nodeList { + if node.NodeID == slf.cfg.currentNode.NodeID { + continue + } slf.nodeclient[node.NodeID] = &RpcClient{node.NodeID, nil, node.ServerAddr, false} } }