From 24e2d92df7cad99e1e514fa581fe59765dbc4a12 Mon Sep 17 00:00:00 2001 From: liuxiaolong <736321739@qq.com> Date: 星期五, 02 八月 2019 09:54:33 +0800 Subject: [PATCH] rm discovery server --- discovery/server.go | 110 +++++++++++++++++++++++++++--------------------------- 1 files changed, 55 insertions(+), 55 deletions(-) diff --git a/discovery/server.go b/discovery/server.go index 52ac5d3..4b37c53 100644 --- a/discovery/server.go +++ b/discovery/server.go @@ -1,57 +1,57 @@ package discovery -import ( - "basic.com/pubsub/protomsg.git" - "basic.com/valib/gopherdiscovery.git" - "github.com/gogo/protobuf/proto" - "time" - "webserver/extend/logger" -) - -const ( - Discovery_Server = "tcp://0.0.0.0:40008" - Discovery_UrlPubSub = "tcp://0.0.0.0:50008" -) - -//鍚姩discovery鐨剆erver -var discoveryServer *gopherdiscovery.DiscoveryServer -var dbChangeChan chan *protomsg.EsPersonCacheChange -func StartServer() { - var clients []string - var err error - var ( - defaultOpts = gopherdiscovery.Options{ - SurveyTime: 3 * time.Second, - //RecvDeadline: 3 * time.Second, - PollTime: 5 * time.Second, - } - ) - - discoveryServer, err = gopherdiscovery.Server(Discovery_Server, Discovery_UrlPubSub, defaultOpts) - - logger.Debug("server: ", discoveryServer) - logger.Debug("err:",err) - logger.Debug("clients: ",clients) - - dbChangeChan = make(chan *protomsg.EsPersonCacheChange) - - for { - select { - case dbMsg := <-dbChangeChan: - publishMessage(dbMsg) - } - } -} - -//骞挎挱鏁版嵁搴撴敼鍙樼殑msg -func publishMessage(msg *protomsg.EsPersonCacheChange) { - sendBytes,err := proto.Marshal(msg) - if err ==nil{ - discoveryServer.PublishMsg(string(sendBytes)) - } -} - -func AddDbMessage(msg *protomsg.EsPersonCacheChange) { - logger.Debug("MSG EsPersonCacheChange In") - dbChangeChan<-msg -} \ No newline at end of file +//import ( +// "basic.com/pubsub/protomsg.git" +// "basic.com/valib/gopherdiscovery.git" +// "github.com/gogo/protobuf/proto" +// "time" +// "webserver/extend/logger" +//) +// +//const ( +// Discovery_Server = "tcp://0.0.0.0:40008" +// Discovery_UrlPubSub = "tcp://0.0.0.0:50008" +//) +// +////鍚姩discovery鐨剆erver +//var discoveryServer *gopherdiscovery.DiscoveryServer +//var dbChangeChan chan *protomsg.EsPersonCacheChange +//func StartServer() { +// var clients []string +// var err error +// var ( +// defaultOpts = gopherdiscovery.Options{ +// SurveyTime: 3 * time.Second, +// //RecvDeadline: 3 * time.Second, +// PollTime: 5 * time.Second, +// } +// ) +// +// discoveryServer, err = gopherdiscovery.Server(Discovery_Server, Discovery_UrlPubSub, defaultOpts) +// +// logger.Debug("server: ", discoveryServer) +// logger.Debug("err:",err) +// logger.Debug("clients: ",clients) +// +// dbChangeChan = make(chan *protomsg.EsPersonCacheChange) +// +// for { +// select { +// case dbMsg := <-dbChangeChan: +// publishMessage(dbMsg) +// } +// } +//} +// +////骞挎挱鏁版嵁搴撴敼鍙樼殑msg +//func publishMessage(msg *protomsg.EsPersonCacheChange) { +// sendBytes,err := proto.Marshal(msg) +// if err ==nil{ +// discoveryServer.PublishMsg(string(sendBytes)) +// } +//} +// +//func AddDbMessage(msg *protomsg.EsPersonCacheChange) { +// logger.Debug("MSG EsPersonCacheChange In") +// dbChangeChan<-msg +//} \ No newline at end of file -- Gitblit v1.8.0