Swoole通过长连接和事件驱动实现双向通信,服务器可主动推送数据,客户端亦能发送消息。

Swoole 实现客户端与服务器的双向通信,核心在于其基于事件驱动的长连接机制。与传统的 HTTP 短连接不同,Swoole 的 TCP 或 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("连接关闭"); };只要连接不断开,客户端和服务端都可以随时发送数据,互不依赖请求-响应模式。
基本上就这些。只要理解了长连接 + 事件回调 + 主动 push 的模型,Swoole 的双向通信并不复杂,但非常强大。
以上就是Swoole如何实现客户端与服务器的双向通信的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号