成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

Beanstalkd 使用記錄

yearsj / 2647人閱讀

摘要：的消費(fèi)者，通過(guò)命令來(lái)獲取或改變的狀態(tài)。不再維持這些消息。持久化可以通過(guò)將及其狀態(tài)記錄到文件里面，在下次啟動(dòng)時(shí)可以通過(guò)讀取來(lái)恢復(fù)之前的及狀態(tài)。

一、安裝 1、官網(wǎng)

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

2、安裝 
yum install beanstalkd --enablerepo=epel
3、啟動(dòng) 
/usr/bin/beanstalkd -l 0.0.0.0 -p 11300 -b /var/lib/beanstalkd/binlog -F

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

4、配置文件 
/etc/sysconfig/beanstalkd
二、基本概念 1、Beanstalkd設(shè)計(jì)里面的核心概念：

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

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

producer：Job 的生產(chǎn)者，通過(guò) put 命令來(lái)將一個(gè) job 放到一個(gè) tube 中。

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

2、job 的生命周期

當(dāng)producer直接put一個(gè)job時(shí)，job就處于READY狀態(tài)，等待consumer來(lái)處理，如果選擇延遲put，job就先到DELAYED狀態(tài)，等待時(shí)間過(guò)后才遷移到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)消亡，之后不能再獲?。籸elease操作可以重新把該job狀態(tài)遷移回READY（也可以延遲該狀態(tài)遷移操作），使其他的consumer可以繼續(xù)獲取和執(zhí)行該job；有意思的是bury操作，可以把該job休眠，等到需要的時(shí)候，再將休眠的job kick回READY狀態(tài)，也可以delete BURIED狀態(tài)的job。正是有這些有趣的操作和狀態(tài)，才可以基于此做出很多意思的應(yīng)用，比如要實(shí)現(xiàn)一個(gè)循環(huán)隊(duì)列，就可以將RESERVED狀態(tài)的job休眠掉，等沒(méi)有READY狀態(tài)的job時(shí)再將BURIED狀態(tài)的job一次性kick回READY狀態(tài)。

READY - 需要立即處理的任務(wù)，當(dāng)延時(shí) (DELAYED) 任務(wù)到期后會(huì)自動(dòng)成為當(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ù)不會(huì)被執(zhí)行，也不會(huì)消失，除非有人把它 "踢" 回隊(duì)列；

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

3、一些特性 優(yōu)先級(jí)

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

持久化

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

分布式容錯(cuò)

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

超時(shí)控制

為了防止某個(gè)consumer長(zhǎng)時(shí)間占用任務(wù)但不能處理的情況，Beanstalkd為reserve操作設(shè)置了timeout時(shí)間，如果該consumer不能在指定時(shí)間內(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);
2、Consumer 示例：從隊(duì)列中取出job 
$job = $pheanstalk ->watch("tubeName") ->ignore("default") ->reserve();

echo $job->getData();

$pheanstalk->delete($job);
3、檢查服務(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;
    }
}
四、其他 1、PHP 版控制臺(tái)

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

文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/30247.html

相關(guān)文章

  • Laravel隊(duì)列小結(jié)

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

    MoAir 評(píng)論0 收藏0

  • PHP 操作 Beanstalkd 方法及參數(shù)注釋

    摘要：后來(lái)開源，現(xiàn)在有大規(guī)模部署和使用，每天處理百萬(wàn)級(jí)任務(wù)。是典型的類設(shè)計(jì)，協(xié)議和使用方式都是同樣的風(fēng)格，所以使用過(guò)的用戶會(huì)覺(jué)得似曾相識(shí)。 Beanstalkd介紹 什么是Beanstalkd Beanstalk，一個(gè)高性能、輕量級(jí)的分布式內(nèi)存隊(duì)列系統(tǒng)，最初設(shè)計(jì)的目的是想通過(guò)后臺(tái)異步執(zhí)行耗時(shí)的任務(wù)來(lái)降低高容量Web應(yīng)用系統(tǒng)的頁(yè)面訪問(wèn)延遲，支持過(guò)有9.5 million用戶的Facebook ...

    孫淑建 評(píng)論0 收藏0

  • Laravel 隊(duì)列 --- beanstalkd 驅(qū)動(dòng)

    摘要：上一篇文章講了通道建議先去看上篇文章與把隊(duì)列添加到數(shù)據(jù)表中把隊(duì)列添加到內(nèi)存中安裝依賴安裝到項(xiàng)目根目錄修改訪問(wèn)路由數(shù)據(jù)將寫入到內(nèi)存中執(zhí)行命令打開日志文件打印的消息完結(jié)下一篇文章講能更直觀的看到數(shù)據(jù)添加到內(nèi)存中 上一篇文章講了 database 通道 建議先去看上篇文章 1.beanstalkd 與 database database：把隊(duì)列添加到數(shù)據(jù)表中beanstalkd：把隊(duì)列添加到...

    Lycheeee 評(píng)論0 收藏0

  • SWBT基于beanstalkd實(shí)現(xiàn)多進(jìn)程處理消息隊(duì)列的框架

    摘要：項(xiàng)目地址框架目的基于和實(shí)現(xiàn)多進(jìn)程處理消息隊(duì)列。文件用于配置消息隊(duì)列管道及其處理類項(xiàng)目配置文件文件夾下為方式運(yùn)行下產(chǎn)生的日志內(nèi)容是運(yùn)行時(shí)的進(jìn)程信息命令查看的狀態(tài)信息查看的信息啟動(dòng)啟動(dòng)停止重啟其它子進(jìn)程異常退出時(shí)將會(huì)自動(dòng)重啟。 項(xiàng)目地址 SWBT框架 https://github.com/YWNA/SWBT 目的 基于Swoole和beanstalkd實(shí)現(xiàn)多進(jìn)程處理消息隊(duì)列。 安裝 com...

    XanaHopper 評(píng)論0 收藏0

  • [譯] Laravel 5 之美 - 2) 安裝運(yùn)行時(shí)必要軟件和組件

    摘要：對(duì)于來(lái)說(shuō)，在主機(jī)操作系統(tǒng)上運(yùn)行是絕對(duì)必要的。在和中，從主機(jī)操作系統(tǒng)中運(yùn)行可以出現(xiàn)系統(tǒng)通知。你仍然可以在或的虛擬機(jī)中成功地運(yùn)行，但在發(fā)出通知時(shí)將收到警告錯(cuò)誤僅從你的主機(jī)操作系統(tǒng)運(yùn)行。 原文地址: Laravel 5.1 Beauty - Required Software and Components 怎樣安裝開發(fā) Laravel 5.1 必要的軟件: VirtualBox 和 Vagr...

    alaege 評(píng)論0 收藏0

發(fā)表評(píng)論

0條評(píng)論

最新活動(dòng)
閱讀需要支付1元查看
<