您好!欢迎来到雅安论坛
关注我们
扫码关注官方微信
手机版
手机扫描直接访问
欢迎: 附近的朋友。
111111

SWOOLE相关知识

[复制链接]
未命名 发表于 2021-12-31 12:02:56 | 显示全部楼层 |阅读模式 打印 上一主题 下一主题
  1. <?php
  2. //创建websocket服务器对象,监听0.0.0.0:9502端口
  3. $ws = new swoole_websocket_server("0.0.0.0", 9501);

  4. //监听WebSocket连接打开事件
  5. /**
  6. * 客户端想服务器发送信息是调用函数
  7. * $ws   websocket 服务器
  8. * $request 客户端信息
  9. * $request->fd 客户端唯一编号
  10. *
  11. * */
  12. $ws->on('open', function ($ws, $request) {
  13.     //var_dump($request->fd, $request->get, $request->server);
  14.     //$ws->push($request->fd, "hello, welcome\n");
  15.     echo "connection open:{$request->fd}\n";
  16.     //$ws->push($request->fd, json_encode(['hello','world']));
  17. });

  18. //监听WebSocket消息事件
  19. /**
  20. * $frame 客户端发送的信息
  21. * $frame->fd 客户端的唯一编号
  22. * $frame->data 客户端发送的信息
  23. * */
  24. $ws->on('message', function ($ws, $frame) {
  25.     //echo "接收到的信息: {$frame->data}\n";
  26.     //$ws->push($frame->fd, "server: {$frame->data}");
  27.     //echo "服务器已接收:【".$frame->fd."】";
  28.     //$ws->push($frame->fd, json_encode(['hello','world'.$frame->data]));


  29.     // 1.客户端发送过来的信息
  30.     $content = $frame->data;
  31.     echo "服务器接收到信息:".$content;
  32.     // 2.讲消息发送个所有客户端
  33.     foreach ($ws->connections as $fd){
  34.         $ws->push($fd,$content);
  35.     }
  36. });

  37. //监听WebSocket连接关闭事件
  38. $ws->on('close', function ($ws, $fd) {
  39.     echo "client-{$fd} is closed\n";
  40.     echo "已断开链接:{$fd}";
  41. });

  42. 显示数据:
复制代码
来源:https://www.cnblogs.com/wesky/p/9449647.html

回复

使用道具 举报

您需要登录后才可以回帖 登录 | 注册

本版积分规则

关注3

粉丝13

帖子2251

发布主题
阅读排行 更多
广告位
欢迎使用无需登录在线留言
姓名 

手机 

内容
关注我们
  • 关注官方微信

  • 论坛QQ群

Sitemap小黑屋Archiver雅安论坛( 已经安全运行 ) |网站地图

在线客服

会员收集的资源(插件源码等),仅方便学习,您需要自行承担版权风险,未获得原作者授权的情况下,请勿将文章公开发布或用于商业用途。

声明:本站内容来自于论坛作者本人的观点,不代表本网站的观点和看法,与本网站立场无关,相关责任作者自负。如有侵权,请联系我们及时删除

高能预警:本站为个人网站,非团队运作,常年务农,山上信号不好,在线少,如有不妥之处,望大佬们多多包涵,万分感激!

雅安论坛互联网违法和不良信息举报平台 您也可以通过留言进行相关问题提交,留言提交无需注册,我们将严格保证用户隐私。   © 2009-2021