thinkphp 是一个非常流行的 php 框架，thinkphp 6 自带了 swoole 扩展包，使得在使用 websocket 技术时变得非常简单。本文将介绍如何使用 thinkphp 6 框架来实现一个 websocket 广播功能。
环境要求在开始之前，需要准备以下环境：
php 7.2+swoole 扩展composer基本的 web 开发知识创建项目首先，我们需要创建一个新的项目：
composer create-project topthink/think my-project
然后，为了方便使用 websocket，我们需要在项目的 composer.json 文件中添加 swoole 扩展：
"require": { "topthink/think-swoole": "^2.0", "swoole/swoole": "^4.7"}
完成后，运行以下命令进行安装：
composer install
创建控制器接下来，我们需要创建一个控制器来处理 websocket 的请求。在 app/controller 目录下创建一个名为 websocket.php 的文件，写入以下代码：
<?phpdeclare(strict_types=1);namespace appcontroller;use thinkswoolewebsocket as swoolewebsocket;use swoolewebsocketframe;class websocket extends swoolewebsocket{ /** * 监听连接事件 * @param swoolewebsocketserver $server * @param swoolehttprequest $request */ public function onopen($server, $request) { } /** * 监听接收消息事件 * @param swoolewebsocketserver $server * @param frame $frame */ public function onmessage($server, frame $frame) { } /** * 监听关闭事件 * @param swoolewebsocketserver $server * @param int $fd */ public function onclose($server, $fd) { }}
在上面的代码中，我们继承了 thinkswoolewebsocket 类，并重写了其中的三个方法：
onopen 方法用于监听连接事件；onmessage 方法用于监听接收消息事件；onclose 方法用于监听关闭事件。当前，这些方法并没有做任何事情，接下来我们将会在这些方法中添加 websocket 通信的逻辑。
注册路由在控制器创建好之后，我们需要在路由中进行注册。在 app/route.php 文件中添加以下内容：
use think acaderoute;route::post('/ws', 'websocket@onmessage')->middleware( hinkmiddlewareallowcrossdomain::class);
这里使用了 route::post 方法来注册路由。这个路由的请求方式是 post，路径为 /ws，并将请求映射到了 websocket 控制器的 onmessage 方法上。
编写 websocket 通信逻辑现在，我们已经完成了 websocket 路由和控制器的创建与注册。接下来，我们需要在控制器中添加 websocket 通信的逻辑。我们将使用 swoole 的 websocket 服务端来实现 websocket 通信。
在 onopen 方法中，我们可以获取客户端的连接对象，并将其存储起来，以便后续使用。在 onmessage 方法中，我们可以获取客户端发送的消息，并将这条消息广播给其它客户端。在 onclose 方法中，我们需要将客户端从连接池中移除。
在 app/controller 目录下创建一个名为 websocketserver.php 的文件，写入以下代码：
<?phpdeclare(strict_types=1);namespace appcontroller;use swoolehttpresponse;use swoolewebsocketframe;use swoolewebsocketserver;use thinkswoolewebsockethandlerinterface;class websocketserver implements handlerinterface{ /** * @var array $connections */ private $connections = []; /** * 监听连接事件 * @param server $server * @param swoolehttprequest $request */ public function onopen(server $server, swoolehttprequest $request): void { $this->connections[$request->fd] = $request->fd; echo "client-{$request->fd} is connected"; } /** * 监听消息事件 * @param server $server * @param frame $frame */ public function onmessage(server $server, frame $frame): void { foreach ($this->connections as $fd) { $info = $server->getclientinfo((int)$fd); if ($info && isset($info['websocket_status']) && $info['websocket_status'] == websocket_status_frame) { $server->push($fd, $frame->data); } else { unset($this->connections[$fd]); } } echo "received message from client-{$frame->fd}: {$frame->data}"; } /** * 监听关闭事件 * @param server $server * @param int $fd * @param int $reactorid */ public function onclose(server $server, int $fd, int $reactorid): void { unset($this->connections[$fd]); echo "client-{$fd} is closed"; } /** * @param response $response */ public function onhandshake(request $request, response $response): bool { // do nothing return true; }}
配置 websocket 服务在写入 websocket 的服务代码之前，我们需要在 config 目录下创建一个名为 swoole.php 的配置文件，写入以下内容：
return [ 'socket_type' => 'websocket', 'host' => '0.0.0.0', 'port' => 9501, 'mode' => swoole_process, 'sock_type' => swoole_sock_tcp, 'settings' => [ 'worker_num' => swoole_cpu_num(), ], 'handler' => ppcontrollerwebsocketserver::class,];
在上面的代码中，我们通过配置文件告诉应用程序如何启动 swoole websocket 服务。我们启动 websocket socket 类型，绑定在 0.0.0.0:9501 上，并开启了多进程模式，使用 tcp 协议。worker_num 配置项设置了服务器的进程数，这里使用了 swoole_cpu_num() 用于返回系统 cpu 数量；handler 配置项指定了我们在上文中创建的 websocketserver 类。
运行 websocket 服务在完成了创建、配置 websocket 服务的代码之后，我们需要运行一下代码，来开启 websocket 服务。在命令行中执行以下命令即可：
php think swoole start --mode=websocket
websocket 服务已经启动，你可以通过访问你的应用程序来测试它。你可以使用这个地址：ws://your-domain:9501/ws。在浏览器中打开多个选项卡，分别测试 websocket 的连接、消息发送和接收等功能。
小结本文介绍了如何使用 thinkphp 6 框架来实现一个 websocket 广播功能。我们通过创建控制器、注册路由和编写 websocket 通信逻辑，以及配置 websocket 服务，来完成这一功能。这个示例可以作为一个简单 websocket 最佳实践，为我们开发更高级的 websocket 功能提供了参考。
以上就是利用thinkphp6实现websocket广播的详细内容。