| | |
| | | "basic.com/pubsub/protomsg.git" |
| | | "basic.com/valib/gopherdiscovery.git" |
| | | "github.com/gogo/protobuf/proto" |
| | | "ruleprocess/logger" |
| | | "basic.com/valib/logger.git" |
| | | "time" |
| | | ) |
| | | |
| | |
| | | } |
| | | |
| | | const ( |
| | | Discovery_Server = "tcp://192.168.1.123:40008" |
| | | Discovery_UrlPubSub = "tcp://192.168.1.123:50008" |
| | | Discovery_Server = "tcp://0.0.0.0:40009" |
| | | Discovery_UrlPubSub = "tcp://0.0.0.0:50009" |
| | | ) |
| | | |
| | | //启动discovery的server |
| | |
| | | func publishMessage(msg *protomsg.VideotapeInfo) { |
| | | sendBytes,err := proto.Marshal(msg) |
| | | if err ==nil{ |
| | | logger.Debug("看看这个疑似空指针的东西",discoveryServer) |
| | | discoveryServer.PublishMsg(string(sendBytes)) |
| | | } |
| | | } |