| | |
|---|
| | | heartBeatUrl string |
|---|
| | | pubCh chan Message //publish msg chan |
|---|
| | | aliveNodes gopherdiscovery.StringSet |
|---|
| | | clients map[string][]string |
|---|
| | | |
|---|
| | | recvCh chan Message //recv msg chan |
|---|
| | | } |
|---|
| | |
|---|
| | | |
|---|
| | | 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) |
|---|
| | |
|---|
| | | 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 { |
|---|
