From a7e4c833c7edcf55f08657660682ecf242882390 Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期二, 14 一月 2020 20:40:44 +0800
Subject: [PATCH] fix
---
mangos.go | 6 ++----
1 files changed, 2 insertions(+), 4 deletions(-)
diff --git a/mangos.go b/mangos.go
index 47a9b0d..a59c188 100644
--- a/mangos.go
+++ b/mangos.go
@@ -12,7 +12,6 @@
heartBeatUrl string
pubCh chan Message //publish msg chan
aliveNodes gopherdiscovery.StringSet
- clients map[string][]string
recvCh chan Message //recv msg chan
}
@@ -31,13 +30,12 @@
discoveryServer, err = gopherdiscovery.Server(heartBeatUrl, publishUrl, defaultOpts)
- fmt.Println("err:",err)
+ fmt.Println("newPub err:",err)
pub := &mangosPubSub{
url: publishUrl,
heartBeatUrl: heartBeatUrl,
aliveNodes: gopherdiscovery.NewStringSet(),
pubCh: make(chan Message, 50),
- clients: make(map[string][]string),
}
var msgCache = make(map[string]Message)
//clientMsgCh := make(map[string]chan Message)
@@ -67,7 +65,7 @@
removedNodes := cacheNodes.Difference(nodeIds)
addedNodes := nodeIds.Difference(cacheNodes)
if len(nodeIds.ToSlice()) >0 {
- if removedNodes.Cardinality() >0 || addedNodes.Cardinality() >0 { //鑺傜偣鏈夊彉鍖栫殑鏃跺�欙紝涔熼渶瑕佸彂娑堟伅
+ if addedNodes.Cardinality() >0 { //鏈夋柊鑺傜偣涓婄嚎鐨勬椂鍊欙紝闇�瑕佸彂涓�娆℃秷鎭紝鑺傜偣绂荤嚎鐨勬椂鍊欎笉鐢ㄧ
fmt.Println("removedNodes:", removedNodes, "addedNodes:", addedNodes)
if len(msgCache) > 0 {
for _,cMsg := range msgCache {
--
Gitblit v1.8.0