摘要:的消費者,通過命令來獲取或改變的狀態(tài)。不再維持這些消息。持久化可以通過將及其狀態(tài)記錄到文件里面,在下次啟動時可以通過讀取來恢復之前的及狀態(tài)。
一、安裝 1、官網(wǎng)
https://kr.github.io/beanstalkd/
2、安裝yum install beanstalkd --enablerepo=epel3、啟動
/usr/bin/beanstalkd -l 0.0.0.0 -p 11300 -b /var/lib/beanstalkd/binlog -F
-b 開啟binlog,斷電后重啟會自動恢復任務。
4、配置文件/etc/sysconfig/beanstalkd二、基本概念 1、Beanstalkd設計里面的核心概念:
job:一個需要異步處理的任務,是 Beanstalkd 中的基本單元,需要放在一個 tube 中。
tube:一個有名的任務隊列,用來存儲統(tǒng)一類型的 job,是 producer 和 consumer 操作的對象。
producer:Job 的生產(chǎn)者,通過 put 命令來將一個 job 放到一個 tube 中。
consumer:Job的消費者,通過 reserve/release/bury/delete 命令來獲取 job 或改變 job 的狀態(tài)。
2、job 的生命周期當producer直接put一個job時,job就處于READY狀態(tài),等待consumer來處理,如果選擇延遲put,job就先到DELAYED狀態(tài),等待時間過后才遷移到READY狀態(tài)。consumer獲取了當前READY的job后,該job的狀態(tài)就遷移到RESERVED,這樣其他的consumer就不能再操作該job。當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),才可以基于此做出很多意思的應用,比如要實現(xiàn)一個循環(huán)隊列,就可以將RESERVED狀態(tài)的job休眠掉,等沒有READY狀態(tài)的job時再將BURIED狀態(tài)的job一次性kick回READY狀態(tài)。
READY - 需要立即處理的任務,當延時 (DELAYED) 任務到期后會自動成為當前任務;
DELAYED - 延遲執(zhí)行的任務, 當消費者處理任務后, 可以用將消息再次放回 DELAYED 隊列延遲執(zhí)行;
RESERVED - 已經(jīng)被消費者獲取, 正在執(zhí)行的任務。Beanstalkd 負責檢查任務是否在 TTR(time-to-run) 內(nèi)完成;
BURIED - 保留的任務: 任務不會被執(zhí)行,也不會消失,除非有人把它 "踢" 回隊列;
DELETED - 消息被徹底刪除。Beanstalkd 不再維持這些消息。
3、一些特性 優(yōu)先級任務 (job) 可以有 0~2^32 個優(yōu)先級, 0 代表最高優(yōu)先級,默認優(yōu)先級為1024。
持久化可以通過binlog將job及其狀態(tài)記錄到文件里面,在Beanstalkd下次啟動時可以通過讀取binlog來恢復之前的job及狀態(tài)。
分布式容錯分布式設計和Memcached類似,beanstalkd各個server之間并不知道彼此的存在,都是通過client來實現(xiàn)分布式以及根據(jù)tube名稱去特定server獲取job。
超時控制為了防止某個consumer長時間占用任務但不能處理的情況,Beanstalkd為reserve操作設置了timeout時間,如果該consumer不能在指定時間內(nèi)完成job,job將被遷移回READY狀態(tài),供其他consumer執(zhí)行。
三、Client Libraries For PHP項目地址:https://github.com/pda/pheanstalk/
1、Producer 示例:向隊列中添加job$pheanstalk = new Pheanstalk_Pheanstalk("127.0.0.1"); $pheanstalk ->useTube("tubeName") ->put($jobData);2、Consumer 示例:從隊列中取出job
$job = $pheanstalk ->watch("tubeName") ->ignore("default") ->reserve(); echo $job->getData(); $pheanstalk->delete($job);3、檢查服務狀態(tài)
$isAlive = $pheanstalk->getConnection()->isServiceListening(); //返回 true 或 false4、獲取某一 tube 的數(shù)據(jù)
try{ $tubeStatus = $pheanstalk->statsTube("tubeName"); } catch (Exception $e){ if($e->getMessage()=="Server reported NOT_FOUND"){ //tube 不存在 $current_jobs_ready = 0; } }四、其他 1、PHP 版控制臺
https://github.com/ptrofimov/beanstalk_console
2、Chrome 插件https://chrome.google.com/webstore/detail/beanstalkd-dashboard/dakkekjnlffnecpmdiamebeooimjnipm
五、參考資料https://github.com/kr/beanstalkd/wiki/faq
http://csrd.aliapp.com/?p=1201
文章版權歸作者所有,未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址:http://specialneedsforspecialkids.com/yun/30247.html
摘要:說明隊列配置文件存放在。每一種隊列驅(qū)動的配置都可以在該文件中找到,包括數(shù)據(jù)庫,,,,以及同步本地使用驅(qū)動。其中還包含了一個隊列驅(qū)動用于那些放棄隊列的任務。 showImg(https://segmentfault.com/img/remote/1460000012384126?w=888&h=280); 說明 隊列配置文件存放在 config/queue.php。 每一種隊列驅(qū)動的配...
摘要:后來開源,現(xiàn)在有大規(guī)模部署和使用,每天處理百萬級任務。是典型的類設計,協(xié)議和使用方式都是同樣的風格,所以使用過的用戶會覺得似曾相識。 Beanstalkd介紹 什么是Beanstalkd Beanstalk,一個高性能、輕量級的分布式內(nèi)存隊列系統(tǒng),最初設計的目的是想通過后臺異步執(zhí)行耗時的任務來降低高容量Web應用系統(tǒng)的頁面訪問延遲,支持過有9.5 million用戶的Facebook ...
摘要:上一篇文章講了通道建議先去看上篇文章與把隊列添加到數(shù)據(jù)表中把隊列添加到內(nèi)存中安裝依賴安裝到項目根目錄修改訪問路由數(shù)據(jù)將寫入到內(nèi)存中執(zhí)行命令打開日志文件打印的消息完結(jié)下一篇文章講能更直觀的看到數(shù)據(jù)添加到內(nèi)存中 上一篇文章講了 database 通道 建議先去看上篇文章 1.beanstalkd 與 database database:把隊列添加到數(shù)據(jù)表中beanstalkd:把隊列添加到...
摘要:項目地址框架目的基于和實現(xiàn)多進程處理消息隊列。文件用于配置消息隊列管道及其處理類項目配置文件文件夾下為方式運行下產(chǎn)生的日志內(nèi)容是運行時的進程信息命令查看的狀態(tài)信息查看的信息啟動啟動停止重啟其它子進程異常退出時將會自動重啟。 項目地址 SWBT框架 https://github.com/YWNA/SWBT 目的 基于Swoole和beanstalkd實現(xiàn)多進程處理消息隊列。 安裝 com...
摘要:對于來說,在主機操作系統(tǒng)上運行是絕對必要的。在和中,從主機操作系統(tǒng)中運行可以出現(xiàn)系統(tǒng)通知。你仍然可以在或的虛擬機中成功地運行,但在發(fā)出通知時將收到警告錯誤僅從你的主機操作系統(tǒng)運行。 原文地址: Laravel 5.1 Beauty - Required Software and Components 怎樣安裝開發(fā) Laravel 5.1 必要的軟件: VirtualBox 和 Vagr...
閱讀 2137·2023-04-26 00:23
閱讀 807·2021-09-08 09:45
閱讀 2435·2019-08-28 18:20
閱讀 2542·2019-08-26 13:51
閱讀 1595·2019-08-26 10:32
閱讀 1392·2019-08-26 10:24
閱讀 2027·2019-08-26 10:23
閱讀 2196·2019-08-23 18:10