国产+高潮+在线,国产 av 仑乱内谢,www国产亚洲精品久久,51国产偷自视频区视频,成人午夜精品网站在线观看

關(guān)于使用mqtt做異步消息分發(fā)問(wèn)題

萌萌噠

問(wèn)題描述

我單獨(dú)開了一個(gè)進(jìn)程，異步請(qǐng)求數(shù)據(jù)后，往mqtt里面publish數(shù)據(jù)，但是我發(fā)現(xiàn)一個(gè)問(wèn)題，在new mqtt client的時(shí)候，如果寫在onMessage里面，就會(huì)出現(xiàn)很多mqtt連接，如果寫在onMessage外面，則會(huì)只publish一次，導(dǎo)致沒(méi)有后續(xù)數(shù)據(jù)，我現(xiàn)在只能publish一次后，close掉，然后重新connect 然后重新close。不知道我這種處理方式合理嗎？有沒(méi)有更好的處理方式？

792 2 0
2個(gè)回答
walkor 打賞

寫一個(gè)類或者函數(shù)把mqtt連接實(shí)例存起來(lái)，用的時(shí)候取出來(lái)調(diào)用

例如寫一個(gè)函數(shù)放在 app/functions.php 下

function mqtt_connection()
{
    static $connection;
    if (!$connection) {
        $connection = new Client('mqtt://...');
    }
    return $connection;
}

寫一個(gè)類用staitc屬性存儲(chǔ)連接示例也是一樣的道理

  • 萌萌噠 2024-02-23

    這么寫我也試了 只往里面publish一次數(shù)據(jù)，后面就不會(huì)publish了
  • walkor 2024-02-23

    可能你哪里寫的有問(wèn)題
  • 萌萌噠 2024-02-23

    就是不知道哪里的問(wèn)題，我現(xiàn)在一直new 然后close, 雖然效果有，但是感覺(jué)這么寫不太合理。
萌萌噠

已處理
先連接mqtt, 在mqtt onConnect 里面 在連接異步連接

  • 暫無(wú)評(píng)論
年代過(guò)于久遠(yuǎn)，無(wú)法發(fā)表回答
??