发布到多个经纪人
publish to multiple brokers
我想使用 https://github.com/eclipse/paho.mqtt.golang 实现某种消息扇出。
我期待客户端连接并发布到所有代理。但我可以在他们各自的仪表板中看到它只连接到其中一个经纪人。
tgOpts := mqtt.NewClientOptions()
for _, target := range targets {
tgOpts.AddBroker(target)
}
我是否必须为每个目标经纪人创建一个客户,还是我做错了什么?
MQTT 是一种基于主题的模型,1 个代理有多个客户端,而不是相反。
一些代理(例如 mosquitto)支持 bridging,它允许跨代理构建扇出设置,但此设置是在代理级别,核心 MQTT 功能仍然是每个客户端连接 1 个代理。如果您想发布到多个代理,则需要连接到每个代理并单独发布。
我想使用 https://github.com/eclipse/paho.mqtt.golang 实现某种消息扇出。
我期待客户端连接并发布到所有代理。但我可以在他们各自的仪表板中看到它只连接到其中一个经纪人。
tgOpts := mqtt.NewClientOptions()
for _, target := range targets {
tgOpts.AddBroker(target)
}
我是否必须为每个目标经纪人创建一个客户,还是我做错了什么?
MQTT 是一种基于主题的模型,1 个代理有多个客户端,而不是相反。
一些代理(例如 mosquitto)支持 bridging,它允许跨代理构建扇出设置,但此设置是在代理级别,核心 MQTT 功能仍然是每个客户端连接 1 个代理。如果您想发布到多个代理,则需要连接到每个代理并单独发布。