webman使用mqtt插件，在自定义进程订阅进程数量开了2个，会接收多个相同的订阅数据，怎么处理？
问题描述
webman里面使用了mqttClient插件，在自定义进程里面做了mqtt的订阅接收，自定义进程数量设置到2个以上的时候，同一个主题会收到多个相同的数据，这个情况怎么处理呢？mqtt服务器是EMQX。
1301 3 1
3个回答
相似问题
年代过于久远，无法发表回答
月贡献榜
赞助商
热门问答
workerman 里面的redis 队列是基于redis的什么特性实现的？
webman有没有可能考虑内置Macro宏功能呢？
webman移植到linux报错Cannot redeclare……
安装《简单方便的计划任务》的错误
workerman/http-client 是否需要手动关闭连接
关于webman使用fastcgi_finish_request函数的类似效果的方案
webman不错，但不建议官方做webman-admin
workerman/workerman (v4.2.0 => v4.2.1)后webman报错
Webman AI 发布5.2版本，支持画廊功能，支持史上最强gpt-4o模型
wokerman think-worker 内存一直增长
要么用分布式锁 谁先抢到谁执行 要么 直接订阅子topic
mqtt 机制就是广播吧。
如果只想要一次通知，只让一个进程订阅这个消息就好了。
比如A进程订阅A主题，B进程订阅B主题。进程id可以用$worker->id来获取，用来区分当前是哪个进程。
我们的设备ID都是纯数字的，之前尝试过采用“设备ID % 2 == $woker->id” 的方式来处理。