问题描述 我单独开了一个进程,异步请求数据后,往mqtt里面publish数据,但是我发现一个问题,在new mqtt client的时候,如果写在onMessage里面,就会出现很多mqtt连接,如果写在onMessage外面,则会只publish一次,导致没有后续数据,我现在只能publish一次后,close掉,然后重新connect 然后重新close。不知道我这种处理方式合理吗?有没有更好的处理方式? ...
问题描述 做异步消息转发的时候,使用mqtt,连接一段时候,就会出现报错,这改如何解决? 程序代码 $asyCon = new AsyncTcpConnection('ws://ws.xxx.com'); $asyCon->onConnect = function(AsyncTcpConnection $asyCon){ $asyCon->send(json_encode(['action' =...
问题描述 这里写问题描述 由于外接第三方的WS,他们最多只允许3个ws connect 因此萌生了一个想法:做一个数据转发,异步发一个connect给第三方,然后拿到数据,在转发给多个客户端。 现在出现一个问题:每次客户端连接,我的发现都会异步介入了一次第三方,有没有大佬帮我看下为啥实现不了我想要的效果。 $worker = new Worker('websocket://0.0.0.0:8123'); $work...