ruleserver/server.go
@@ -43,6 +43,8 @@ select { case dbMsg := <-videotapChan: publishMessage(dbMsg) default: time.Sleep(time.Millisecond * 10) } } } @@ -51,7 +53,6 @@ func publishMessage(msg *protomsg.VideotapeInfo) { sendBytes,err := proto.Marshal(msg) if err ==nil{ logger.Debug("看看这个疑似空指针的东西",discoveryServer) discoveryServer.PublishMsg(string(sendBytes)) } }