輕量級消息隊列benastalkd

Beanstalkd設計裏面的核心概念：

◆ job

一個須要異步處理的任務，是Beanstalkd中的基本單元，須要放在一個tube中。

◆ tube

一個有名的任務隊列，用來存儲統一類型的job，是producer和consumer操做的對象。

◆ producer

Job的生產者，經過put命令來將一個job放到一個tube中。

◆ consumer

Job的消費者，經過reserve/release/bury/delete命令來獲取job或改變job的狀態。 Beanstalkd中一個job的生命週期如圖所示。一個job有READY, RESERVED, DELAYED, BURIED四種狀態。當producer直接put一個job時，job就處於READY狀態，等待consumer來處理，若是選擇延遲put，job就先到DELAYED狀態，等待時間事後才遷移到READY狀態。consumer獲取了當前READY的job後，該job的狀態就遷移到RESERVED，這樣其餘的consumer就不能再操做該job。當consumer完成該job後，能夠選擇delete, release或者bury操做;delete以後，job從系統消亡，以後不能再獲取;release操做能夠從新把該job狀態遷移回READY(也能夠延遲該狀態遷移操做)，使其餘的consumer能夠繼續獲取和執行該job;有意思的是bury操做，能夠把該job休眠，等到須要的時候，再將休眠的job kick回READY狀態，也能夠delete BURIED狀態的job。正是有這些有趣的操做和狀態，才能夠基於此作出不少意思的應用，好比要實現一個循環隊列，就能夠將RESERVED狀態的job休眠掉，等沒有READY狀態的job時再將BURIED狀態的job一次性kick回READY狀態。

1、安裝beanstalkd

sudo apt-get install beanstalkd

源碼安裝 tar -zxvf /usr/bin/beanstalkd/beanstalkd-1.9.tar.gz cd beanstalkd make install PERFIX=/usr/bin/beanstalkd

後臺啓動：

beanstalkd -l 地址 -p 端口號 -z 最大的任務大小(byte) -c &

ps:若是是外部客戶端鏈接，ip地址要寫外網地址，這樣才能鏈接上

例：/usr/bin/beanstalkd -l 192.168.50.233 -p 11311

2、示例

//1.連接benstalkd
require 'beanstalkd.php';
$baenstalkd=new beanstalkd();
$pheanstalk=$baenstalkd->getBeanstalkd('192.168.50.233','11311');
$tube='test';//tube名

//2.生產任務
$info=array('name'=>'tjj','sex'=>'男');
$ret=$baenstalkd->send2queue($pheanstalk,$tube,json_encode($info));//發送消息隊列

//2.消費（處理任務） //消費隊列消息

while($job=$pheanstalk->watch($tube)->ignore('default')->reserve()){
    $ret=$job->getData();
    var_dump($ret);
    $pheanstalk->delete($job);
    
}

3、上述代碼下載：https://git.oschina.net/tanjiajun/share.git