問題描述

這里寫問題描述
幫忙看下這個(gè)mqtt的配置，哪里需要優(yōu)化下呢?，F(xiàn)在的問題是可以連接上，也可以成功接收到訂閱的話題消息，但是接收到幾次以后就接收不到了。mqtt.fx客戶端測(cè)試又可以一致接收到，所以還是代碼上的問題。

$worker = new Worker();
        $worker->onWorkerStart = function(){
            $mqtt = new \Workerman\Mqtt\Client('mqtt://xx.xx.xx.x:1883', [
                'reconnect_period' => 30,
                'username'         => 'xxx',
                'password'         => 'yyy',
                'clean_session'    => false
            ]);
            $mqtt->onConnect = function($mqtt) {
                $mqtt->subscribe('mqtt/face/321842/Rec');
            };
            $mqtt->onMessage = function($topic, $content){
                echo date('Y-m-d H:i:s') . "Received message on topic [" .$topic ."]\n";

            };
            $mqtt->onClose = function () {
                echo 'rec::onClose';
            };
            $mqtt->connect();
        };
        Worker::runAll();