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、异步消息队列等众多高性能组件。

安装Worderman请点击此链接到官网

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接收和发布消息,

1. 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(消费者)

<?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(生产者)

<?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官网查看