Beanstalkd，一個高效能、輕量級的分散式記憶體佇列系統 
安裝參考GitHub：https://github.com/kr/beanstalkd 
啟動Beanstalkd : beanstalkd -l 127.0.0.1 -p 11300

佇列的使用場景：非同步處理、系統解耦、定時處理。

Beanstalk的特性

1. 優先順序（priority）
2. 延遲（delay）
3. 持久化（persistent data）
4. 預留（buried）
5. 任務超時重發（time-to-run）

Beanstalk的核心元素

• 管道（tube）
• 任務（job） 
  

Beanstalk的任務狀態

• ready 任務就緒，隨時可以被消費
• delayed 任務延遲，延遲時間到時進入ready狀態
• buried 任務預留，此狀態會重新進入ready
• delete 刪除任務
• reserved 任務正在消費中，此狀態可以進入delayed、ready、buried、delete

PHP操作Beanstalkd需要安裝Pheanstalk 
通過composer安裝 composer require pda/pheanstalk

require 'vendor/autoload.php';

use Pheanstalk\Pheanstalk;

$pheanstalk = new Pheanstalk('127.0.0.1','11300');

• 1
• 2
• 3
• 4
• 5
• 6

通過 new Pheanstalk(host, port)

Pheanstalk類常用操作

• stats() 檢視佇列狀態
• listTubes() 檢視當前所有管道
• statsTube(tubeName) 檢視指定管道資訊
• statsJob(job) 檢視指定任務資訊
• useTube(tubeName) 指定管道
• put(Job, [priority]) 新增任務
• putInTube(tubeName, Job, [priority]) 同useTube和put組合
• delete(job) 刪除任務
• watch(tubeName) 設定要監聽的管道，可以同時設定多個
• reserve([time]) 以阻塞的方式監聽管道，可以設定阻塞時間,不設定預設永久

栗子

選擇demo管道新增一個任務 
然後列印管道狀態

$pheanstalk->useTube('demo')->put("test");
print_r($pheanstalk->statsTube('demo'));

• 1
• 2

current-jobs-ready表示當前ready狀態的任務數量，其他current-jobs同理。 
total-jobs 表示當前管道所有任務數量 
current-using 當前有多少個生產者正在使用這個管道（使用useTube累計+1） 
current-watching 當前有多少個消費者正在使用這個管道（使用watch累計+1） 
current-waiting 當前有多少消費者正在等待任務（使用watch阻塞等待中累計+1）

監聽demo管道，列印任務資訊

    $job = $pheanstalk->watch('d$pheanstalk->delete($job);emo')->reserve();
    //一般任務被reserve讀出後，業務處理完成時應及時進行delete操作，防止重新被放回管道
    print_r($pheanstalk->statsJob($job));
    //$pheanstalk->delete($job);

• 1
• 2
• 3
• 4

id 為當前任務的唯一id 
tube 為當前任務所在的管道 
state 當前任務的狀態 
pri 當前任務的優先順序，預設1024，數字越小優先順序越大 
age 表示當前任務存在秒數 
delay 表示當前任務延遲秒數 
ttr 表示任務超時時間，預設60秒 
time-left 表示當前任務在reserved狀態已經維持了多少秒，超過ttr時間將重新放回管道 
file 如果沒有開啟檔案快取此處數值為0 
reserves 已經被reserves次數