Beanstalkd隊(duì)列的使用方法

本篇內(nèi)容主要講解“Beanstalkd隊(duì)列的使用方法”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實(shí)用性強(qiáng)。下面就讓小編來帶大家學(xué)習(xí)“Beanstalkd隊(duì)列的使用方法”吧!

安裝

1. 官網(wǎng):https://kr.github.io/beanstalkd/

2. 安裝（也可以采用composer進(jìn)行安裝）

yum install beanstalkd --enablerepo=epel

或者

 composer require pda/pheanstalk

• 1

1. 啟動（0.0.0.0可以運(yùn)行任何ip進(jìn)行連接）

   /usr/bin/beanstalkd -l 0.0.0.0 -p 11300 -b /var/lib/beanstalkd/binlog -F

    

   -b 開啟binlog，斷電后重啟會自動恢復(fù)任務(wù)。

• 1

2. 配置文件

/etc/sysconfig/beanstalkd

• 1

基本概念

1. Beanstalkd設(shè)計(jì)里面的核心概念：

• job：一個需要異步處理的任務(wù)，是 Beanstalkd 中的基本單元，需要放在一個 tube 中。

• tube：一個有名的任務(wù)隊(duì)列，用來存儲統(tǒng)一類型的 job，是 producer 和 consumer 操作的對象。

• producer：Job 的生產(chǎn)者，通過 put 命令來將一個 job 放到一個 tube 中。

• consumer：Job的消費(fèi)者，通過 reserve/release/bury/delete 命令來獲取 job 或改變 job 的狀態(tài)。

2. job 的生命周期

當(dāng)producer直接put一個job時，job就處于READY狀態(tài)，等待consumer來處理，如果選擇延遲put，job就先到DELAYED狀態(tài)，等待時間過后才遷移到READY狀態(tài)。

consumer獲取了當(dāng)前READY的job后，該job的狀態(tài)就遷移到RESERVED，這樣其他的consumer就不能再操作該job。當(dāng)consumer完成該job后，可以選擇delete, release或者bury操作；delete之后，job從系統(tǒng)消亡，之后不能再獲??；release操作可以重新把該job狀態(tài)遷移回READY（也可以延遲該狀態(tài)遷移操作），使其他的consumer可以繼續(xù)獲取和執(zhí)行該job；有意思的是bury操作，可以把該job休眠，等到需要的時候，再將休眠的job kick回READY狀態(tài)，也可以delete BURIED狀態(tài)的job。

正是有這些有趣的操作和狀態(tài)，才可以基于此做出很多意思的應(yīng)用，比如要實(shí)現(xiàn)一個循環(huán)隊(duì)列，就可以將RESERVED狀態(tài)的job休眠掉，等沒有READY狀態(tài)的job時再將BURIED狀態(tài)的job一次性kick回READY狀態(tài)。

• READY - 需要立即處理的任務(wù)，當(dāng)延時 (DELAYED) 任務(wù)到期后會自動成為當(dāng)前任務(wù)；

• DELAYED - 延遲執(zhí)行的任務(wù), 當(dāng)消費(fèi)者處理任務(wù)后, 可以用將消息再次放回 DELAYED 隊(duì)列延遲執(zhí)行；

• RESERVED - 已經(jīng)被消費(fèi)者獲取, 正在執(zhí)行的任務(wù)。Beanstalkd 負(fù)責(zé)檢查任務(wù)是否在 TTR(time-to-run) 內(nèi)完成；

• BURIED - 保留的任務(wù): 任務(wù)不會被執(zhí)行，也不會消失，除非有人把它 “踢” 回隊(duì)列；

• DELETED - 消息被徹底刪除。Beanstalkd 不再維持這些消息。

一些特性

• 優(yōu)先級

任務(wù) (job) 可以有 0~2^32 個優(yōu)先級, 0 代表最高優(yōu)先級，默認(rèn)優(yōu)先級為1024。

• 持久化

可以通過binlog將job及其狀態(tài)記錄到文件里面，在Beanstalkd下次啟動時可以通過讀取binlog來恢復(fù)之前的job及狀態(tài)。

• 分布式容錯

分布式設(shè)計(jì)和Memcached類似，beanstalkd各個server之間并不知道彼此的存在，都是通過client來實(shí)現(xiàn)分布式以及根據(jù)tube名稱去特定server獲取job。

• 超時控制 
  為了防止某個consumer長時間占用任務(wù)但不能處理的情況，Beanstalkd為reserve操作設(shè)置了timeout時間，如果該consumer不能在指定時間內(nèi)完成job，job將被遷移回READY狀態(tài)，供其他consumer執(zhí)行。

Client Libraries For PHP

項(xiàng)目地址：https://github.com/pda/pheanstalk/

1. Producer 示例：向隊(duì)列中添加job

$pheanstalk = new Pheanstalk_Pheanstalk('127.0.0.1');

$pheanstalk ->useTube('tubeName') ->put($jobData);

1. Consumer 示例：從隊(duì)列中取出job

$job = $pheanstalk ->watch('tubeName') ->ignore('default') ->reserve();

echo $job->getData();

$pheanstalk->delete($job);

1. 檢查服務(wù)狀態(tài)

$isAlive = $pheanstalk->getConnection()->isServiceListening(); //返回 true 或 false
4、獲取某一 tube 的數(shù)據(jù)
try{
    $tubeStatus = $pheanstalk->statsTube('tubeName');
} catch (Exception $e){
    if($e->getMessage()=='Server reported NOT_FOUND'){     //tube 不存在
        $current_jobs_ready = 0;
    }
}

到此，相信大家對“Beanstalkd隊(duì)列的使用方法”有了更深的了解，不妨來實(shí)際操作一番吧！這里是億速云網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！