PHPMQTT v1.3.0 版本發佈，MQTT 協議解析 & 協程客戶端

時間 2021-02-25

標籤 php git github 優化 spa 日誌 code server 協程 rem 欄目 PHP 简体版

原文原文鏈接

v1.3.0 版本新增了一個 Message 類簇，主要方便用於在 Server 中回覆對端 ACK。php

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_datagit

而如今只須要實例化對應的 Message 類，設置所須要的值便可，如 ConnAck ：github

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 文件優化