请问mqtt订阅，如何做多核负载均衡？

我们在后端起了一个mqtt的客户端，但因为在多个进程里订阅同一个主题，会造成同一条消息过来会回复多次。所以现在只在主进程里订阅主题。不过最近并发有点太高了，有点吃不消。请问这种mqtt订阅如何做负载均衡？？

你们是自建的 mqtt 服务吗？可以试一下阿里云的 MQTT 服务，在服务端直接使用 MQ 的方式就好了，mqtt 协议不适合用在服务端

emqtt支持共享订阅。共享订阅(Shared Subscription) 共享订阅(Shared Subscription)支持在多订阅者间采用分组负载平衡方式派发消息:

                        ---------
                        |       | --Msg1--> Subscriber1

Publisher–Msg1,Msg2,Msg3–>| EMQ | --Msg2–> Subscriber2 | | --Msg3–> Subscriber3 --------- 使用方式: 订阅者在主题(Topic)前增加’$queue’或’$share/<group>/’前缀。

HobaiRiku 3楼•5 年前

这不是用mqtt能处理的，这个和redis一样，都是pub/sub，而不是消息队列，我觉得你应该需要的是MQ类中间件

wiviwiv 4楼•5 年前

无论自建还是公有云消费端量大了都解决不了，共享订阅可以缓解下，如果物联网的话，楼上 EMQ 那个教程里面共享订阅大多 Broker 都支持有个废弃项目可以参考下 https://github.com/wivwiv/egg-iot-with-mqtt/blob/master/README.md#服务启动配置

根本办法还是先到 Kafka 等消息流中间件，再慢慢来处理

dallball 5楼•5 年前作者