Composer在线学习地址：学习地址
还记得你上一次在网站上点击一个按钮，然后页面转啊转，等了半天甚至直接报错“gateway timeout”的经历吗？这在php应用中是个常见痛点，尤其当你的程序需要执行一些耗时操作时，比如：批量发送上千封邮件、生成复杂的pdf报告、或者与响应缓慢的第三方api进行交互。
传统的同步执行模式意味着，在这些任务完成之前，用户的请求会一直被“挂起”。结果就是：用户体验极差、服务器资源被长时间占用、甚至直接触发PHP的执行时间限制，导致请求失败。我曾为此焦头烂额，尝试过各种优化代码、调整PHP配置，但治标不治本。真正的问题在于，这些任务根本就不应该在用户请求的生命周期内同步完成。
遇见救星：resque/php-resque
就在我几乎要放弃的时候，我遇到了一个改变游戏规则的工具：
resque/php-resque。
简单来说，它是一个基于Redis的PHP库，灵感来源于Ruby社区的Resque。它的核心思想是：把那些耗时的任务扔到一个“待办事项列表”（队列）里，让专门的“工人”（Worker）在后台慢慢处理，而你的主程序则可以立即响应用户，告诉他们“任务已提交，请稍候”。
这就像你去餐厅点餐，服务员不是等你吃完才去招呼下一位客人，而是先记下你的订单，然后把订单交给后厨，自己继续服务其他客人。你和后厨（Worker）之间，就通过订单（Queue）来沟通。
立即学习“PHP免费学习笔记（深入）”；
resque/php-resque提供了一系列强大功能：
- Redis支持：利用Redis的快速读写能力作为任务队列的存储。
- 分布式Worker：可以在多台机器上部署Worker，轻松扩展处理能力。
- 任务优先级：支持多个队列，可以为不同类型的任务设置不同的优先级。
-
健壮性：通过PHP的
fork
机制（在支持的系统上）， Worker在处理任务时是独立的子进程，即使任务失败也不会影响主Worker。 - 任务状态追踪：可以追踪任务的执行状态（等待中、运行中、已完成、失败）。
-
延迟任务：通过
php-resque-scheduler
，可以安排任务在未来的某个时间点执行。
如何使用Composer集成resque/php-resque
使用Composer集成
resque/php-resque简直是小菜一碟。
-
安装
resque/php-resque
在你的项目根目录下，打开终端，运行以下命令：
composer require resque/php-resque
安装完成后，别忘了在你的项目入口文件（例如
index.php
或public/index.php
）中引入Composer的自动加载文件：require 'vendor/autoload.php';
-
配置Redis连接
resque/php-resque
默认会尝试连接localhost:6379
的Redis服务器。如果你的Redis位于其他地址或端口，你需要明确指定：use Resque\Resque; Resque::setBackend('localhost:6379'); // 或者 '192.168.1.100:6379' -
定义一个任务（Job）
每个后台任务都需要定义在一个独立的PHP类中，并且必须包含一个
perform()
方法。所有实际的业务逻辑都在这个方法中实现。例如，我们来创建一个发送欢迎邮件的任务：
<?php // src/Job/WelcomeEmailJob.php namespace App\Job; // 根据你的项目结构定义命名空间 class WelcomeEmailJob { /** * 任务执行时传递的参数 * @var array */ public $args; public function perform() { $userId = $this->args['userId']; $email = $this->args['email']; $username = $this->args['username']; // 模拟发送邮件的耗时操作 sleep(5); // 假设发送一封邮件需要5秒 // 将邮件发送记录到日志文件，实际应用中可能是调用邮件服务 file_put_contents( __DIR__ . '/../../logs/emails.log', sprintf("[%s] Sending welcome email to %s (%s) for user %d\n", date('Y-m-d H:i:s'), $username, $email, $userId), FILE_APPEND ); echo "Sent welcome email to {$username} ({$email})\n"; // 如果任务执行过程中发生异常，Resque会自动将其标记为失败 // throw new \Exception("Failed to send email!"); } /** * 可选：任务执行前调用 */ public function setUp() { // 例如：建立数据库连接、初始化日志等 // echo "Setting up for job...\n"; } /** * 可选：任务执行后调用 */ public function tearDown() { // 例如：关闭数据库连接、清理临时文件等 // echo "Tearing down after job...\n"; } } -
将任务推入队列
现在，当用户注册成功后，我们不再直接发送邮件，而是将发送邮件的任务推送到队列中。
<?php // public/register.php (模拟用户注册成功后的操作) require __DIR__ . '/../vendor/autoload.php'; // 引入Composer自动加载 use Resque\Resque; use App\Job\WelcomeEmailJob; // 确保你的Job类被正确加载 // 假设用户注册成功，获取到用户信息 $newUserId = 123; $newUserEmail = 'test@example.com'; $newUsername = 'JohnDoe'; // 设置Redis连接 Resque::setBackend('localhost:6379'); // 将发送邮件的任务推入名为 'email' 的队列 // WelcomeEmailJob::class 是PHP 5.5+ 获取类名的标准方式 $args = [ 'userId' => $newUserId, 'email' => $newUserEmail, 'username' => $newUsername, ]; Resque::enqueue('email', WelcomeEmailJob::class, $args); echo "用户 {$newUsername} 注册成功，欢迎邮件已加入发送队列！页面将立即响应。\n"; // 页面可以立即跳转或显示成功信息，用户无需等待邮件发送完成 -
启动Worker处理任务
光把任务扔进队列还不行，还需要有“工人”来处理它们。
resque/php-resque
提供了一个命令行工具来启动Worker。在项目根目录下，打开终端，运行以下命令（确保Redis服务器正在运行）：
# QUEUE='email' 表示这个Worker只处理名为 'email' 的队列 # QUEUE='*' 表示处理所有队列 # APP_INCLUDE 用于加载你的应用程序环境，特别是Job类，这里直接用 Composer 的 autoload QUEUE='email' APP_INCLUDE='vendor/autoload.php' php vendor/bin/resque
此时，你会在终端看到Worker开始工作，它会从
email
队列中取出WelcomeEmailJob
并执行perform()
方法。用户注册页面会瞬间响应，而邮件则在后台悄悄地发送。你也可以启动多个Worker来并行处理任务，或者使用
php vendor/bin/resque-scheduler
来处理延迟任务。
resque/php-resque
带来的优势和实际应用效果
通过引入
resque/php-resque，我的PHP应用获得了显著的提升：
- 用户体验飞升：用户不再需要漫长等待，页面秒级响应，显著提升满意度。无论是注册、下单还是上传文件，用户都能获得即时反馈，而耗时操作则在幕后默默完成。
- 系统稳定性增强：避免了因单个耗时操作导致的请求超时和服务器崩溃，即使某个任务失败，也不会影响主应用的正常运行。失败的任务可以被记录下来，方便后续重试或分析。
- 轻松实现可伸缩性：当任务量增加时，只需简单地启动更多的Worker进程或部署到更多的服务器上，即可横向扩展处理能力，轻松应对流量高峰。
- 资源高效利用：耗时任务被隔离处理，主Web服务器可以专注于快速响应用户请求，CPU和内存资源分配更合理，提高了整体吞吐量。
- 业务逻辑解耦：将核心业务逻辑与耗时操作分离，代码结构更清晰，更易于维护和测试。例如，发送邮件的逻辑可以独立测试，不依赖于用户注册流程。
总结
resque/php-resque不仅仅是一个库，它是一种处理耗时任务的全新范式。它帮助我将那些曾经令人头疼的性能瓶颈转化为流畅的用户体验，让我的PHP应用变得更加健壮和高效。
如果你也正被PHP应用中的耗时操作所困扰，那么我强烈推荐你尝试一下
resque/php-resque。它会让你对异步任务处理有全新的认识，并为你的应用带来质的飞跃。告别“Gateway Timeout”，拥抱快速响应和弹性扩展的未来！
