PHP搭建Workerman + MQTT 搭建物联网传输环境
最近一个项目需要用到MQTT作为物联网传输协议, 为防止以后再用到的时候方便配置,特此记录, 有不对的地方请指正并一起学习
MQTT是一个客户端服务端架构的发布/订阅模式的消息传输协议，已经成为物联网的重要组成部分。它的设计思想是轻巧、开放、简单、规范，易于实现。这些特点使得它对很多场景来说都是很好的选择，特别是对于受限的环境如机器与机器的通信（M2M）以及物联网环境（IoT）。
安装基础环境
安装基础环境已经有前辈很完整的介绍, 这里不再过多赘述
1. Workerman
Workerman是一款纯PHP开发的开源高性能的PHP 应用容器。
Workerman不是重复造轮子，它不是一个MVC框架，而是一个更底层更通用的服务框架，你可以用它开发tcp代理、梯子代理、做游戏服务器、邮件服务器、ftp服务器、甚至开发一个php版本的redis、php版本的数据库、php版本的nginx、php版本的php-fpm等等。Workerman可以说是PHP领域的一次创新，让开发者彻底摆脱了PHP只能做WEB的束缚。
实际上Workerman类似一个PHP版本的nginx，核心也是多进程+Epoll+非阻塞IO。Workerman每个进程能维持上万并发连接。由于本身常驻内存，不依赖Apache、nginx、php-fpm这些容器，拥有超高的性能。同时支持TCP、UDP、UNIXSOCKET，支持长连接，支持Websocket、HTTP、WSS、HTTPS等通讯协议以及各种自定义协议。拥有定时器、异步socket客户端、异步Redis、异步Http、异步消息队列等众多高性能组件。
2. 安装MQTT服务器
centos 7 安装MQTT服务器mosquitto
设置链接账号密码
- 这里注意下mosquitto的默认端口是1883, 出于安全考虑请将其改为其他端口, 更改端口配置文件再/etc/mosquitto/mosquitto.conf文件内, 将
port前面的#注释掉, 并将1883改为其他内容 
- 特定方式运行
mosquitto -c /etc/mosquitto/mosquitto.conf -d
3. 使用MQTTBox测试服务器是否搭建成功
- 点击mqttbox的Create Mqtt Client进入链接编辑界面
- 在界面中输入你的MQTT连接的参数
- 点击保存之后界面上出现
Connected即表示连接成功 
- 订阅topic后向topic推送测试数据, 接收成功表示搭建完成, 注意发布与订阅的topic要保持一致
使用Workman接收和发布消息,
- workerman\mqtt 是一个基于workerman的异步mqtt 客户端库，可用于接收或者发送mqtt协议的消息。支持QoS 0、QoS 1、QoS 2。支持MQTT 3.1和3.1.1版本。
使用composer进行安装
composer config -g repo.packagist composer https://mirrors.aliyun.com/composer/composer require workerman/mqtt示例
- subscribe.php(消费者)
use Workerman\Worker;require_once __DIR__ . '/vendor/autoload.php';$worker = new Worker();$worker->onWorkerStart = function(){ $mqtt = new Workerman\Mqtt\Client('mqtt://test.mosquitto.org:1883'); $mqtt->onConnect = function($mqtt) { $mqtt->subscribe('test'); }; $mqtt->onMessage = function($topic, $content){ var_dump($topic, $content); }; $mqtt->connect();};Worker::runAll();命令行运行 php subscribe.php start 启动
- publish.php(生产者)
use Workerman\Worker;require_once __DIR__ . '/vendor/autoload.php';$worker = new Worker();$worker->onWorkerStart = function(){ $mqtt = new Workerman\Mqtt\Client('mqtt://test.mosquitto.org:1883'); $mqtt->onConnect = function($mqtt) { $mqtt->publish('test', 'hello workerman mqtt'); }; $mqtt->connect();};Worker::runAll();命令行运行 php publish.php start 启动
其他配置参数(账号\密码\client_id等)请前往Workerman官网查看
来源地址：https://blog.csdn.net/Simplegif/article/details/124568405
