1. 首页
  2. 文章中心
  3. PHP

一文快速了解PHP项目中怎么使用MQTT

104 阅读 0 评论
我是靠谱客的博主 耍酷红酒，最近开发中收集的这篇文章主要介绍一文快速了解PHP项目中怎么使用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 PhpMqttClientMqttClient;
登录后复制

设置 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]: %sn", $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 sendn");
  sleep(1);
}

// 客户端轮询以处理传入消息和重发队列
$mqtt->loop(true);
登录后复制

完整代码

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

<?php

require('vendor/autoload.php');

use PhpMqttClientMqttClient;
use PhpMqttClientConnectionSettings;

$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 connectedn");

$mqtt->subscribe('emqx/test', function ($topic, $message) {
    printf("Received message on topic [%s]: %sn", $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 sendn");
  sleep(1);
}

$mqtt->loop(true);
登录后复制

测试

运行 MQTT 消息发布代码，我们将看到客户端已经成功连接，且消息已经逐条发布并接收成功：

php pubsub_tcp.php
登录后复制

1.png

总结

至此，我们完成了使用 php-mqtt/client 客户端连接到公共 MQTT 服务器，并实现了测试客户端与 MQTT 服务器的连接、消息发布和订阅。

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

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

最后

以上就是耍酷红酒为你收集整理的一文快速了解PHP项目中怎么使用MQTT的全部内容，希望文章能够帮你解决一文快速了解PHP项目中怎么使用MQTT所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。

本图文内容来源于网友提供，作为学习参考使用，或来自网络收集整理，版权属于原作者所有。
点赞(69)

相关文章

分享实现PHP红包算法的思路（附开发代码）
分享实现PHP红包算法的思路（附开发代码）
巧用PHP函数或常量快速获取PHP版本号、最大文件名长度
巧用PHP函数或常量快速获取PHP版本号、最大文件名长度
简单对比一下PHP 7 和 PHP 5 中的对象
简单对比一下PHP 7 和 PHP 5 中的对象
用PHP换个思路读取WORD内容
用PHP换个思路读取WORD内容
一文快速了解PHP项目中怎么使用MQTT
一文快速了解PHP项目中怎么使用MQTT
我来告诉你PHP中require_once()为什么不好用！
我来告诉你PHP中require_once()为什么不好用！
玩转PHP之快速制作Word简历
玩转PHP之快速制作Word简历
PHP中的===运算符为什么比==快？
PHP中的===运算符为什么比==快？

评论列表共有 0 条评论

立即
投稿
返回
顶部