workerman有一個(gè)依賴pthreads擴(kuò)展的MT多線程版本,但是由于pthreads擴(kuò)展還不夠穩(wěn)定,所以這個(gè)Workerman多線程版本已經(jīng)不再維護(hù)。? ? ? ? ? ? ? ? ? ? ? ? ?(推薦學(xué)習(xí): workerman教程)
workermanmqtt 是一個(gè)基于workerman的異步mqtt 客戶端庫(kù),可用于接收或者發(fā)送mqtt協(xié)議的消息。支持QoS 0、QoS 1、QoS 2。支持MQTT3.1和3.1.1版本。
安裝
composer?require?workerman/mqtt
示例
subscribe.php
<?php require __DIR__ . '/vendor/autoload.php'; use WorkermanWorker; $worker = new Worker(); $worker->onWorkerStart?=?function(){ ????$mqtt?=?new?WorkermanMqttClient('mqtt://test.mosquitto.org:1883'); ????$mqtt->onConnect?=?function($mqtt)?{ ????????$mqtt->subscribe('test'); ????}; ????$mqtt->onMessage?=?function($topic,?$content){ ????????var_dump($topic,?$content); ????}; ????$mqtt->connect(); }; Worker::runAll();
? 版權(quán)聲明
文章版權(quán)歸作者所有,未經(jīng)允許請(qǐng)勿轉(zhuǎn)載。
THE END