我想使用https://github.com/eclipse/paho.mqtt.golang实现某种消息扇出。
我期待客户端连接并发布到所有代理。但我可以在他们各自的仪表板中看到它只连接到其中一个经纪人。
tgOpts := mqtt.NewClientOptions()
for _, target := range targets {
tgOpts.AddBroker(target)
}
我必须为每个目标代理创建一个客户端,还是我做错了什么?
郎朗坤
相关分类