<?php
use Workerman\Worker;
require_once __DIR__ . '/Workerman/Autoloader.php';
$worker = new Worker();
$worker->onWorkerStart = function(){
$mqtt = new Workerman\Mqtt\Client('mqtt://ip:1883');
$mqtt->onConnect = function($mqtt) {
$mqtt->subscribe('test');
};
$mqtt->onMessage = function($topic, $content){
var_dump($topic, $content);
};
$mqtt->connect();
};
Worker::runAll();
我測(cè)試這個(gè)代碼,鏈接自己服務(wù)器搭建的emq。就是mqtt5.0。發(fā)現(xiàn)無(wú)法通信。請(qǐng)教大家解決方案。