应用场景: 我采用websocket的方法连接对方的服务,对方的服务是以用户登录的方式连接。即我每多一个connection都是一个普通的用户登录连接状态。由于网络的问题或者对方服务器鉴权问题,我每隔4小时把所有的用户连接断开$con->close()方法,然后通过onClose事件等待10秒重新连接。 出现的问题: 每个用户connection我都做了一个timer监听它与对方服务器的连接状态,而且我也在co...
有没有哪位兄弟给个方案啊?考虑了多进程的问题,但是维护很麻烦。我是在一个进程下有很多Connection链接数,导致接受的数据像写入到其他地方,严重阻塞了当前主进程,延迟非常严重。...
我用GlobalData做进程之间的数据共享,但是我其中一个进程数据量很大,发现GlobalData变量共享组件阻塞了,导致共享的数据和当前实际数据 随时间维度,差距越来越大? 我如何解决啊? 我用Timer::add方式,也不行。 我业务是数据提供方是onMessage方式异步大量数据发送给我,而且想用共享数据方式存起来,可以不同进程访问...
响应太快了,项目经理要求加点延迟,让客户觉得真实有效。 秒级的可以用 消息队列 延迟处理。 毫秒级的有办法吗? 选择性延迟响应,比如100-200毫秒,4000-8000毫秒、不延迟。 用定时器做个0.001的循环判断吗?...
我接受对方ws推送的数据,并发量非常大,每秒200条数据。我count只有一个, 现在是对方推送的数据时间和我接受的数据时间,会越来越大。 我是把数据存在global中,另一个进程来读数据的...
我在worker进程中运用了进程之间数据共享的组件globaldata,设置Client操作一些数据 set add等等。但是我退出进程就爆这样的错误。 难道是我退出过程中 globaldata 还在操作数据,中断了就报错?...
我的业务是用WS作为client端,我想在一个进程进行上成百上千的WS client连接, 但是这种连接是动态生成连接。根据文档案例如下代码: $worker = new Worker(); $worker->onWorkerStart = function() { $con = new AsyncTcpConnection("ws://echo.websocket.org:80"); } ...
$task = new Worker(); // 进程启动时异步建立一个到www.baidu.com连接对象,并发送数据获取数据 $task->onWorkerStart = function($task) { $con1 = new AsyncTcpConnection('tcp://www.baidu.com:443'); $con2 = new AsyncTcpConnection('tcp://www....