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