【mqtt】开源下载和安装教程

1、项目介绍

MQTT Protocol Analysis & Coroutine Client 是一个专为 PHP 开发的 MQTT 协议解析和协程客户端库。它支持 MQTT 协议版本 3.1、3.1.1 和 5.0，并提供 QoS 0/1/2 消息等级支持。此外，该项目还支持通过 WebSocket 实现 MQTT 通信，是首个支持 MQTT 5.0 协议的 PHP 库。

2、项目下载位置

通过 Composer 直接下载安装：

composer require simps/mqtt

3、项目安装环境配置

环境要求

• PHP 版本 ≥ 7.1
• Swoole 扩展 ≥ 4.4.20

配置示例

4、项目安装方式

方式一：Composer 安装（推荐）

composer require simps/mqtt

方式二：手动安装

1. 下载源码包：

git clone https://github.com/simps/mqtt.git

2. 进入项目目录执行：

composer install

5、项目处理脚本

基础发布/订阅示例

<?php
require __DIR__ . '/vendor/autoload.php';

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

Coroutine\run(function () {
    $client = new Client('127.0.0.1', 1883);
    $client->connect();
    
    // 订阅主题
    $client->subscribe('test/topic', function ($topic, $message) {
        echo "收到消息: {$message}\n";
    });
    
    // 发布消息
    $client->publish('test/topic', 'Hello MQTT');
});

QoS 2 消息处理

$client->subscribe('qos2/topic', function ($topic, $message) {
    echo "QoS2消息: {$message}\n";
}, 2);

提示：更多示例可查看项目中的 examples 目录。