關(guān)于使用mqtt做異步消息分發(fā)問題
問題描述 我單獨(dú)開了一個(gè)進(jìn)程，異步請求數(shù)據(jù)后，往mqtt里面publish數(shù)據(jù)，但是我發(fā)現(xiàn)一個(gè)問題，在new mqtt client的時(shí)候，如果寫在onMessage里面，就會出現(xiàn)很多mqtt連接，如果寫在onMessage外面，則會只publish一次，導(dǎo)致沒有后續(xù)數(shù)據(jù)，我現(xiàn)在只能publish一次后，close掉，然后重新connect 然后重新close。不知道我這種處理方式合理嗎？有沒有更好的處理方式？ ...
關(guān)于mqtt連接報(bào)錯(cuò)
問題描述 做異步消息轉(zhuǎn)發(fā)的時(shí)候，使用mqtt,連接一段時(shí)候，就會出現(xiàn)報(bào)錯(cuò),這改如何解決？ 程序代碼 $asyCon = new AsyncTcpConnection('ws://ws.xxx.com'); $asyCon->onConnect = function(AsyncTcpConnection $asyCon){ $asyCon->send(json_encode(['action' =...
關(guān)于gateway worker 相關(guān)問題
問題描述 我想onWorkerStart方法里面去異步請求一個(gè)連接，然后在onMessage里面將異步請求的結(jié)果send出去，該怎么做。...
關(guān)于數(shù)據(jù)轉(zhuǎn)發(fā)，異步連接問題
問題描述 這里寫問題描述 由于外接第三方的WS，他們最多只允許3個(gè)ws connect 因此萌生了一個(gè)想法：做一個(gè)數(shù)據(jù)轉(zhuǎn)發(fā)，異步發(fā)一個(gè)connect給第三方，然后拿到數(shù)據(jù)，在轉(zhuǎn)發(fā)給多個(gè)客戶端。 現(xiàn)在出現(xiàn)一個(gè)問題：每次客戶端連接，我的發(fā)現(xiàn)都會異步介入了一次第三方，有沒有大佬幫我看下為啥實(shí)現(xiàn)不了我想要的效果。 $worker = new Worker('websocket://0.0.0.0:8123'); $work...
