当前位置：首页 > PHP

php实现mqtt

2026-02-14 21:37:53PHP

PHP 实现 MQTT 的方法

使用 `php-mqtt/client` 库

php-mqtt/client 是一个流行的 PHP MQTT 客户端库，支持 MQTT 3.1 和 3.1.1 协议。

安装依赖：

composer require php-mqtt/client

发布消息示例：

<?php
use PhpMqtt\Client\MqttClient;
use PhpMqtt\Client\ConnectionSettings;

$server   = 'broker.example.com';
$port     = 1883;
$clientId = 'php-publisher';
$username = 'username';
$password = 'password';

$mqtt = new MqttClient($server, $port, $clientId);
$connectionSettings = (new ConnectionSettings())
    ->setUsername($username)
    ->setPassword($password);

$mqtt->connect($connectionSettings, true);
$mqtt->publish('topic/test', 'Hello World!', 0);
$mqtt->disconnect();

订阅消息示例：

<?php
use PhpMqtt\Client\MqttClient;
use PhpMqtt\Client\ConnectionSettings;

$server   = 'broker.example.com';
$port     = 1883;
$clientId = 'php-subscriber';
$username = 'username';
$password = 'password';

$mqtt = new MqttClient($server, $port, $clientId);
$connectionSettings = (new ConnectionSettings())
    ->setUsername($username)
    ->setPassword($password);

$mqtt->connect($connectionSettings, true);
$mqtt->subscribe('topic/test', function ($topic, $message) {
    echo "Received message on topic {$topic}: {$message}\n";
}, 0);

$mqtt->loop(true);
$mqtt->disconnect();

使用 `bluerhinos/phpmqtt` 库

另一个常用库是 bluerhinos/phpmqtt，这是一个纯 PHP 实现的 MQTT 客户端。

php实现mqtt

安装依赖：

composer require bluerhinos/phpmqtt

发布消息示例：

<?php
require('vendor/autoload.php');
use Bluerhinos\phpMQTT;

$server = 'broker.example.com'; 
$port = 1883;
$username = 'username';
$password = 'password';
$client_id = 'php-publisher';

$mqtt = new phpMQTT($server, $port, $client_id);
if ($mqtt->connect(true, NULL, $username, $password)) {
    $mqtt->publish('topic/test', 'Hello World!', 0);
    $mqtt->close();
}

订阅消息示例：

php实现mqtt

<?php
require('vendor/autoload.php');
use Bluerhinos\phpMQTT;

$server = 'broker.example.com';
$port = 1883;
$username = 'username';
$password = 'password';
$client_id = 'php-subscriber';

$mqtt = new phpMQTT($server, $port, $client_id);
if(!$mqtt->connect(true, NULL, $username, $password)) {
    exit(1);
}

$topics['topic/test'] = array('qos' => 0, 'function' => 'procmsg');
$mqtt->subscribe($topics, 0);

function procmsg($topic, $msg) {
    echo "Msg Recieved: {$msg}\n";
}

while($mqtt->proc()) {}
$mqtt->close();

使用 Mosquitto 扩展

PHP 也可以使用 Mosquitto 扩展来连接 MQTT 代理。

安装 Mosquitto 扩展：

pecl install Mosquitto-alpha

发布消息示例：

<?php
$client = new Mosquitto\Client();
$client->setCredentials('username', 'password');
$client->connect('broker.example.com', 1883, 60);

$client->onConnect(function() use ($client) {
    $client->publish('topic/test', 'Hello World!', 0, false);
});

$client->loopForever();

订阅消息示例：

<?php
$client = new Mosquitto\Client();
$client->setCredentials('username', 'password');
$client->connect('broker.example.com', 1883, 60);

$client->onConnect(function() use ($client) {
    $client->subscribe('topic/test', 0);
});

$client->onMessage(function($message) {
    printf("Received message on topic %s: %s\n", $message->topic, $message->payload);
});

$client->loopForever();