workerman/mqtt 怎么使用

sorshion 2024-05-19

問(wèn)題描述

目前的場(chǎng)景是手機(jī)遙控器的場(chǎng)景，手機(jī)遙控器發(fā)送指令到接口，接口接收到后mqtt 發(fā)布到emqx，

為此你搜索到了哪些方案及不適用的原因

因?yàn)榻涌谑褂玫氖莣ebman，我看了幾個(gè)帖子，其中有說(shuō)到做一個(gè)自定義進(jìn)程
代碼如何

class MqttTask
{
    public static function onWorkerStart()
    {
        $mqtt = new \Workerman\Mqtt\Client('mqtt://xxxx:1883', array(
            //'debug' => true,
            "username"=>"xxx",
            "password"=>"xxx",
            "client_id"=>"xxx"
        ));
        $mqtt->onConnect = function($mqtt) {
            $mqtt->subscribe('test');
        };
        $mqtt->onMessage = function($topic, $content) {
            echo "topic:$topic content:$content\n";
        };
        $mqtt->connect();
    }
}

主要是這里的onMessage 又是如何接到到topic呢，我就不知道該如何處理呢，請(qǐng)教大家，如何做

 1206  1 0

1個(gè)回答

Gin 2024-05-20

class MqttTask
{
    public function onWorkerStart()
    {
        global $mqtt;
        $mqtt = new \Workerman\Mqtt\Client('mqtt://xxxx:1883', array(
            //'debug' => true,
            "username"=>"xxx",
            "password"=>"xxx",
            "client_id"=>"xxx"
        ));
        $mqtt->onConnect = function($mqtt) {
            //這里是訂閱的設(shè)備端的信息
            $mqtt->subscribe('test');
        };
        $mqtt->onMessage = function($topic, $content) {
            //設(shè)備端回復(fù)的 主題信息
            echo "topic:$topic content:$content\n";
        };
        $mqtt->connect();
    }
    public function onMessage($connection, $data)
    {

        global $mqtt;
        //通過(guò)data中的信息  動(dòng)態(tài)發(fā)布
        $mqtt->publish($data['topic'], $data['order']);

        $connection->close($data);

    }
}