broker.go @@ -9,5 +9,5 @@ //发布到远程机器 PublishNet(nodes []bhomebus.NetNode, topic string, msg []byte) error Subscribe(topics []string) chan []byte Subscribe(topics []string) }