v1.3.0 版本新增了一个 Message 类簇，次要不便用于在 Server 中回复对端 ACK。
use Simps\MQTT\Protocol\Types;use Simps\MQTT\Protocol\V3;use Simps\MQTT\Message\ConnAck;use Simps\MQTT\Message\PingResp;$server = new Swoole\Server('127.0.0.1', 1883, SWOOLE_BASE);$server->set( [ 'open_mqtt_protocol' => true, 'package_max_length' => 2 * 1024 * 1024, ]);$server->on('connect', function ($server, $fd) { echo "Client #{$fd}: Connect.\n";});$server->on('receive', function (Swoole\Server $server, $fd, $from_id, $data) { $data = V3::unpack($data); if (is_array($data) && isset($data['type'])) { switch ($data['type']) { case Types::CONNECT: if ($data['protocol_name'] != 'MQTT') { $server->close($fd); return false; } $server->send( $fd, (new ConnAck())->setCode(0) ->setSessionPresent(0) ); break; case Types::PINGREQ: $server->send($fd, (new PingResp())); break; } } else { $server->close($fd); }});$server->on('close', function ($server, $fd) { echo "Client #{$fd}: Close.\n";});$server->start();在收到CONNECT包之后，须要回复CONNACK报文，之前的版本须要用户手动调用pack类来生成send_data
而当初只须要实例化对应的 Message 类，设置所须要的值即可，如 ConnAck ：
- MQTT3
use Simps\MQTT\Message\ConnAck;$ack = new ConnAck();$ack->setCode(0)->setSessionPresent(0);$server->send($fd, $ack->getContents());$server->send($fd, $ack);- MQTT5
use Simps\MQTT\Message\ConnAck;use Simps\MQTT\Protocol\ProtocolInterface;$ack = new ConnAck();$ack->setProtocolLevel(ProtocolInterface::MQTT_PROTOCOL_LEVEL_5_0) ->setCode(0) ->setSessionPresent(0) ->setProperties([]);$server->send($fd, $ack->getContents());$server->send($fd, $ack);其余的能够查看 具体的类 或者 example 文件
更新日志
向下不兼容
- SUBACK 的
payload应该是返回码，批改键名payload为codes(9e72ce2) (283ff41)
加强
- 优化 Client recv (#38) (99a85bf)
- 增加 CONNACK & PUBLISH & PINGRESP Message (700a6c9)
- 增加 SubAck Message 和更新 getMessageId (09f6334)
- 增加 DISCONNECT、PUBACK、PUBREC、PUBREL、UNSUBACK (20a78c7)
- 批改 AbstractConfig (dff6283)
- 增加 Message 应用示例 (58d5b4a)
- 增加 getContents 不便在
__toString中调用 (a7ba577) - 增加 Message 应用文档 (bab2297)
对于 PHPMQTT
- MQTT 协定解析 & 协程客户端
- 实用于 PHP 的 MQTT 协定解析和协程客户端
- 反对 MQTT 协定 3.1、3.1.1 和 5.0 版本，反对 QoS 0、QoS 1、QoS 2
- 首个反对 MQTT v5.0 协定的 PHP library
文档：https://mqtt.simps.io
GitHub：https://github.com/simps/mqtt
Gitee：https://gitee.com/phpiot/mqtt
反对记得点个 Star~