会有什么原因会让websocket已经建立的connection数量减少?

应用场景: 我采用websocket的方法连接对方的服务,对方的服务是以用户登录的方式连接。即我每多一个connection都是一个普通的用户登录连接状态。由于网络的问题或者对方服务器鉴权问题,我每隔4小时把所有的用户连接断开$con->close()方法,然后通过onClose事件等待10秒重新连接。 出现的问题: 每个用户connection我都做了一个timer监听它与对方服务器的连接状态,而且我也在co...

zhouaini528 发表与 2021-08-18 1683 浏览 1 回答
始终无法解决onMessage接受大量数据写入redis或者GlobalData共享组件阻塞问题。

有没有哪位兄弟给个方案啊?考虑了多进程的问题,但是维护很麻烦。我是在一个进程下有很多Connection链接数,导致接受的数据像写入到其他地方,严重阻塞了当前主进程,延迟非常严重。...

zhouaini528 发表与 2021-06-01 2378 浏览 1 回答
GlobalData变量共享组件如何可以异步赋值?不阻塞当前进程?

我用GlobalData做进程之间的数据共享,但是我其中一个进程数据量很大,发现GlobalData变量共享组件阻塞了,导致共享的数据和当前实际数据 随时间维度,差距越来越大? 我如何解决啊? 我用Timer::add方式,也不行。 我业务是数据提供方是onMessage方式异步大量数据发送给我,而且想用共享数据方式存起来,可以不同进程访问...

zhouaini528 发表与 2021-05-27 2802 浏览 1 回答
workerman 毫秒级选择性延迟响应,有好的方案吗?

响应太快了,项目经理要求加点延迟,让客户觉得真实有效。 秒级的可以用 消息队列 延迟处理。 毫秒级的有办法吗? 选择性延迟响应,比如100-200毫秒,4000-8000毫秒、不延迟。 用定时器做个0.001的循环判断吗?...

blesswarrior 发表与 2021-05-26 2646 浏览 2 回答
wokerman作为client端用ws方式接受数据,但是随着时间~接受的数据跟对方推送的数据时间差越来越大。

我接受对方ws推送的数据,并发量非常大,每秒200条数据。我count只有一个, 现在是对方推送的数据时间和我接受的数据时间,会越来越大。 我是把数据存在global中,另一个进程来读数据的...

zhouaini528 发表与 2021-05-26 1523 浏览 1 回答
我每次Ctrel+C退出,都会报错。

我在worker进程中运用了进程之间数据共享的组件globaldata,设置Client操作一些数据 set add等等。但是我退出进程就爆这样的错误。 难道是我退出过程中 globaldata 还在操作数据,中断了就报错?...

zhouaini528 发表与 2020-11-16 1836 浏览 2 回答
是不是必须要在Worker onXXX事件回调方法里才能新建立连接?

我的业务是用WS作为client端,我想在一个进程进行上成百上千的WS client连接, 但是这种连接是动态生成连接。根据文档案例如下代码: $worker = new Worker(); $worker->onWorkerStart = function() { $con = new AsyncTcpConnection("ws://echo.websocket.org:80"); } ...

zhouaini528 发表与 2020-09-30 2076 浏览 1 回答
AsyncTcpConnection 可以在onWorkerStart 初始化New多个吗

$task = new Worker(); // 进程启动时异步建立一个到www.baidu.com连接对象,并发送数据获取数据 $task->onWorkerStart = function($task) { $con1 = new AsyncTcpConnection('tcp://www.baidu.com:443'); $con2 = new AsyncTcpConnection('tcp://www....

zhouaini528 发表与 2020-09-29 3095 浏览 1 回答

zhouaini528

-18
积分
0
获赞数
0
粉丝数
2020-09-28 加入
×
🔝