[TOC] ## 安裝 ### mac `brew install beanstalkd ` ## 啟動 `beanstalkd -l 0.0.0.0 -p 11300` * -l 默認為0.0.0.0 * -p 默認為11300 所以等價于 `beanstalkd` ## demo 生產者.php ``` $pheanstalk = Pheanstalk::create('127.0.0.1'); $pheanstalk ->useTube('testtube') ->put("job payload goes here\n"); ``` 消費者.php ``` use Pheanstalk\Pheanstalk; $pheanstalk = Pheanstalk::create('127.0.0.1'); while (true){ $job = $pheanstalk ->watch('testtube') ->reserve(); //默認任務時,阻塞在這里 echo $job->getData(); //刪除處理過的數據 $pheanstalk->delete($job); } ``` 先啟動`消費者.php`做監聽,在執行`生產者.php` ## 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 ## 方法 ### 維護方法 stats() 查看隊列狀態 listTubes() 查看當前所有管道 statsTube(tubeName) 查看指定管道信息 statsJob(job) 查看指定任務信息 ## 使用方法 useTube(tubeName) 指定管道,沒有則自動創建 put(Job, [priority]) 添加任務 putInTube(tubeName, Job, [priority]) 同useTube和put組合 delete(job) 刪除任務 watch(tubeName) 設置要監聽的管道，可以同時設置多個 reserve([time]) 以**阻塞**的方式監聽管道，可以設置阻塞時間,不設置默認永久 ignore("default") 忽略默認管道