雅安论坛

标题: SWOOLE相关知识 [打印本页]

---

作者: 未命名    时间: 2021-12-31 12:02
标题: SWOOLE相关知识

1. <?php
   
2. //创建websocket服务器对象，监听0.0.0.0:9502端口
   
3. $ws = new swoole_websocket_server("0.0.0.0", 9501);
   
4. 
   
5. //监听WebSocket连接打开事件
   
6. /**
   
7. * 客户端想服务器发送信息是调用函数
   
8. * $ws   websocket 服务器
   
9. * $request 客户端信息
   
10. * $request->fd 客户端唯一编号
    
11. *
    
12. * */
    
13. $ws->on('open', function ($ws, $request) {
    
14.     //var_dump($request->fd, $request->get, $request->server);
    
15.     //$ws->push($request->fd, "hello, welcome\n");
    
16.     echo "connection open:{$request->fd}\n";
    
17.     //$ws->push($request->fd, json_encode(['hello','world']));
    
18. });
    
19. 
    
20. //监听WebSocket消息事件
    
21. /**
    
22. * $frame 客户端发送的信息
    
23. * $frame->fd 客户端的唯一编号
    
24. * $frame->data 客户端发送的信息
    
25. * */
    
26. $ws->on('message', function ($ws, $frame) {
    
27.     //echo "接收到的信息: {$frame->data}\n";
    
28.     //$ws->push($frame->fd, "server: {$frame->data}");
    
29.     //echo "服务器已接收:【".$frame->fd."】";
    
30.     //$ws->push($frame->fd, json_encode(['hello','world'.$frame->data]));
    
31. 
    
32. 
    
33.     // 1.客户端发送过来的信息
    
34.     $content = $frame->data;
    
35.     echo "服务器接收到信息：".$content;
    
36.     // 2.讲消息发送个所有客户端
    
37.     foreach ($ws->connections as $fd){
    
38.         $ws->push($fd,$content);
    
39.     }
    
40. });
    
41. 
    
42. //监听WebSocket连接关闭事件
    
43. $ws->on('close', function ($ws, $fd) {
    
44.     echo "client-{$fd} is closed\n";
    
45.     echo "已断开链接:{$fd}";
    
46. });
    
47. 
    
48. 显示数据：

复制代码

来源：https://www.cnblogs.com/wesky/p/9449647.html

---

欢迎光临 雅安论坛 (https://www.yaanbbs.net/)

Powered by Discuz! X3.4