add es cache change

liuxiaolong

2019-08-01 978757c6cd702684d736ddf733f1d718a8c67060

 discovery/server.go

@@ -3,10 +3,9 @@
import (
   "basic.com/pubsub/protomsg.git"
   "basic.com/valib/gopherdiscovery.git"
   "fmt"
   "github.com/gogo/protobuf/proto"
   "time"
   "webserver/extend/logger"
   "github.com/gogo/protobuf/proto"
)

const (
@@ -16,7 +15,7 @@

//启动discovery的server
var discoveryServer *gopherdiscovery.DiscoveryServer
var dbChangeChan chan *protomsg.DbChangeMessage
var dbChangeChan chan *protomsg.EsPersonCacheChange
func StartServer() {
   var clients []string
   var err error
@@ -34,7 +33,7 @@
   logger.Debug("err:",err)
   logger.Debug("clients: ",clients)

   dbChangeChan = make(chan *protomsg.DbChangeMessage)
   dbChangeChan = make(chan *protomsg.EsPersonCacheChange)

   for {
      select {
@@ -45,14 +44,14 @@
}

//广播数据库改变的msg
func publishMessage(msg *protomsg.DbChangeMessage) {
func publishMessage(msg *protomsg.EsPersonCacheChange) {
   sendBytes,err := proto.Marshal(msg)
   if err ==nil{
      discoveryServer.PublishMsg(string(sendBytes))
   }
}

func AddDbMessage(msg *protomsg.DbChangeMessage) {
   fmt.Println("MSG In")
func AddDbMessage(msg *protomsg.EsPersonCacheChange) {
   logger.Debug("MSG EsPersonCacheChange In")
   dbChangeChan<-msg
}