# Mqtt [TOC] SD提供了MQTT異步客戶端。 * 異步MQTT客戶端，可以結合EMQ開源服務器實現百萬千萬級通訊業務。 * 支持完整的MQTT協議規則 * 純異步，斷線重連 ## 創建MQTT連接 ```php public function initAsynPools($workerId) { parent::initAsynPools(); $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(); } ``` >我們在initAsynPools中創建了Mqtt客戶端，這樣會導致每個worker進程都會創建一個MQTT客戶端。 最好的做法是創建一個自定義進程，在自定義進程中創建MQTT客戶端。 MQTT是純異步的，需要通過回調獲取通訊的結果。 ## 回調 * connack 連接成功的回調 * disconnect 斷開連接的回調 * puback * pubrec * pubrel * pubcomp * suback 訂閱成功的回調 * unsuback 移除訂閱的回調 * publish 收到訂閱消息的回調 ## Api * setRetryTimeout 設置Retry超時時間 * setVersion 設置MQTT版本 * version 獲取MQTT版本 * setAuth 設置AUTH * setKeepalive 設置Keepalive時間 * setConnectClean 設置連接清除標志 * setWill 設置遺囑消息 * on 設置回調 * ping ping * connect 連接 * disconnect 斷開連接 * publish 發布 * subscribe 訂閱 * unsubscribe 取消訂閱