狀態(tài) | 注釋 |
---|---|
delayed | 延遲狀態(tài) |
ready | 準(zhǔn)備好狀態(tài) |
reserved | 消費(fèi)者把任務(wù)讀出來(lái),處理時(shí) |
buried | 預(yù)留狀態(tài) |
delete | 刪除狀態(tài) |
管理工具
親測(cè)了很多網(wǎng)上能找到的 beanstalkd 工具,這兩款是我最中意的了,一個(gè)命令行,一個(gè) web 的。
命令行:https://github.com/src-d/beanstool
web 界面:https://github.com/ptrofimov/beanstalk_console
編程語(yǔ)言客戶端
PHP 客戶端
https://packagist.org/packages/pda/pheanstalk
composer require pda/pheanstalk
寫(xiě)入 job
?php //創(chuàng)建隊(duì)列消息 require_once('./vendor/autoload.php'); use Pheanstalk\Pheanstalk; $pheanstalk = new Pheanstalk('127.0.0.1',11300); $tubeName = 'email_list'; $jobData = [ 'email' => '123456@163.com', 'message' => 'Hello World !!', 'dtime' => date('Y-m-d H:i:s'), ]; $pheanstalk->useTube( $tubeName)->put( json_encode( $jobData ) );
消費(fèi) job
?php ini_set('default_socket_timeout', 86400*7); ini_set( 'memory_limit', '256M' ); // 消費(fèi)隊(duì)列消息 require_once('./vendor/autoload.php'); use Pheanstalk\Pheanstalk; $pheanstalk = new Pheanstalk('127.0.0.1',11300); $tubeName = 'email_list'; while ( true ) { // 獲取隊(duì)列信息, reserve 阻塞獲取 $job = $pheanstalk->watch( $tubeName )->ignore( 'default' )->reserve(); if ( $job !== false ) { $data = $job->getData(); /* TODO 邏輯操作 */ /* 處理完成,刪除 job */ $pheanstalk->delete( $job ); } }
default_socket_timeout 這個(gè)參數(shù)是一定要加的,php 默認(rèn)一般是 60s,假如您沒(méi)有在代碼里面設(shè)置,采用默認(rèn)的話(60s),60s 之內(nèi)如果沒(méi)有 job 產(chǎn)生,腳本就會(huì)報(bào) socket 錯(cuò)誤,我寫(xiě)的是 7 天超時(shí),您可以根據(jù)業(yè)務(wù)去調(diào)整,記住一定要配置,網(wǎng)上很多搜的 consumer 腳本都沒(méi)有配置這個(gè),根本不能投入生產(chǎn)環(huán)境使用,這是我親自實(shí)踐的結(jié)果。
關(guān)于 while true 是否死循環(huán),很明確告訴你是死循環(huán),但是不會(huì)一直耗性能的那樣執(zhí)行下去,它會(huì)在 reserve 這里阻塞不動(dòng),直到有消息產(chǎn)生才會(huì)往下走,所以大可放心使用,我的項(xiàng)目代碼里面是使用了方法調(diào)用方法自身去實(shí)現(xiàn)循環(huán)的。
就是這樣的代碼,供參考:
public function watchJob() { $job = $this->pheanstalk->watch( config( 'tube' ) )->ignore( 'default' )->reserve(); if ( $job !== false ) { $job_data = $job->getData(); $this->subscribe( $job_data ); $this->pheanstalk->delete( $job ); /* 繼續(xù) Watch 下一個(gè) job */ $this->watchJob(); } else { $this->log->error( 'reserve false', 'reserve false' ); } }
監(jiān)控 beanstalkd 狀態(tài)
?php //監(jiān)控服務(wù)狀態(tài) require_once('./vendor/autoload.php'); use Pheanstalk\Pheanstalk; $pheanstalk = new Pheanstalk('127.0.0.1',11300); $isAlive = $pheanstalk->getConnection()->isServiceListening(); var_dump( $isAlive );
可以配合 email 做一個(gè)報(bào)警郵件,腳本每分鐘去執(zhí)行,判斷狀態(tài)是 false,就給管理員發(fā)送郵件報(bào)警。
一些相關(guān)命令
查看 beanstalkd 服務(wù)內(nèi)存占用
top -u beanstalkd
后臺(tái)運(yùn)行 consumer 腳本
nohup php googlehome_subscribe.php
查看 consumer 腳本運(yùn)行時(shí)間
ps -A -opid,stime,etime,args | grep consumer.php
手工重啟 consumer 腳本
ps auxf|grep 'googlehome_subscribe.php'|grep -v grep|awk '{print $2}'|xargs kill -9 nohup php googlehome_subscribe.php
一些總結(jié)
php 要把錯(cuò)誤日志打開(kāi),方便收集 consumer 腳本 crash 的 log,腳本跑出一些致命的 error 一定要及時(shí)修復(fù),因?yàn)橐坏┯绣e(cuò)就會(huì)掛掉,這會(huì)影響你腳本的可用性,后期穩(wěn)定之后可以上 supervisor 這種進(jìn)程管理程序來(lái)管控腳本生命周期。
一些網(wǎng)絡(luò)請(qǐng)求操作,一定要 try catch 到所有錯(cuò)誤,一旦沒(méi)有 catch 到,腳本就崩。我用的是 Guzzle 去做的網(wǎng)絡(luò)請(qǐng)求,下面是我 catch 的一些錯(cuò)誤,代碼片段供參考。
try { /* TODO: 邏輯操作 */ } catch ( ClientException $e ) { $results['mid'] = $this->mid; $results['code'] = $e->getResponse()->getStatusCode(); $results['reason'] = $e->getResponse()->getReasonPhrase(); $this->log->error( 'properties-changed ClientException', $results ); } catch ( ServerException $e ) { $results['mid'] = $this->mid; $results['code'] = $e->getResponse()->getStatusCode(); $results['reason'] = $e->getResponse()->getReasonPhrase(); $this->log->error( 'properties-changed ServerException', $results ); } catch ( ConnectException $e ) { $results['mid'] = $this->mid; $this->log->error( 'properties-changed ConnectException', $results ); }
job 消費(fèi)之后一定要?jiǎng)h除掉,如果長(zhǎng)時(shí)間不刪除,php 客戶端會(huì)有 false 返回,是因?yàn)橛?DEADLINE_SOON 這個(gè)超時(shí)錯(cuò)誤產(chǎn)生,所以處理完任務(wù),一定要記得刪除,這一點(diǎn)跟 kafka 不一樣,beanstalkd 需要開(kāi)發(fā)者自己去刪除 job。
以上就是PHP7生產(chǎn)環(huán)境隊(duì)列Beanstalkd用法詳解的詳細(xì)內(nèi)容,更多關(guān)于PHP7中Beanstalkd正確用法的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!
標(biāo)簽:雞西 綿陽(yáng) 貴陽(yáng) 白城 迪慶 瀘州 郴州 黃石
巨人網(wǎng)絡(luò)通訊聲明:本文標(biāo)題《PHP7生產(chǎn)環(huán)境隊(duì)列Beanstalkd用法詳解》,本文關(guān)鍵詞 PHP7,生產(chǎn),環(huán)境,隊(duì)列,Beanstalkd,;如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問(wèn)題,煩請(qǐng)?zhí)峁┫嚓P(guān)信息告之我們,我們將及時(shí)溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò),涉及言論、版權(quán)與本站無(wú)關(guān)。