PHP 使用 php-resque + Redis 實現消息佇列：從原理到落地完整教程

PHP 使用 php-resque + Redis 實現消息佇列：從原理到落地完整教程

Web 應用中耗時任務（發郵件、生成報表、推播通知）不宜阻塞 HTTP 請求。Resque 架構（Job + Queue + Worker）提供標準化解決方案。本文詳細講解 php-resque 安裝、Job/Worker 編寫、佇列操作、狀態追蹤與生產部署要點。

一、核心角色劃分

二、環境需求與安裝

• Linux 環境（需 pcntl、posix 擴充，Windows 不支援 fork）。
• Redis Server（apt-get install redis-server）。
• Composer 管理依賴。

# 專案目錄
composer require chrisboulton/php-resque
# 或手動 clone
git clone https://github.com/chrisboulton/php-resque.git
cd php-resque && composer install

三、編寫 Job 類別

// jobs/SendMailJob.php
class SendMailJob {
    public function perform() {
        // $this->args 為入佇列時傳遞的參數陣列
        $to      = $this->args['to'];
        $subject = $this->args['subject'];
        $body    = $this->args['body'];

        // 實際發送邏輯（可用 PHPMailer）
        $mailer = new \PHPMailer\PHPMailer\PHPMailer();
        // ... 設定 SMTP、內容 ...
        $mailer->addAddress($to);
        $mailer->Subject = $subject;
        $mailer->Body = $body;
        $mailer->send();

        // 可選：輸出日誌到 STDOUT，Worker 會捕獲
        fwrite(STDOUT, "[".date('Y-m-d H:i:s')."] Mail sent to {$to}\n");
    }
    
    // 可選：設置失敗重試次數
    // public $maxRetries = 3;
    
    // 可選：設置佇列名稱（預設 default）
    // public $queue = 'emails';
}

四、將 Job 推入佇列（生產端，如 Controller）

require_once 'vendor/autoload.php';

use Resque\Resque;

Resque::setBackend('127.0.0.1:6379'); // Redis 連線

$jobId = Resque::enqueue('emails', 'SendMailJob', [
    'to'      => 'user@example.com',
    'subject' => '歡迎註冊',
    'body'    => '感謝您的註冊，您的驗證碼是 123456',
], true); // true = 追蹤狀態

echo "Job 已入佇列，ID: {$jobId}";

五、啟動 Worker（消費端，命令列常駐）

# 單進程處理 emails 佇列
QUEUE=emails php vendor/bin/resque.php

# 多進程（需安裝 php-resque-scheduler 或使用 supervisor 管理多個 worker）
COUNT=5 QUEUE=emails php vendor/bin/resque.php

# 處理所有佇列
QUEUE=* php vendor/bin/resque.php

Worker 會 fork 子進程執行 Job，主進程負責監控與信號處理。生產環境**必須使用 Supervisor/Systemd 管理 Worker 進程**，保證自動重啟、日誌輪轉、開機自啟。

六、Supervisor 部署範例

# /etc/supervisor/conf.d/resque-worker.conf
[program:resque-worker]
command=php /var/www/project/vendor/bin/resque.php
process_name=%(program_name)s_%(process_num)02d
numprocs=5
directory=/var/www/project
user=www-data
autostart=true
autorestart=true
redirect_stderr=true
stdout_logfile=/var/log/supervisor/resque-worker.log
environment=QUEUE="emails",APP_ENV="production"

supervisorctl reread && supervisorctl update && supervisorctl status

七、狀態追蹤與監控

// 獲取 Job 狀態
$status = Resque\Job\Status::get($jobId);
echo $status; // 1=waiting, 2=running, 3=failed, 4=complete

// 失敗任務查看
$failed = Resque\Failure\Failure::all(0, 20);
foreach ($failed as $job) {
    echo "Job: {$job['payload']['class']}, Error: {$job['error']}\n";
}

// 重試失敗任務
Resque\Failure\Failure::retry($failedJobId);

八、進階功能與最佳實踐

• 延遲任務： 使用 php-resque-scheduler 擴充，支援 enqueueAt($timestamp, ...)、enqueueIn($seconds, ...)。
• 優先級佇列： 啟動 Worker 時指定 QUEUE=high,default,low，高優先級佇列先被消費。
• Job 內部異常處理： perform() 拋出異常會被 Worker 捕獲、標記失敗、記錄堆疊、可選重試。
• 唯一性鎖： 避免重複任務，可在 perform() 開頭用 Redis SETNX 鎖定 key。
• 監控儀表板： 部署 php-resque-web（Sinatra/React 介面）即時查看佇列長度、Worker 狀態、失敗率。

九、常見坑點避雷

1. 上一篇文章： ThinkPHP 批量更新數據三大方案：CASE WHEN、迴圈事務、遞歸回滾實戰
2. 下一篇文章： PHP 圖片上傳類實現：含縮略圖生成、類型檢驗與錯誤處理

PHP 相關知識

8 分鐘上手 DedeCMS (織夢) 全流程：安裝、欄目、模板、標簽、生成、避坑

DedeCMS 以「簡單、實用、開源」聞名，是國內使用量最大

PHP 動態驗證碼產生器完整實作：從圖片產生到 Session 驗證

PHP 動態驗證碼產生器完整實作：從圖片產生到 Sessio

PHP empty() / is_null() / isset() 三大判斷函數差異徹底圖解

函數定義回顧 isset($var)：變量**存在且不為

PHP 實現九九乘法表：從基礎邏輯到面試優化的多種寫法

九九乘法表是經典的編程入門練習，考察雙層循環控制、字符串拼接