hbusc.go @@ -230,7 +230,8 @@ sockSub := bhomebus.OpenSocket() //订阅所有主题 for _,v := range ri.SubTopic { sockSub.Sub(v) subN := sockSub.Sub(v) handle.printLog("subTopic:", v, " ret n:", subN) } //启动订阅信息接收