Redis+Swoole是宝塔面板中PHP跨Worker消息传递的轻量可靠方案,需先确认Redis运行、安装Swoole扩展、编写协程消费者脚本、配置Task进程投递并避免协程冲突。

在宝塔面板中部署的PHP服务需要跨Worker进程传递订单、日志、通知等消息,又不想引入RabbitMQ这类重量级中间件,此时用Redis作为Swoole消息总线是最轻量且可靠的方案。
确认Redis服务已就绪
进入宝塔面板 → 左侧「软件商店」→ 找到已安装的「Redis」→ 点击「设置」→ 查看「运行状态」是否为“正在运行”。若未安装,请先安装Redis 7.x版本并启动服务。
打开终端执行:/www/server/redis/src/redis-cli ping,返回 【PONG】 表示Redis服务可达;若超时或报错,则后续所有步骤无法继续。
安装并启用Swoole扩展
方法一:宝塔软件商店一键安装(推荐)
1、左侧菜单点「软件商店」→ 找到你站点所用的PHP版本(如PHP 80)→ 点击右侧「设置」。
2、切换至「安装扩展」选项卡 → 搜索框输入 swoole → 若显示“Swoole5”或“Swoole4”,点击「安装」。
3、安装完成后务必点击「重启PHP」(不是重载),否则扩展不生效。
方法二:源码编译安装(需指定版本或启用SSL)
1、SSH连接服务器,执行:cd /www/server && wget https://pecl.php.net/get/swoole-5.1.5.tgz。
2、解压并进入目录:tar -zxvf swoole-5.1.5.tgz && cd swoole-5.1.5。
3、调用对应PHP版本的phpize:/www/server/php/80/bin/phpize。
4、配置时必须指向正确的php-config:./configure --with-php-config=/www/server/php/80/bin/php-config --enable-openssl。
5、编译安装:make && make install。
6、编辑php.ini:vi /www/server/php/80/etc/php.ini,末尾新增一行:extension=swoole.so。
7、重启PHP服务。
验证是否成功:/www/server/php/80/bin/php --ri swoole,输出中含 【swoole support => enabled】 及版本号即为正常。
编写Redis消息总线协程消费者
第一步:创建消费者脚本 /www/wwwroot/your-site/redis_consumer.php,内容如下:
Redis 缓存和数据结构管理技能。通过自然语言操作 Redis,支持 String、Hash、List、Set、ZSet、Stream 等数据结构操作。当用户提到 Redis、缓存、消息队列、会话存储时使用此技能。
<?php<br>swoole_async_set(['aio_thread_num' => 2]);<br>$redis = new Swoole\Coroutine\Redis();<br>$redis->connect('127.0.0.1', 6379);<br>while (true) {<br> $res = $redis->brPop(['task_queue'], 5);<br> if ($res && is_array($res) && count($res) === 2) {<br> $payload = json_decode($res[1], true);<br> if ($payload && isset($payload['type'])) {<br> // 根据type分发处理逻辑<br> switch ($payload['type']) {<br> case 'order_created':<br> echo "[ORDER] 处理ID: {$payload['order_id']}\n";<br> break;<br> }<br> }<br> }<br> swoole_timer_tick(100, function() {}); // 防止CPU空转<br>}
第二步:通过宝塔「计划任务」添加守护进程
类型选「Shell脚本」→ 执行周期设为「N分钟」→ 周期值填 【1】 → 脚本内容写:ps aux | grep redis_consumer.php | grep -v grep || cd /www/wwwroot/your-site && /www/server/php/80/bin/php redis_consumer.php > /dev/null 2>&1 &。
第三步:测试生产者推送
新建临时文件 test_push.php:<?php $redis = new Swoole\Coroutine\Redis(); $redis->connect('127.0.0.1', 6379); $redis->lPush('task_queue', json_encode(['type'=>'order_created','order_id'=>time()])); echo "已推入队列\n";,执行后观察消费者终端是否有输出。
配置Swoole Server启用Task进程投递
在你的Swoole HTTP或WebSocket服务启动文件中(如 server.php),加入Task进程配置:
1、初始化Server时添加:$server = new Swoole\Http\Server("0.0.0.0", 9501); $server->set(['task_worker_num' => 4]);。
2、注册Task事件回调:$server->on('task', function ($server, $task_id, $from_worker_id, $data) { $redis = new Swoole\Coroutine\Redis(); $redis->connect('127.0.0.1', 6379); $redis->lPush('task_queue', json_encode($data)); });。
3、在业务逻辑中触发投递:$server->task(['type'=>'order_created','order_id'=>123]);。
4、注意:Task进程内不能直接使用 brPop,必须由独立消费者脚本处理,否则会阻塞整个Task Worker。
确保 【$server->set() 中未设置 'task_enable_coroutine' => true】,该参数会导致Task进程协程化后与Redis连接冲突,引发连接复用错误。

















