【swoole】OpenSwoole的应用 OpenSwoole 是 PHP 的异步、协程、高性能网络通信引擎，能让 PHP 做到：高性能 HTTP 服务（替代 Nginx+FPM，单机万级并发）异步任务（邮件、短信、推送不阻塞主流程）定时任务（替代 Linux Crontab）WebSocket 实时通信（聊天室、实时通知）TCP/UDP 服务、微服务、高并发爬虫环境准备（1 分钟安装）# 安装 openswoole 扩展 pecl install openswoole验证：<?php echo OpenSwoole\Util::getVersion();场景 1：搭建高性能 HTTP 服务（最常用）替代传统 Nginx+PHP-FPM，并发提升 10~100 倍，支持路由、静态文件、接口服务。完整可运行代码<?php use OpenSwoole\Http\Server; use OpenSwoole\Http\Request; use OpenSwoole\Http\Response; // 创建 HTTP 服务，监听 0.0.0.0:9501 $server = new Server('0.0.0.0', 9501); // 配置（worker 数 = CPU 核心数） $server->set([ 'worker_num' => 4, 'enable_static_handler' => true, 'document_root' => __DIR__ . '/public', // 静态文件目录 ]); // 处理请求 $server->on('Request', function (Request $request, Response $response) { // 获取请求参数 $path = $request->server['request_uri']; $get = $request->get; $post = $request->post; // 路由分发 if ($path === '/') { $response->header('Content-Type', 'text/html; charset=utf-8'); $response->end("<h1>OpenSwoole HTTP 服务运行中</h1>"); } // 接口示例：用户信息 elseif ($path === '/api/user') { $uid = $get['uid'] ?? 0; $response->header('Content-Type', 'application/json'); $response->end(json_encode([ 'code' => 0, 'msg' => 'success', 'data' => [ 'uid' => $uid, 'name' => 'OpenSwoole 用户', 'time' => date('Y-m-d H:i:s') ] ])); } else { $response->status(404); $response->end("404 Not Found"); } }); echo "服务启动：http://127.0.0.1:9501\n"; $server->start();运行 & 测试php http_server.php # 访问 # http://127.0.0.1:9501 # http://127.0.0.1:9501/api/user?uid=100你必须掌握的点Request 封装所有请求信息（GET/POST/HEADER/COOKIE）Response 只能调用一次 end()，响应结束服务常驻内存，比传统 PHP 快极多场景 2：异步任务（最核心业务价值）场景：注册发送邮件、下单发送短信、日志上报、数据统计——不阻塞用户请求。异步任务服务器代码<?php use OpenSwoole\Http\Server; use OpenSwoole\Http\Request; use OpenSwoole\Http\Response; $server = new Server('0.0.0.0', 9502); $server->set([ 'worker_num' => 2, 'task_worker_num' => 4, // 任务进程数 ]); // 处理 HTTP 请求 $server->on('Request', function (Request $request, Response $response) use ($server) { // 业务：用户注册 $data = [ 'email' => 'test@demo.com', 'content' => '欢迎注册' ]; // 投递异步任务（非阻塞，瞬间返回） $server->task($data); // 直接响应，不用等邮件发送完成 $response->end("注册成功，邮件已发送"); }); // 任务处理进程 $server->on('Task', function ($server, $taskId, $workerId, $data) { echo "开始发送邮件：{$data['email']}\n"; // 模拟耗时：2 秒（真实场景：发送邮件/短信/推送） sleep(2); echo "邮件发送完成\n"; // 任务完成 return 'success'; }); // 任务完成回调 $server->on('Finish', function ($server, $taskId, $result) { echo "任务 $taskId 完成，结果：$result\n"; }); $server->start();核心价值用户请求0 等待耗时任务丢给任务进程，不影响接口响应速度支撑高并发业务必备场景 3：WebSocket 实时通信（聊天室/实时通知）场景：在线客服、实时弹幕、订单状态实时推送、游戏。服务端代码<?php use OpenSwoole\WebSocket\Server; use OpenSwoole\WebSocket\Frame; use OpenSwoole\Http\Request; $server = new Server('0.0.0.0', 9503); // 客户端连接 $server->on('Open', function (Server $server, Request $request) { echo "客户端 {$request->fd} 连接\n"; }); // 接收消息并广播 $server->on('Message', function (Server $server, Frame $frame) { echo "收到消息：{$frame->data}\n"; // 广播给所有在线客户端（聊天室核心） foreach ($server->connections as $fd) { if ($server->isEstablished($fd)) { $server->push($fd, "广播：{$frame->data}"); } } }); // 客户端关闭 $server->on('Close', function (Server $server, $fd) { echo "客户端 {$fd} 断开\n"; }); $server->start();前端测试代码（HTML）<script> const ws = new WebSocket('ws://127.0.0.1:9503'); ws.onmessage = (e) => alert(e.data); // 发送消息 ws.send('Hello OpenSwoole'); </script>场景 4：定时任务（替代 Crontab，更灵活）场景：每分钟统计订单、每小时清理缓存、每天同步数据。<?php use OpenSwoole\Timer; // 每 1 秒执行 Timer::tick(1000, function () { echo "每秒执行：" . date('H:i:s') . "\n"; }); // 5 秒后执行一次 Timer::after(5000, function () { echo "5 秒后执行\n"; }); // 保持服务运行 Swoole\Event::wait();场景 5：协程 MySQL + Redis（高并发数据库操作）OpenSwoole 协程能让IO 操作（MySQL/Redis/Curl）并发执行，速度提升巨大。协程 MySQL 示例<?php use OpenSwoole\Coroutine\MySQL; use OpenSwoole\Coroutine; Coroutine::create(function () { $db = new MySQL(); $db->connect([ 'host' => '127.0.0.1', 'user' => 'root', 'password' => '123456', 'database' => 'test', ]); $res = $db->query('SELECT * FROM user LIMIT 1'); var_dump($res); });并发请求（3 个请求并行，只花 1 秒而不是 3 秒）<?php use OpenSwoole\Coroutine; Coroutine\run(function () { // 并行 3 个协程 Coroutine::create(function () { sleep(1); echo "任务1\n"; }); Coroutine::create(function () { sleep(1); echo "任务2\n"; }); Coroutine::create(function () { sleep(1); echo "任务3\n"; }); });场景 6：多进程处理（大量数据导出/批量任务）场景：百万数据导出、批量发送消息、数据清洗。<?php use OpenSwoole\Process; // 创建 4 个子进程 for ($i = 0; $i < 4; $i++) { $process = new Process(function () use ($i) { echo "子进程 $i 运行，PID：" . getmypid() . "\n"; sleep(2); echo "子进程 $i 结束\n"; }); $process->start(); } // 回收子进程 while ($ret = Process::wait()) { echo "子进程 {$ret['pid']} 退出\n"; }你必须掌握的 5 个核心特性（精通关键）1. 常驻内存传统 PHP：请求结束 → 销毁所有变量OpenSwoole：变量常驻内存，重复使用注意：不要用全局变量存用户会话，会串请求2. 协程（Coroutine）轻量级线程，开销极小IO 阻塞（MySQL/Redis/Curl）自动切换高并发核心技术3. 异步非阻塞任务、消息推送、文件IO都可以异步接口响应速度极快4. 多进程模型Master 管理进程Worker 处理请求Task 处理异步任务5. 热重启（生产必备）修改代码后不用重启服务：kill -USR1 主进程PID生产环境最佳实践（直接照做）配置 worker_num = CPU 核心数静态文件用 Nginx 代理，PHP 接口用 OpenSwoole数据库连接使用连接池定时任务统一管理使用 systemd 守护进程总结你现在已经掌握 OpenSwoole 最实用的 6 大业务场景，所有代码复制即可运行：HTTP 高性能接口服务异步任务（邮件/短信/推送）WebSocket 实时通信定时任务协程并发 MySQL/Redis多进程批量任务