优化服务发现

2026-02-07 01:04:41 +08:00 · 2024-04-30 19:05:44 +08:00
1 changed files with 4 additions and 0 deletions
--- a/cluster/origindiscovery.go
+++ b/cluster/origindiscovery.go
@@ -183,6 +183,10 @@ func (ds *OriginDiscoveryMaster) OnNodeDisconnect(nodeId string) {

 func (ds *OriginDiscoveryMaster) RpcCastGo(serviceMethod string, args interface{}) {
 	for nodeId, _ := range ds.mapNodeInfo {
+		if nodeId == cluster.GetLocalNodeInfo().NodeId {
+			continue
+		}
+
 		ds.GoNode(nodeId, serviceMethod, args)
 	}
 }