broker.go @@ -9,5 +9,9 @@ //发布到远程机器 PublishNet(nodes []bhomebus.NetNode, topic string, msg []byte) error Subscribe(topics []string) chan []byte //订阅一些主题,可动态新增 Subscribe(topics []string) //注销订阅的主题 DeSub(topics []string) }