update 保护字符截取边界

consumers/consumerWJHP.go

@@ -78,7 +78,7 @@ func (the *consumerWJHP) Work() {
 }
 func (the *consumerWJHP) onData(Topic string, Msg string) {
 	if len(Msg) > 80 {
-		log.Printf("mqtt-recv:[%s]:%s ...", Topic, Msg[:100])
+		log.Printf("mqtt-recv:[%s]:%s ...", Topic, Msg[:80])
 	}
 	var needPush []byte
 	topicPrefixIndex := strings.LastIndex(Topic, "/")