PHP Memcache 佇列類 memcacheQueue 完整解析：FIFO、反向讀取、鎖機制與原子操作

前言

高併發系統常需緩衝佇列 (日誌收集、任務分發、訊息推送)。基於 Memcache 實現的 memcacheQueue 類別提供先進先出 (FIFO)、反向讀取、鎖保護、原子增減、過期自動清理等企業級特性。本文深度解析核心原理與使用範例。

核心設計

• 鍵名結構：{queueName}_lkkQueueHead_ (頭指標)、{queueName}_lkkQueueTail_ (尾指標)、{queueName}_lkkQueueValu_{index} (資料)、{queueName}_lkkQueueLock_ (分散式鎖)。
• 指標遞增：頭尾指標單調遞增，array_flip 式索引，避免資料搬移。
• 鎖機制：memcache_add 原子性獲取鎖，usleep 重試，防止併發競態。
• 壓縮儲存：MEMCACHE_COMPRESSED 節省網路/記憶體。

關鍵方法速查

使用範例

$q = new memcacheQueue('task_queue', 3600, ['host'=>'127.0.0.1','port'=>11211]);

// 生產者
for ($i=0; $i<100; $i++) {
    $q->add(['id'=>$i, 'action'=>'send_email', 'to'=>"user$i@example.com"]);
}

// 消費者 (批次取出 10 筆處理)
while (($batch = $q->get(10)) !== false) {
    foreach ($batch as $task) {
        // 處理任務...
        echo "處理任務 {$task['id']}\n";
    }
    // 記得釋放記憶體
    unset($batch);
}

// 反向讀取 (最新優先)
$latest = $q->get(-5); // 取最後 5 筆

進階：分散式系統注意事項

1. 指標持久化：Memcache 重啟會丟失指標，導致資料無法讀取。建議定期將 head/tail 同步寫入 MySQL/Redis 持久化，重啟時恢復。
2. 資料過期 vs 佇列長度：expire 設太短會導致未消費資料消失；設太長佔用記憶體。依業務 SLA 設定 (如 1 小時)。
3. 大資料分片：單值超過 1MB 會降低效能，大任務建議只存任務 ID，實際資料存在資料庫/物件儲存。
4. 監控指標：暴露 getQueueLength() 供 Prometheus/Grafana 抓取，設定告警閾值。

替代方案比較

總結

memcacheQueue 以巧妙的指標設計在 Memcache 上實現了高效能佇列，適合中小型專案、已有 Memcache 基礎設施、容忍極低概率資料丟失的場景。核心優勢在於無鎖讀取 (read)、反向讀取、原子鎖保護寫入。生產環境務必加上指標持久化與監控告警。