swoole通过长连接和事件驱动实现双向通信，服务器可主动推送数据，客户端亦能发送消息。
Swoole 实现客户端与服务器的双向通信，核心在于其基于事件驱动的长连接机制。与传统的 HTTP 短连接不同，Swoole 的 TCP 或 WebSocket 服务在连接建立后保持持久通道，允许服务器主动向客户端推送数据，同时也能接收客户端发送的消息，从而实现真正的双向通信。
使用 Swoole WebSocket 实现双向通信
WebSocket 是实现双向通信最常用的方式。Swoole 内置了对 WebSocket 协议的支持，开发者可以快速搭建一个全双工通信服务。
服务端代码示例：
$server = new Swoole\WebSocket\Server("0.0.0.0", 9501); $server->on('open', function ($server, $req) { echo "客户端 {$req->fd} 已连接\n"; }); $server->on('message', function ($server, $frame) { echo "收到消息: {$frame->data} 来自客户端 {$frame->fd}\n"; // 向所有客户端广播消息 foreach ($server->connections as $fd) { if ($server->isEstablished($fd)) { $server->push($fd, "服务器回复: {$frame->data}"); } } }); $server->on('close', function ($server, $fd) { echo "客户端 {$fd} 已断开\n"; }); $server->start();上述代码中，服务器监听 9501 端口，当客户端发送消息时，服务端通过 $server->push($fd, $data) 主动向指定客户端发送数据，实现“服务器 → 客户端”的通信；而客户端通过 WebSocket API 发送消息则完成“客户端 → 服务器”通信。
客户端如何连接并收发消息
前端 JavaScript 可以使用原生 WebSocket API 连接 Swoole 服务：
const ws = new WebSocket("ws://your-server-ip:9501"); ws.onopen = () => { console.log("连接成功"); ws.send("你好，Swoole！"); }; ws.onmessage = (event) => { console.log("收到服务器消息:", event.data); }; ws.onclose = () => { console.log("连接关闭"); };只要连接不断开，客户端和服务端都可以随时发送数据，互不依赖请求-响应模式。
双向通信的关键点
- 连接持久化：Swoole 维护每个客户端的 file descriptor（fd），通过 fd 可精准定位连接，实现定向或广播推送。
- 事件回调机制：on('message') 处理客户端上行数据，$server->push() 实现下行推送，两者结合构成双向流动。
- 支持多种协议：除 WebSocket 外，也可用 Swoole TCP 服务配合自定义协议实现双向通信，适用于非浏览器场景。
- 高并发能力：基于协程和异步 I/O，单个 Swoole 服务可维持数十万长连接，适合实时聊天、通知系统等场景。
基本上就这些。只要理解了长连接 + 事件回调 + 主动 push 的模型，Swoole 的双向通信并不复杂，但非常强大。
