安裝
linux安裝(window用戶我暫時(shí)沒有更好的方案，請安裝虛擬機(jī)，我使用的是vagrant)
yum install beanstalk
yii2項(xiàng)目安裝
composer require udokmeci/yii2-beanstalk "dev-master"
安裝管理 Beanstalk 隊(duì)列的 Web 系統(tǒng),此項(xiàng)目是一個(gè)單獨(dú)的系統(tǒng)言疗，可以查看和管理隊(duì)列任務(wù)
composer create-project ptrofimov/beanstalk_console -s dev beanstalk_console
如何使用
首先诀艰，服務(wù)端開啟
beanstalkd -l 127.0.0.1 -p 11300
yii2 console 模塊中配置
main.php
'components' => [
// ...
'beanstalk' => [
'class' => 'udokmeci\yii2beanstalk\Beanstalk',
'host' => 127.0.0.1, // default host
'port' => 11300,
'connectTimeout' => 1,
'sleep' => false, // or int for usleep after every job
],
// ...
],
'controllerMap' => [
'worker'=>[
'class' => 'app\commands\WorkerController',
]
],
執(zhí)行隊(duì)列在 console\controllers\WorkerController 里面：
<?php
namespace app\commands;
use common\helpers\ObjectHelper;
use common\models\MongoTrack;
use common\services\TrackService;
use Pheanstalk\Job;
use udokmeci\yii2beanstalk\BeanstalkController;
use Yii;
class WorkerController extends BeanstalkController
{
/**
* @var integer 優(yōu)先級 值越小優(yōu)先級越高，默認(rèn)為1024
*/
const DELAY_PRIORITY = 1000;
/**
* @var integer 延遲執(zhí)行的秒數(shù)
*/
const DELAY_TIME = 5;
/**
* @var integer 當(dāng) delay_max 達(dá)到 刪除或延遲
*/
const DELAY_MAX = 3;
public function listenTubes()
{
return ['tube', 'track'];
}
/**
* 采集數(shù)據(jù)
* @param $job Job
* @return string
*/
public function actionTrack($job)
{
/** @var object $sentData */
$sentData = $job->getData();
if (TrackService::isNeedTrack($sentData->unique_id, $sentData->source, $sentData->method)) {
$model = new MongoTrack();
$model->load(ObjectHelper::toArray($sentData), '');
fwrite(STDOUT, json_encode($model->errors));
if ($model->save()) {
return self::DELETE;
}
fwrite(STDOUT, json_encode($model->errors));
return self::BURY;
}
// 不需要保存 mongodb 刪除
return self::DELETE;
}
// ...
}
然后執(zhí)行php yii worker
安裝管理 Beanstalk 隊(duì)列的 Web 系統(tǒng),此項(xiàng)目是一個(gè)單獨(dú)的系統(tǒng)黄绩，可以查看和管理隊(duì)列任務(wù)
composer create-project ptrofimov/beanstalk_console -s dev beanstalk_console
安裝完成后將域名指向beanstalk_console/public目錄下羡洁，可查看哥哥tube隊(duì)列狀態(tài)
Paste_Image.png
問題：linux 啟動進(jìn)程yii worker 進(jìn)程后，關(guān)閉xshell,如何保證進(jìn)程不關(guān)閉爽丹？有待探索
