Beanstalkd 使用記錄

yearsj 發布于2019-07-01 12:12 / 2649人閱讀

摘要：的消費者，通過命令來獲取或改變的狀態。不再維持這些消息。持久化可以通過將及其狀態記錄到文件里面，在下次啟動時可以通過讀取來恢復之前的及狀態。

一、安裝 1、官網

https://kr.github.io/beanstalkd/

2、安裝

yum install beanstalkd --enablerepo=epel

3、啟動

/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：一個有名的任務隊列，用來存儲統一類型的 job，是 producer 和 consumer 操作的對象。

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

consumer：Job的消費者，通過 reserve/release/bury/delete 命令來獲取 job 或改變 job 的狀態。

2、job 的生命周期

當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狀態。

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

DELAYED - 延遲執行的任務, 當消費者處理任務后, 可以用將消息再次放回 DELAYED 隊列延遲執行；

RESERVED - 已經被消費者獲取, 正在執行的任務。Beanstalkd 負責檢查任務是否在 TTR(time-to-run) 內完成；

BURIED - 保留的任務: 任務不會被執行，也不會消失，除非有人把它 "踢" 回隊列；

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

3、一些特性 優先級

任務 (job) 可以有 0~2^32 個優先級, 0 代表最高優先級，默認優先級為1024。

持久化

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

分布式容錯

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

超時控制

為了防止某個consumer長時間占用任務但不能處理的情況，Beanstalkd為reserve操作設置了timeout時間，如果該consumer不能在指定時間內完成job，job將被遷移回READY狀態，供其他consumer執行。

三、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、檢查服務狀態

$isAlive = $pheanstalk->getConnection()->isServiceListening(); //返回 true 或 false

4、獲取某一 tube 的數據

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

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

轉載請注明本文地址：http://m.specialneedsforspecialkids.com/yun/30247.html

Laravel隊列小結

摘要：說明隊列配置文件存放在。每一種隊列驅動的配置都可以在該文件中找到，包括數據庫，，，，以及同步本地使用驅動。其中還包含了一個隊列驅動用于那些放棄隊列的任務。 showImg(https://segmentfault.com/img/remote/1460000012384126?w=888&h=280); 說明隊列配置文件存放在 config/queue.php。每一種隊列驅動的配...

MoAir 2019-06-28 14:27 評論0 收藏0
PHP 操作 Beanstalkd 方法及參數注釋

摘要：后來開源，現在有大規模部署和使用，每天處理百萬級任務。是典型的類設計，協議和使用方式都是同樣的風格，所以使用過的用戶會覺得似曾相識。 Beanstalkd介紹什么是Beanstalkd Beanstalk，一個高性能、輕量級的分布式內存隊列系統，最初設計的目的是想通過后臺異步執行耗時的任務來降低高容量Web應用系統的頁面訪問延遲，支持過有9.5 million用戶的Facebook ...

孫淑建 2019-07-01 10:10 評論0 收藏0
Laravel 隊列 --- beanstalkd 驅動

摘要：上一篇文章講了通道建議先去看上篇文章與把隊列添加到數據表中把隊列添加到內存中安裝依賴安裝到項目根目錄修改訪問路由數據將寫入到內存中執行命令打開日志文件打印的消息完結下一篇文章講能更直觀的看到數據添加到內存中上一篇文章講了 database 通道建議先去看上篇文章 1.beanstalkd 與 database database：把隊列添加到數據表中beanstalkd：把隊列添加到...

Lycheeee 2019-07-01 12:47 評論0 收藏0
SWBT基于beanstalkd實現多進程處理消息隊列的框架

摘要：項目地址框架目的基于和實現多進程處理消息隊列。文件用于配置消息隊列管道及其處理類項目配置文件文件夾下為方式運行下產生的日志內容是運行時的進程信息命令查看的狀態信息查看的信息啟動啟動停止重啟其它子進程異常退出時將會自動重啟。項目地址 SWBT框架 https://github.com/YWNA/SWBT 目的基于Swoole和beanstalkd實現多進程處理消息隊列。安裝 com...

XanaHopper 2019-07-01 10:11 評論0 收藏0
[譯] Laravel 5 之美 - 2) 安裝運行時必要軟件和組件

摘要：對于來說，在主機操作系統上運行是絕對必要的。在和中，從主機操作系統中運行可以出現系統通知。你仍然可以在或的虛擬機中成功地運行，但在發出通知時將收到警告錯誤僅從你的主機操作系統運行。原文地址: Laravel 5.1 Beauty - Required Software and Components 怎樣安裝開發 Laravel 5.1 必要的軟件: VirtualBox 和 Vagr...

alaege 2019-06-28 13:50 評論0 收藏0