fix

liuxiaolong

2020-01-14 a7e4c833c7edcf55f08657660682ecf242882390

 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 {