cluster-computing - 蚊子集群的基准?

标签 cluster-computing mqtt mosquitto

我正在尝试构建一个 mosquitto 集群,因为 mosquitto 是单线程并且似乎无法处理大量 qos 2 消息。

MQTT 服务器比较:Benchmark of MQTT Servers

我发现 mosquitto 可以使用桥接方式构建集群(Cluster forming with Mosquitto broker),但我想知道 mosquitto 订阅来自所有其他服务器的所有消息是否会导致内部消息发送的高开销。

例如,如果我有 10 个 mosquitto 代理,每个代理提供 1,000 条消息,最初总共有 10,000 条消息。但是消息将在代理之间共享,因此每条消息将发送到另外 9 个代理,总共有 1,000 x 9 x 10 = 90,000 条消息供内部使用。

蚊子聚类是否有一些基准?或者发送大量 qos 2 消息的一般解决方案是什么?

谢谢

最佳答案

我们曾经建立了一个 MQTT 服务平台,使用 Mosquitto 作为代理,8 个代理桥接在一起,大约 2 万个客户端订阅 2 万个主题,qos=0,平均每秒发布 1 千条消息,100-2 千字节,桥订阅并发布所有主题,并带来巨大的前向延迟,有时超过 2 分钟。 所以现在我们只需将所有酒吧广播给每个经纪人,这确实有效。 但是桥是集群的另一回事,这意味着它不喜欢支持集群 session 、负载平衡、单点故障……的逻辑 MQTT 代理。 所以我实现了一个自治的 Mosquitto 集群,并由 Tsung 做了一些性能测试,一般来说,场景是 30k subscriber/2.5k pubs/sec,payload length=744bytes,qos=1,平均请求响应有点高然后桥接(5.1 毫秒对 2.32 毫秒),但没有消息丢失并且负载平衡。 您可以在mosquitt-cluster-bridge-benchmark下找到详细的测试报告.

关于cluster-computing - 蚊子集群的基准?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/40170965/

相关文章:

linux - 错误 : Unable to write pid file Mosquitto v2. 0.3

erlang - Erlang 是专为在单个多核机器上运行而设计的,还是可以分配进程?

plot - 如何存储/计算单个簇大小并在 NetLogo 中绘制它们

python - 将多个列中的匹配对分组在一起 Python

jdbc - 群集WebLogic JDBC数据源设置是按节点还是按群集?

acl - mosquitto 1.4 - 一旦启用 ACL 运行,就会获取 "Socket error on client <unknown>, disconnecting"

apache-spark - 将 mqtt 与 pyspark 流结合使用

go - 无法使用Paho库连接到mosquitto 2.0

android - 适用于 Android 的 MQTT 代理

mqtt - 如何发现支持MQTT的局域网中的所有设备?