PHP 是一种被广泛应用的凋谢源代码的多用途脚本语言，它可嵌入到 HTML 中，尤其适宜 Web 开发。

本文次要介绍如何在 PHP 我的项目中应用 php-mqtt/client 客户端库 ，实现 MQTT 客户端与 MQTT 服务器的连贯、订阅、勾销订阅、收发音讯等性能。

MQTT 客户端库抉择

本文抉择了 composer 上下载量最高的 php-mqtt/client 这个客户端库，更多 PHP-MQTT 客户端库能够在 Packagist - Search MQTT 中查看。

无关 php-mqtt/client 更多应用文档请参阅 Packagist php-mqtt/client。

MQTT 通信属于 HTTP 体系之外的网络通信场景，因为 PHP 个性限度，应用 PHP 体系中的 Swoole/Workerman 等专为网络通信打造的拓展能够带来更好的体验，其应用本文不再赘述，相干的 MQTT 客户端库如下：

  • workerman/mqtt：Asynchronous MQTT client for PHP based on workerman.
  • simps/mqtt：MQTT Protocol Analysis and Coroutine Client for PHP.

我的项目初始化

确认 PHP 版本

本我的项目应用 7.4.21 进行开发测试，读者可用如下命令确认 PHP 的版本。

php --versionPHP 7.4.21 (cli) (built: Jul 12 2021 11:52:30) ( NTS )Copyright (c) The PHP GroupZend Engine v3.4.0, Copyright (c) Zend Technologies    with Zend OPcache v7.4.21, Copyright (c), by Zend Technologies

应用 Composer 装置 php-mqtt/client 客户端

Composer 是 PHP 的一个依赖管理工具，它能治理你的 PHP 我的项目所须要的所有依赖关系。

composer require php-mqtt/client

PHP MQTT 应用

连贯 MQTT 服务器

本文将应用 EMQ X 提供的 收费公共 MQTT 服务器，该服务基于 EMQ X 的 MQTT 物联网云平台 创立。服务器接入信息如下：

  • Broker: broker-cn.emqx.io
  • TCP Port: 1883
  • SSL/TLS Port: 8883

导入 composer autoload 文件和 php-mqtt/client

require('vendor/autoload.php');use \PhpMqtt\Client\MqttClient;

设置 MQTT Broker 连贯参数

设置 MQTT Broker 连贯地址，端口以及 topic，同时咱们调用 PHP rand 函数随机生成 MQTT 客户端 id。

$server   = 'broker-cn.emqx.io';$port     = 1883;$clientId = rand(5, 15);$username = 'emqx_user';$password = null;$clean_session = false;

编写 MQTT 连贯函数

应用上述的参数进行连贯，通过 ConnectionSettings 设置连贯参数，比方

$connectionSettings  = new ConnectionSettings();$connectionSettings  ->setUsername($username)  ->setPassword(null)  ->setKeepAliveInterval(60)  // Last Will 设置  ->setLastWillTopic('emqx/test/last-will')  ->setLastWillMessage('client disconnect')  ->setLastWillQualityOfService(1);

订阅音讯

编写代码订阅 emqx/test 主题，并为该订阅配置回调函数以解决接管到的音讯，此处咱们将订阅失去的主题和音讯打印进去：

// 订阅$mqtt->subscribe('emqx/test', function ($topic, $message) {    printf("Received message on topic [%s]: %s\n", $topic, $message);}, 0);

公布音讯

结构一个 payload，调用 publish 函数向 emqx/test 主题公布音讯，公布实现之后客户端须要进入轮询状态，解决传入的音讯和重发队列：

for ($i = 0; $i< 10; $i++) {  $payload = array(    'protocol' => 'tcp',    'date' => date('Y-m-d H:i:s'),    'url' => 'https://github.com/emqx/MQTT-Client-Examples'  );  $mqtt->publish(    // topic    'emqx/test',    // payload    json_encode($payload),    // qos    0,    // retain    true  );  printf("msg $i send\n");  sleep(1);}// 客户端轮询以解决传入音讯和重发队列$mqtt->loop(true);

残缺代码

服务器连贯、音讯公布与接管代码。

<?phprequire('vendor/autoload.php');use \PhpMqtt\Client\MqttClient;use \PhpMqtt\Client\ConnectionSettings;$server   = 'broker.emqx.io';$port     = 1883;$clientId = rand(5, 15);$username = 'emqx_user';$password = null;$clean_session = false;$connectionSettings  = new ConnectionSettings();$connectionSettings  ->setUsername($username)  ->setPassword(null)  ->setKeepAliveInterval(60)  // Last Will 设置  ->setLastWillTopic('emqx/test/last-will')  ->setLastWillMessage('client disconnect')  ->setLastWillQualityOfService(1);$mqtt = new MqttClient($server, $port, $clientId);$mqtt->connect($connectionSettings, $clean_session);printf("client connected\n");$mqtt->subscribe('emqx/test', function ($topic, $message) {    printf("Received message on topic [%s]: %s\n", $topic, $message);}, 0);for ($i = 0; $i< 10; $i++) {  $payload = array(    'protocol' => 'tcp',    'date' => date('Y-m-d H:i:s'),    'url' => 'https://github.com/emqx/MQTT-Client-Examples'  );  $mqtt->publish(    // topic    'emqx/test',    // payload    json_encode($payload),    // qos    0,    // retain    true  );  printf("msg $i send\n");  sleep(1);}$mqtt->loop(true);

测试

运行 MQTT 音讯公布代码，咱们将看到客户端曾经胜利连贯，且音讯曾经逐条公布并接管胜利：

php pubsub_tcp.php

总结

至此，咱们实现了应用 php-mqtt/client 客户端连贯到公共 MQTT 服务器，并实现了测试客户端与 MQTT 服务器的连贯、音讯公布和订阅。

版权申明： 本文为 EMQ 原创，转载请注明出处。

原文链接：https://www.emqx.com/zh/blog/how-to-use-mqtt-in-php