適用於PHP協定解析和協程客戶端的是什麼

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[&#39;keep_alive&#39;]) && $timeSincePing < (time() - $config[&#39;keep_alive&#39;])) {
            $buffer = $client->ping();
            if ($buffer) {
                echo &#39;send ping success&#39; . PHP_EOL;
                $timeSincePing = time();
            } else {
                $client->close();
                break;
            }
        }
        // QoS1 发布回复
        if ($buffer[&#39;type&#39;] === Types::PUBLISH && $buffer[&#39;qos&#39;] === 1) {
            $client->send(
                [
                    &#39;type&#39; => Types::PUBACK,
                    &#39;message_id&#39; => $buffer[&#39;message_id&#39;],
                    &#39;code&#39; => 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協定解析和協程客戶端的是什麼的詳細內容。更多資訊請關注PHP中文網其他相關文章！