| | |
|---|
| | | logger.Info("LTime:", ev.LTime, " Recevie virtualIp change") |
|---|
| | | SyncVirtualIpChan <- ev.Payload |
|---|
| | | } |
|---|
| | | func HandleUserEventSyncMessage(ev serf.UserEvent) { |
|---|
| | | logger.Info("receive a UserEventSyncMessage event") |
|---|
| | | var procMsg ProcMessageEvent |
|---|
| | | err := json.Unmarshal(ev.Payload, &procMsg) |
|---|
| | | if err != nil { |
|---|
| | | logger.Error("sqlUe unmarshal err:", err) |
|---|
| | | return |
|---|
| | | } |
|---|
| | | |
|---|
| | | //收到其它节点主动将注册中心的所有topic通知到集群中 |
|---|
| | | // 自己发送的消息不处理 |
|---|
| | | if procMsg.Owner != config.Server.AnalyServerId { |
|---|
| | | // 判断是否有指定的接收目标 |
|---|
| | | if procMsg.Target == "" || procMsg.Target == config.Server.AnalyServerId { |
|---|
| | | SyncProcMessageChan <- ev.Payload |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 收到其它节点主动将注册中心的所有topic通知到集群中 |
|---|
| | | func HandleSyncRegisterInfo(ev serf.UserEvent) { |
|---|
| | | logger.Debug("HandleSyncRegisterInfo") |
|---|
| | | var si bhome_msg_dev.MsgDevRegisterInfo |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | //处理其他的一些query请求 |
|---|
| | | // 处理其他的一些query请求 |
|---|
| | | func HandleOtherQuery(ev *serf.Query) { |
|---|
| | | var reqBody RequestSerfTopicMsg |
|---|
| | | var ret []byte |
|---|
