基于thinkphp的fastadmin使用composer安装swoole并启用swoole的websocket服务

admin

基于thinkphp的fastadmin使用composer安装swoole并启用swoole的websocket服务，首先在站点根目录建立服务启动swoole/start.php

1. <?php
   
2. require_once '/data/dj.zljt.net/application/common/library/WSServer.php';
   
3. // 导入 WSServer 类所在的命名空间
   
4. use app\common\library\WSServer;
   
5. 
   
6. // 实例化 WSServer 类并启动服务器
   
7. $ws = new WSServer();
   
8. // \think\Log::record($ws);
   
9. $ws->start();

复制代码

在application/common/libary/WSServer.php中写如下代码：

1. <?php
   
2. namespace app\common\library;
   
3. require_once '/data/dj.zljt.net/vendor/topthink/think-swoole/src/Server.php';
   
4. use fast\Random;
   
5. use think\Hook;
   
6. use think\swoole\Server;
   
7. 
   
8. /**
   
9. * 短信验证码类
   
10. */
    
11. class WSServer extends Server
    
12. {
    
13.     protected $host = '127.0.0.1'; //监听所有地址
    
14.     protected $port = 9501; //监听9501端口
    
15.     protected $serverType = 'socket';
    
16.     protected $option = [
    
17.         'worker_num'=>  4, //设置启动的Worker进程数
    
18.         'daemonize'        =>  false, //守护进程化（上线改为true）
    
19.         'backlog'        =>  128, //Listen队列长度
    
20.         'dispatch_mode' =>  2, //固定模式，保证同一个连接发来的数据只会被同一个worker处理
    
21. 
    
22.         //心跳检测：每60秒遍历所有连接，强制关闭10分钟内没有向服务器发送任何数据的连接
    
23.         'heartbeat_check_interval' =>  60,
    
24.         'heartbeat_idle_time' =>  600
    
25.     ];
    
26. 
    
27.     //建立连接时回调函数
    
28.     public function onOpen($server, $req)
    
29.     {
    
30.         $fd = $req->fd;//客户端标识
    
31.         $uid = $req->get['uid'];//客户端传递的用户id
    
32.         $token = $req->get['token'];//客户端传递的用户登录token
    
33. 
    
34.         //省略token验证逻辑......
    
35.         if (!$token) {
    
36.             $arr = array('status'=> 2,'message'=> 'token已过期');
    
37.             $server->push($fd, json_encode($arr));
    
38.             $server->close($fd);
    
39.             return;
    
40.         }
    
41.         //省略给用户绑定fd逻辑......
    
42.         echo "用户{$uid}建立了连接,标识为{$fd}\n";
    
43.     }
    
44. 
    
45.     //接收数据时回调函数
    
46.     public function onMessage($server, $frame)
    
47.     {
    
48.         $fd = $frame->fd;
    
49.         $message = $frame->data;
    
50. 
    
51.         //省略通过fd查询用户uid逻辑......
    
52.         $uid = 666;
    
53.         $data['uid'] = $uid;
    
54.         $data['message'] = '用户'.$uid.'发送了:'.$message;
    
55.         $data['post_time'] = date("m/d H:i",time());
    
56.         $arr = array('status'=> 1,'message'=> 'success','data'=> $data);
    
57. 
    
58.         //仅推送给当前连接用户
    
59.         //$server- push($fd, json_encode($arr));
    
60. 
    
61.         //推送给全部连接用户
    
62.         foreach($server->connections as $fd) {
    
63.             $server->push($fd, json_encode($arr));
    
64.         }
    
65.     }
    
66. 
    
67.     //连接关闭时回调函数
    
68.     public function onClose($server, $fd)
    
69.     {
    
70.         echo "标识{$fd}关闭了连接\n";
    
71.     }
    
72. }

复制代码

使用命令行进入根目录，运行：

1. php server/start.php

复制代码

启用swoole
如果需要关闭：
php server/stop.php
如果关闭不了，可以先查看进程：

1. ps aux | grep swoole

复制代码

第二列是pid，使用如下命令关闭：

1. kill 10299

复制代码

10299是pid。