搜索到
2
篇与
thinkSwoole
的结果
-
ThinkPHP6.x + Swoole 使用文档整理（二）WebSocket 配置在 config/swoole.php中，可以看到有个websocket的配置//... 'websocket' => [ 'enable' => true, //开启 'handler' => \think\swoole\websocket\Handler::class,// \app\websocket\Manage::class ,// 'ping_interval' => 25000, 'ping_timeout' => 60000, 'room' => [ 'type' => 'table', 'table' => [ 'room_rows' => 8192, 'room_size' => 2048, 'client_rows' => 4096, 'client_size' => 2048, ], 'redis' => [ 'host' => '127.0.0.1', 'port' => 6379, 'max_active' => 3, 'max_wait_time' => 5, ], ], 'listen' => [ 'Event' => \app\listener\WebsocketEvent::class, 'message' => \app\listener\WsMessage::class, 'Open' => \app\listener\WsConnect::class, 'Close' => \app\listener\WsClose::class ], 'subscribe' => [ // \app\subscribe\WsSubscribe::class ], ], //....handler 方法就是websocket对应的处理类可以点进去查看一下源码。发现里面就是调用对应事件 $this->event->trigger('swoole.websocket.Open', $request); $this->event->trigger('swoole.websocket.Message', $frame); $this->event->trigger('swoole.websocket.Event', $this->decode($frame->data)); $this->event->trigger('swoole.websocket.Close'); 配置对应的事件创建对应的事件。php think make:listener WebsocketEvent ...在配置文件中，有一个listen = [ ] , 里面就是对应的事件 'Event' => \app\listener\WebsocketEvent::class, //消息事件 'message' => \app\listener\WsMessage::class, //客户端连接 'Open' => \app\listener\WsConnect::class, //客户端关闭 'Close' => \app\listener\WsClose::classWsConnect为例<?php declare (strict_types = 1); namespace app\listener; use think\swoole\Websocket; class WsConnect { /** * 事件监听处理 * * @return mixed */ public function handle($event,Websocket $ws) { $param = request()->param(); # http请求 echo "\n"; echo "新用户进入\n"; echo json_encode($param)."\n"; echo "websocket:".$ws->getSender()."\n"; echo "WsConnect:".json_encode($event)."\n"; echo "\n"; // $ws->close(); # 断开链接 } } 客户端<!DOCTYPE HTML> <html> <head> <meta charset="UTF-8"> <title>Document</title> </head> <body> <script> var ws = new WebSocket("ws://xxxxx:8080?uid=1"); ws.onopen = function(){ const currentTime = new Date(); console.log(currentTime + '连接成功'); } ws.onclose = function(){ const currentTime = new Date(); console.log(currentTime + '连接断开'); } </script> </body> </html>有用户连接上时，控制台就会输出这些消息 -
ThinkPHP6.x + Swoole 使用文档整理（一）先跑起来 前沿thinkphp文档中关于swoole的内容，真的是写的太吝啬了。百度上一些教程，不知道是不是由于框架或thinkSwoole的更新，也有很多对不上。无奈只能自己研究，记录一下。环境搭建本地环境可以使用docker、或者虚拟机。有宝塔的可以用宝塔，基本上都是一键安装。1.安装thinkphp6.x（稳定版）2.安装php7.4 + swoole扩展4.8 php --version //查看php版本 php -m //查看php扩展（是否已经有swoole了） php -ri swoole //查看swoole 3.安装thinkSwoolecomposer require topthink/think-swoole4.配置config/swoole.php<?php return [ 'http' => [ 'enable' => true, //* 开启http 'host' => '0.0.0.0', 'port' => 8080,// * 设置端口，确保端口已开放 'worker_num' => swoole_cpu_num(), 'options' => [], ], 'websocket' => [ 'enable' => true, //*开启websocket 'handler' => \think\swoole\websocket\Handler::class, 'ping_interval' => 25000, 'ping_timeout' => 60000, 'room' => [ 'type' => 'table', 'table' => [ 'room_rows' => 8192, 'room_size' => 2048, 'client_rows' => 4096, 'client_size' => 2048, ], 'redis' => [ 'host' => '127.0.0.1', 'port' => 6379, 'max_active' => 3, 'max_wait_time' => 5, ], ], 'listen' => [ ], 'subscribe' => [ ], ], ]; 运行swoole切换到项目目录，在控制台执行启动命令php think swoole此时，http和websocket服务都已经开启了。http访问 http://域名:8080/ ，即可访问到项目websocket在 http://www.websocket-test.com/ 中，填入 ws://域名:8080 即可链接
