使用workerman/mqtt做队列(订阅)

前言

手上有个需求，第三方门禁触发后数据推送过来，对方使用的是mqtt来传输，这次还是用workerman的mqtt组件来实现，流程跟前篇讲的部署workman/redis队列基本都一样。

部署

1. compser安装workerman/mqtt

 composer require workerman/mqtt

2. 使用make命令创建command（命令类）

 php think make:command MqttS MqttS

3. 将workman启动参数复制到command文件夹下的MqttS里

4. 在config/console.php声明

    'commands' => [         'MqttS'=>\app\command\MqttS::class,    ],

3. 打开MqttS客户端

这里的MqttS就是上面configure里的name（名），start就是Argument（动作），启动worker用的

 php think MqttS start

推荐一个windows上的客户端做调试用：MQTTX-Setup-1.7.3-x64.exe，使用说明

参考资料：
https://www.kancloud.cn/manual/thinkphp6_0/1037651
https://www.workerman.net/doc/workerman/components/workerman-mqtt.html

来源地址：https://blog.csdn.net/xiantianga6883/article/details/128104733