add aliveNodes

liuxiaolong

2020-01-14 0a79992edbc0406d274626c5ad86691b7c5c1fa7

add aliveNodes

 mangos.go

@@ -55,33 +55,30 @@
                    discoveryServer.PublishMsg(string(sendB))
                }
            default:
                nodeIds := discoveryServer.AliveNodes().ToSlice()
                if len(nodeIds) >0 {
                    //for _,nodeId := range nodeIds {
                    //    if _,ok := clientMsgCh[nodeId]; !ok {
                    //        clientMsgCh[nodeId] = make(chan Message)
                    //    }
                    //}
                nodeIds := discoveryServer.AliveNodes()

                    if cacheNodes.Cardinality() == 0 { //第一次有上线的节点
                        if len(msgCache) > 0 {
                            for _,cMsg := range msgCache {
                                sendB, _ := json.Marshal(cMsg)
                                discoveryServer.PublishMsg(string(sendB))
                            }
                //for _,nodeId := range nodeIds {
                //    if _,ok := clientMsgCh[nodeId]; !ok {
                //        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))
                        }
                    }
                    cacheNodes = discoveryServer.AliveNodes()
                } else {
                    cacheNodes = discoveryServer.AliveNodes()
                    time.Sleep(10 * time.Millisecond)
                }
                cacheNodes = discoveryServer.AliveNodes()
            }
        }
    }()
    go func() {

    }()
    return pub,nil
}