關于mqtt示例中發(fā)布publish的問題

devler 更新于2022-09-01

@walkor,
訂閱主題需要實時監(jiān)聽可以啟動后常駐內(nèi)存守護進程運行這個沒問題；發(fā)布publish我想根據(jù)后臺業(yè)務需要發(fā)送主題，如何實現(xiàn)？

 2481  2 1

2個回答

ngrok.cc內(nèi)網(wǎng)穿透 2022-09-02

如果你的后臺是用workerman的系列框架寫的，那么你可以直接使用

 $mqtt = new Workerman\Mqtt\Client('mqtt://test.mosquitto.org:1883');
    $mqtt->onConnect = function($mqtt) {
       $mqtt->publish('test', 'hello workerman mqtt');
    };
    $mqtt->connect();

如果是其他或者fpm框架寫的，可以使用第三方類庫
例如：https://packagist.org/packages/php-mqtt/client

具體使用方法看文檔即可

devler 2022-09-02

謝謝你的回答，我用其他框架中直接使用上面客戶端直接連接是報錯誤的，好像是必須依托Woker進程啟動后在連接成功；意思是我再使用php-mqtt庫進行發(fā)布消息嗎
ngrok.cc內(nèi)網(wǎng)穿透 2022-09-02

是的，其他客戶端不能用workerman，因為workerman是cli模式使用的，你其他框架是fpm的話使用不了
devler 2022-09-02

明白了，理論是能否通過一些操作，將fpm框架的產(chǎn)生的數(shù)據(jù)，推送Woker容器里，然后使用容器里的mqtt進行publish
ngrok.cc內(nèi)網(wǎng)穿透 2022-09-02

你可以借助redis來實現(xiàn)，workerman通過自定義進行去獲取redis里面的內(nèi)容，但是這樣不如你直接fpm去mqtt推送了
devler 2022-09-02

好的，非常感謝