# MqttClient 異步MQTT客戶端，可以結合EMQ開源服務器實現百萬千萬級通訊業務。 支持完整的MQTT協議規則 純異步，斷線重連 實例代碼： ```php /** * 這里可以進行額外的異步連接池，比如另一組redis/mysql連接 * @param $workerId * @return array */ public function initAsynPools($workerId) { parent::initAsynPools(); if($workerId==0) { $mqtt = new MQTT('tcp://127.0.0.1:11883/','root1'); //設置持久會話 $mqtt->setConnectClean(false); //認證 $mqtt->setAuth('root1','root'); //存活時間 $mqtt->setKeepalive(3600); //回調 $mqtt->on('publish', function ($mqtt, PUBLISH $publish_object) { printf( "\e[32mI got a message\e[0m:(msgid=%d, QoS=%d, dup=%d, topic=%s) \e[32m%s\e[0m\n", $publish_object->getMsgID(), $publish_object->getQos(), $publish_object->getDup(), $publish_object->getTopic(), $publish_object->getMessage() ); }); $mqtt->on('connack', function (MQTT $mqtt, CONNACK $connack_object) { var_dump("MQTT連接成功"); $topics['$SYS/#'] = 1; $mqtt->subscribe($topics); }); $mqtt->connect(); } } ```