From 11d59f12fb00a924765352ac4192dbf02bdfb35e Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期二, 14 一月 2020 16:50:04 +0800
Subject: [PATCH] fix
---
mangos.go | 20 +++++++++++---------
1 files changed, 11 insertions(+), 9 deletions(-)
diff --git a/mangos.go b/mangos.go
index 480be38..a194c2e 100644
--- a/mangos.go
+++ b/mangos.go
@@ -62,19 +62,21 @@
// clientMsgCh[nodeId] = make(chan Message)
// }
//}
-
- if len(cacheNodes.Difference(nodeIds).ToSlice()) > 0 { //鑺傜偣鏈夊彉鍖栫殑鏃跺�欙紝涔熼渶瑕佸彂娑堟伅
- fmt.Println("aliveNodes:",nodeIds)
- if len(msgCache) > 0 {
- for _,cMsg := range msgCache {
- sendB, _ := json.Marshal(cMsg)
- discoveryServer.PublishMsg(string(sendB))
+ if len(nodeIds.ToSlice()) >0 {
+ if len(nodeIds.Difference(cacheNodes).ToSlice()) > 0 { //鑺傜偣鏈夊彉鍖栫殑鏃跺�欙紝涔熼渶瑕佸彂娑堟伅
+ fmt.Println("aliveNodes:",nodeIds)
+ if len(msgCache) > 0 {
+ for _,cMsg := range msgCache {
+ sendB, _ := json.Marshal(cMsg)
+ discoveryServer.PublishMsg(string(sendB))
+ }
}
}
- } else {
+ cacheNodes = discoveryServer.AliveNodes()
+ } else {//璁㈤槄鑰呭叏閮ㄩ樀浜�
+ cacheNodes = discoveryServer.AliveNodes()
time.Sleep(10 * time.Millisecond)
}
- cacheNodes = discoveryServer.AliveNodes()
}
}
}()
--
Gitblit v1.8.0