使用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'=>appcommandMqttS::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

最后

以上就是繁荣钢笔为你收集整理的使用workerman/mqtt做队列(订阅)的全部内容，希望文章能够帮你解决使用workerman/mqtt做队列(订阅)所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。