共计 3320 个字符,预计需要花费 9 分钟才能阅读完成。
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' => '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);
残缺代码
服务器连贯、音讯公布与接管代码。
<?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' => '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