PHP项目中如何高效集成并使用MQTT实现消息通信？

本文共计1712个文字，预计阅读时间需要7分钟。

PHP是一种广泛应用的开放源代码的多用途脚本语言，可嵌入到HTML中，特别适合Web开发。以下是PHP项目中使用php-mqtt/client客户端库实现MQTT客户端与服务器的步骤简介：

1. 安装php-mqtt/client库：首先，需要在PHP项目中安装php-mqtt/client库。可以通过Composer来安装，运行以下命令： composer require phpMQTT/client

2. 创建MQTT客户端实例：在PHP脚本中，创建一个MQTT客户端实例，配置其连接选项，如MQTT服务器的地址、端口、客户端ID等。

php $client=new phpMQTT\Client(mqtt.example.com, 1883, client_id);

3. 连接到MQTT服务器：使用客户端实例调用`connect()`方法连接到MQTT服务器。

php $client->connect();

4. 订阅主题：使用客户端实例调用`subscribe()`方法订阅所需的MQTT主题。

php $client->subscribe(topic1, 1);

5. 发布消息：使用客户端实例调用`publish()`方法向指定主题发布消息。

php $client->publish(topic1, Hello MQTT!, 1, 0);

6. 处理消息：在客户端实例中设置消息回调函数，用于接收从服务器发送的消息。

php $client->onMessage=function ($message) { echo Received message: . $message->payload . \n; };

7. 断开连接：完成消息处理或任务后，使用`disconnect()`方法断开与MQTT服务器的连接。

php $client->disconnect();

通过以上步骤，可以在PHP项目中使用php-mqtt/client库实现MQTT客户端功能，与MQTT服务器进行通信。

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 --version PHP 7.4.21 (cli) (built: Jul 12 2021 11:52:30) ( NTS ) Copyright (c) The PHP Group Zend 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' => '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);

完整代码

服务器连接、消息发布与接收代码。

<?php require('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' => '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 服务器的连接、消息发布和订阅。

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

作者：EMQ

推荐学习：《PHP视频教程》

以上就是一文快速了解PHP项目中怎么使用MQTT的详细内容，更多请关注自由互联其它相关文章！