mqtt是一种基于发布/订阅模式的“轻量级”通讯协议，作为一种低开销、低带宽占用的即时通讯协议，已经成为物联网的重要组成部分，今天小编就带大家了解一下simps/mqtt。
mqtt 是一种基于发布/订阅（publish/subscribe）模式的轻量级通讯协议，作为一种低开销、低带宽占用的即时通讯协议，已经成为物联网的重要组成部分
swoole 也给 php 提供了开发物联网项目的能力，只需要设置一个 open_mqtt_protocol 选项，启用后就会解析 mqtt 包头，在 worker 进程的 onreceive 事件每次都会返回一个完整的 mqtt 数据包
当然其他的也有，例如 workerman 之前提供的 异步 mqtt 客户端库 ，还有其他的开源库，这里就不一一介绍了
simps 的第一个版本 mqtt 库 就是参考了 workerman 的实现，使其能够使用 swoole 的协程能力，同时也修复了一些问题
在此也要感谢 @walkor 对 php 生态作出的贡献
第一个版本的实现是放在了框架当中，限制了一些用户的使用。于是又开始了重构，将 mqtt 独立为一个 library ，方便用户使用的同时也丰富了 php 生态，让 php 程序员不再局限于 web 开发
在第一个版本发布之后，simps 的交流群中也有不少用户询问 mqtt 的问题，swoole 也修复了一些相关的 bug，现在使用 php + swoole 去开发物联网相关的项目应该是如虎添翼
同时第一个版本的 mqtt 库，只支持 mqtt 3.x，不支持 mqtt 5.0，在 github 上也没有找到相关支持的类库，所以在重构了 3.x 版本之后，也支持了一下 mqtt 5.0
也许这是第一个支持 mqtt v5.0 协议的 php library...支持 mqtt 协议 3.1、3.1.1 和 5.0 版本，支持 qos 0、qos 1、qos 2，那么它来了，使用 composer 来安装
composer require simps/mqtt
安装成功之后我们来看一下订阅和发布的使用，以 mqtt5.0 为例
订阅首先应该是订阅，订阅成功之后才能收到对应主题的发布消息，创建一个subscribe.php写入以下内容
include __dir__ . '/vendor/autoload.php';use simps\mqtt\hex\reasoncode;use swoole\coroutine;use simps\mqtt\client;use simps\mqtt\types;$config = [ 'host' => 'broker.emqx.io', 'port' => 1883, 'time_out' => 5, 'user_name' => 'user001', 'password' => 'hlxq9ubnzgzkzf', 'client_id' => client::genclientid(), 'keep_alive' => 10, 'properties' => [ 'session_expiry_interval' => 60, 'receive_maximum' => 200, 'topic_alias_maximum' => 200, ], 'protocol_level' => 5,];coroutine\run(function () use ($config) { $client = new client($config, ['open_mqtt_protocol' => true, 'package_max_length' => 2 * 1024 * 1024]); while (!$data = $client->connect()) { coroutine::sleep(3); $client->connect(); } $topics['simps-mqtt/user001/get'] = [ 'qos' => 1, 'no_local' => true, 'retain_as_published' => true, 'retain_handling' => 2, ]; $timesinceping = time(); $res = $client->subscribe($topics); // 订阅的结果 var_dump($res); while (true) { $buffer = $client->recv(); if ($buffer && $buffer !== true) { $timesinceping = time(); // 收到的数据包 var_dump($buffer); } if (isset($config['keep_alive']) && $timesinceping < (time() - $config['keep_alive'])) { $buffer = $client->ping(); if ($buffer) { echo 'send ping success' . php_eol; $timesinceping = time(); } else { $client->close(); break; } } // qos1 发布回复 if ($buffer['type'] === types::publish && $buffer['qos'] === 1) { $client->send( [ 'type' => types::puback, 'message_id' => $buffer['message_id'], 'code' => reasoncode::success ] ); } }});
执行php subscribe.php，就会得到这样的输出
array(3) { ["type"]=> int(9) ["message_id"]=> int(1) ["codes"]=> array(1) { [0]=> int(1) }}
表示订阅成功，codes 对应的是对应订阅主题的 qos 等级
发布订阅成功之后，创建一个publish.php来测试发布
include __dir__ . '/vendor/autoload.php';use swoole\coroutine;use simps\mqtt\client;$config = [ 'host' => 'broker.emqx.io', 'port' => 1883, 'time_out' => 5, 'user_name' => 'user002', 'password' => 'adijs1d482sd', 'client_id' => client::genclientid(), 'keep_alive' => 20, 'properties' => [ 'session_expiry_interval' => 60, 'receive_maximum' => 200, 'topic_alias_maximum' => 200, ], 'protocol_level' => 5,];coroutine\run(function () use ($config) { $client = new client($config, ['open_mqtt_protocol' => true, 'package_max_length' => 2 * 1024 * 1024]); while (!$client->connect()) { coroutine::sleep(3); $client->connect(); } while (true) { $response = $client->publish( 'simps-mqtt/user001/get', '{"time":' . time() . '}', 1, 0, 0, ['topic_alias' => 1] ); var_dump($response); coroutine::sleep(3); }});
代码的意思是每隔 3 秒给订阅的主题simps-mqtt/user001/get发布一次消息
打开一个新的终端窗口，执行php publish.php就会得到输出：
array(4) { ["type"]=> int(4) ["message_id"]=> int(1) ["code"]=> int(0) ["message"]=> string(7) "success"}
这里增加了 message，为了用户可读，不需要去查找对应的 code 含义是什么
返回到订阅的窗口，就会看到所打印的发布信息
array(8) { ["type"]=> int(3) ["topic"]=> string(0) "" ["message"]=> string(19) "{"time":1608017156}" ["dup"]=> int(1) ["qos"]=> int(1) ["retain"]=> int(0) ["message_id"]=> int(4) ["properties"]=> array(1) { ["topic_alias"]=> int(1) }}
这样一个简单的发布订阅功能就实现了
在这个库中还有一些值得优化和还未完成的部分，如还没有支持 mqtt5 的auth type，以及部分的properties还未支持
想参与的同学可以提交 pr，如果有问题也可以提交 issue，让我们共同去建设 php 的生态
推荐学习：php视频教程
以上就是适用于php协议解析和协程客户端的是什么的详细内容。