simpsmqtt适用于PHP的MQTT协议解析和协程客户端

装置胜利之后咱们来看一下订阅和公布的应用，以 MQTT5.0 为例

订阅

首先应该是订阅，订阅胜利之后能力收到对应主题的公布音讯，创立一个subscribe.php写入以下内容

include __DIR__ . &＃039;/vendor/autoload.php&＃039;;

use Simps\MQTT\Hex\ReasonCode;
use Swoole\Coroutine;
use Simps\MQTT\Client;
use Simps\MQTT\Types;

$cOnfig= [
    &＃039;host&＃039; => &＃039;broker.emqx.io&＃039;,
    &＃039;port&＃039; => 1883,
    &＃039;time_out&＃039; => 5,
    &＃039;user_name&＃039; => &＃039;user001&＃039;,
    &＃039;password&＃039; => &＃039;hLXQ9ubnZGzkzf&＃039;,
    &＃039;client_id&＃039; => Client::genClientID(),
    &＃039;keep_alive&＃039; => 10,
    &＃039;properties&＃039; => [
        &＃039;session_expiry_interval&＃039; => 60,
        &＃039;receive_maximum&＃039; => 200,
        &＃039;topic_alias_maximum&＃039; => 200,
    ],
    &＃039;protocol_level&＃039; => 5,
];

Coroutine\run(function () use ($config) {
    $client = new Client($config, [&＃039;open_mqtt_protocol&＃039; => true, &＃039;package_max_length&＃039; => 2 * 1024 * 1024]);
    while (!$data = $client->connect()) {
        Coroutine::sleep(3);
        $client->connect();
    }
    $topics[&＃039;simps-mqtt/user001/get&＃039;] = [
        &＃039;qos&＃039; => 1,
        &＃039;no_local&＃039; => true,
        &＃039;retain_as_published&＃039; => true,
        &＃039;retain_handling&＃039; => 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[&＃039;keep_alive&＃039;]) && $timeSincePing <(time() - $config[&＃039;keep_alive&＃039;])) {
            $buffer = $client->ping();
            if ($buffer) {
                echo &＃039;send ping success&＃039; . PHP_EOL;
                $timeSincePing = time();
            } else {
                $client->close();
                break;
            }
        }
        // QoS1 公布回复
        if ($buffer[&＃039;type&＃039;] === Types::PUBLISH && $buffer[&＃039;qos&＃039;] === 1) {
            $client->send(
                [
                    &＃039;type&＃039; => Types::PUBACK,
                    &＃039;message_id&＃039; => $buffer[&＃039;message_id&＃039;],
                    &＃039;code&＃039; => ReasonCode::SUCCESS
                ]
            );
        }
    }
});

array(3) {
  ["type"]=>
  int(9)
  ["message_id"]=>
  int(1)
  ["codes"]=>
  array(1) {
    [0]=>
    int(1)
  }
}

include __DIR__ . &＃039;/vendor/autoload.php&＃039;;

use Swoole\Coroutine;
use Simps\MQTT\Client;

$cOnfig= [
    &＃039;host&＃039; => &＃039;broker.emqx.io&＃039;,
    &＃039;port&＃039; => 1883,
    &＃039;time_out&＃039; => 5,
    &＃039;user_name&＃039; => &＃039;user002&＃039;,
    &＃039;password&＃039; => &＃039;adIJS1D482sd&＃039;,
    &＃039;client_id&＃039; => Client::genClientID(),
    &＃039;keep_alive&＃039; => 20,
    &＃039;properties&＃039; => [
        &＃039;session_expiry_interval&＃039; => 60,
        &＃039;receive_maximum&＃039; => 200,
        &＃039;topic_alias_maximum&＃039; => 200,
    ],
    &＃039;protocol_level&＃039; => 5,
];

Coroutine\run(function () use ($config) {
    $client = new Client($config, [&＃039;open_mqtt_protocol&＃039; => true, &＃039;package_max_length&＃039; => 2 * 1024 * 1024]);
    while (!$client->connect()) {
        Coroutine::sleep(3);
        $client->connect();
    }
    while (true) {
        $respOnse= $client->publish(
            &＃039;simps-mqtt/user001/get&＃039;,
            &＃039;{"time":&＃039; . time() . &＃039;}&＃039;,
            1,
            0,
            0,
            [&＃039;topic_alias&＃039; => 1]
        );
        var_dump($response);
        Coroutine::sleep(3);
    }
});

array(4) {
  ["type"]=>
  int(4)
  ["message_id"]=>
  int(1)
  ["code"]=>
  int(0)
  ["message"]=>
  string(7) "Success"
}

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)
  }
}