关于使用mqtt做异步消息分发问题

问题描述 我单独开了一个进程,异步请求数据后,往mqtt里面publish数据,但是我发现一个问题,在new mqtt client的时候,如果写在onMessage里面,就会出现很多mqtt连接,如果写在onMessage外面,则会只publish一次,导致没有后续数据,我现在只能publish一次后,close掉,然后重新connect 然后重新close。不知道我这种处理方式合理吗?有没有更好的处理方式? ...

萌萌哒 发表与 2024-02-23 544 浏览 2 回答
关于mqtt连接报错

问题描述 做异步消息转发的时候,使用mqtt,连接一段时候,就会出现报错,这改如何解决? 程序代码 $asyCon = new AsyncTcpConnection('ws://ws.xxx.com'); $asyCon->onConnect = function(AsyncTcpConnection $asyCon){ $asyCon->send(json_encode(['action' =...

萌萌哒 发表与 2024-02-22 808 浏览 0 回答
关于gateway worker 相关问题

问题描述 我想onWorkerStart方法里面去异步请求一个连接,然后在onMessage里面将异步请求的结果send出去,该怎么做。...

萌萌哒 发表与 2024-02-21 463 浏览 2 回答
关于数据转发,异步连接问题

问题描述 这里写问题描述 由于外接第三方的WS,他们最多只允许3个ws connect 因此萌生了一个想法:做一个数据转发,异步发一个connect给第三方,然后拿到数据,在转发给多个客户端。 现在出现一个问题:每次客户端连接,我的发现都会异步介入了一次第三方,有没有大佬帮我看下为啥实现不了我想要的效果。 $worker = new Worker('websocket://0.0.0.0:8123'); $work...

萌萌哒 发表与 2024-01-31 516 浏览 0 回答

萌萌哒

40
积分
0
获赞数
0
粉丝数
2024-01-31 加入
×
🔝