package discovery

//import (
//	"basic.com/pubsub/protomsg.git"
//	"basic.com/valib/gopherdiscovery.git"
//	"github.com/gogo/protobuf/proto"
//	"time"
//	"basic.com/valib/logger.git"
//)
//
//const (
//	Discovery_Server = "tcp://0.0.0.0:40008"
//	Discovery_UrlPubSub = "tcp://0.0.0.0:50008"
//)
//
////启动discovery的server
//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
//}