【发布时间】:2021-08-26 09:05:12
【问题描述】:
我正在尝试设置一个 MQTT 消息传递系统,其中我有以下约束:
我有一个客户想要发送不同类型的消息,每个消息都针对特定类型的主题。例如,一种类型是只描述客户端状态的短消息,另一种类型是有时可能非常大的文件。
关键是我希望客户端能够同时发送消息:由于连接速度可能受到限制,如果它发布包含大文件的大消息,然后立即发布包含状态的消息,我希望将状态并行发送,以便长文件不会阻塞短状态消息。
简而言之,发送到同一个主题的消息都会一个接一个地发送,但我希望能够在不同主题之间并行发送。
此外,系统拓扑需要多个代理之间的桥接。如果客户端和代理之间可以实现,那么多个代理之间的并行发送也可以吗?
我已经尝试过在 Python 上使用 Mosquitto Brokers 和 Paho 客户端,方法是创建多个线程,每个线程都有一个客户端,但即使这样似乎也无法实现并行化。对于实施的客户端和语言的选择,我仍然持开放态度。
希望没有太长,并且已经足够简单地总结了这个主题,感谢那些已经阅读到这里的人!
【问题讨论】:
标签: concurrency mqtt messaging