TP5.0 + workerman 链接 Mqtt 怎么链接 求大佬一点点的指点。

<?php
/*
 * @o: ========================================================
 * @Created By: VsCode
 * @Author: Fu
 * @name: 管理员控制器
 * @LastEditTime: 2021-05-18 16:50:31
 * @Date: 2021-05-18 16:29:02
 * @u: ========================================================
 */
namespace app\push\controller;
 
// use Workerman\Mqtt\Client;
use Workerman\Worker;
 
class Mqtt
{
    public function __construct()
    {
        $worker = new Worker();
        $worker = new Worker();
        $worker->onWorkerStart = function(){
            $mqtt = new \Workerman\Mqtt\Client('mqtt:这里有链接');
            $mqtt->onConnect = function($mqtt) {
                $mqtt->subscribe('test');
            };
            $mqtt->onMessage = function($topic, $content){
                var_dump($topic, $content);
            };
            $mqtt->connect();
        };
        Worker::runAll();
    }


    
    // 回调消息
    public function onMessage($topic, $msg)
    {
        $data = json_decode($msg, true);
        return $data;
        #代码逻辑
    }
}

现在就是不知道下一步咋弄了。比如接收消息等等  求大佬指点

你有开mqtt的服务嘛

您好，我是有问必答小助手，您的问题已经有小伙伴解答了，您看下是否解决，可以追评进行沟通哦~

如果有您比较满意的答案 / 帮您提供解决思路的答案，可以点击【采纳】按钮，给回答的小伙伴一些鼓励哦～～

ps:问答VIP仅需29元，即可享受5次/月 有问必答服务，了解详情>>>https://vip.csdn.net/askvip?utm_source=1146287632