首页
下载
文档
问答社区
视频
捐赠
源代码
AI 助理
赞助商
CRMEB
Apipost
腾讯云
微擎
禅道
51Talk
商业产品
Code-Galaxy
Swoole-Compiler
CRMEB 新零售社交电商系统
登录
注册
全部
提问
分享
讨论
建议
公告
开发框架
CodeGalaxy
发表新帖
如何同时运行多个协程 WebSocket 客户端?
### 问题描述 如何同时运行多个协程 WebSocket 客户端? ### Swoole版本，PHP版本，以及操作系统版本信息 Swoole版本4.5.0 ### 相关代码 ```php $roomIds =[1,2,3]; function ws ($roomId){ $client = new Swoole\Coroutine\Http\Client("127.0.0.1", 9501); $ret = $client->upgrade("/".$roomId); if ($ret) { while(true) { $client->push("hello"); var_dump($client->recv()); co::sleep(0.1); } } } foreach ($roomIds as $roomId) { Co\run(function () use ($roomId){ echo sprintf("[%s] 开始 : %s\n", date('Y-m-d H:i:s'), $roomId); ws($roomId); }); } ``` ### 你期待的结果是什么？实际看到的错误信息又是什么？ 期望可以同时连接3个ws , 实际上因为使用了while ,会阻塞在第一个ws ,请问如何实现同时连接3个ws并不断读取消息呢?
发布于3年前 · 7 次浏览 · 来自
提问
从零开始
### 问题描述 如何同时运行多个协程 WebSocket 客户端? ### Swoole版本，PHP版本，以及操作系统版本信息 Swoole版本4.5.0 ### 相关代码 ```php $roomIds =[1,2,3]; function ws ($roomId){ $client = new Swoole\Coroutine\Http\Client("127.0.0.1", 9501); $ret = $client->upgrade("/".$roomId); if ($ret) { while(true) { $client->push("hello"); var_dump($client->recv()); co::sleep(0.1); } } } foreach ($roomIds as $roomId) { Co\run(function () use ($roomId){ echo sprintf("[%s] 开始 : %s\n", date('Y-m-d H:i:s'), $roomId); ws($roomId); }); } ``` ### 你期待的结果是什么？实际看到的错误信息又是什么？ 期望可以同时连接3个ws , 实际上因为使用了while ,会阻塞在第一个ws ,请问如何实现同时连接3个ws并不断读取消息呢?
赞
0
分享
收藏
提问
分享
讨论
建议
公告
开发框架
CodeGalaxy
评论
2020-04-28
鲁飞
你对协程容器的理解有问题，虽然是在协程环境，但是是一个协程，改成多个协程就好了。 ```php <?php function ws($roomId) { $client = new Swoole\Coroutine\Http\Client("127.0.0.1", 9501); $ret = $client->upgrade("/" . $roomId); if ($ret) { while (true) { $client->push("hello" . $roomId); var_dump($client->recv()); co::sleep(1); } } } Co\run( function () { $roomIds = [1, 2, 3]; foreach ($roomIds as $roomId) { go( function () use ($roomId) { echo sprintf("[%s] 开始 : %s\n", date('Y-m-d H:i:s'), $roomId); ws($roomId); } ); } } ); ```
赞
2
回复
微信公众号
热门内容
暂无回复的问答
- CodeGalaxy K3s 轻量集群节点之间如何实现负载均衡
- 关于openssl CURL WARNING swSSL_connect: SSL_connect(fd=69) failed. Error: error:141A318A:SSL routines:tls_process_ske_dhe:dh key too small[1|394]
- 多个模型如何进行事务异常回退？
- websocket开启wss报错
- 协程tcp服务器如何使用多进程？recv()方法接收信息，打印出来的pid一直是同一个。没用使用到多进程啊。
