安裝

linux安裝(window用戶我暫時沒有更好的方案，請安裝虛擬機(jī)，我使用的是vagrant)

yum install beanstalk

yii2項目安裝

composer require udokmeci/yii2-beanstalk "dev-master"

安裝管理 Beanstalk 隊列的 Web 系統(tǒng),此項目是一個單獨的系統(tǒng)，可以查看和管理隊列任務(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í)行隊列在 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 隊列的 Web 系統(tǒng),此項目是一個單獨的系統(tǒng)，可以查看和管理隊列任務(wù)

composer create-project ptrofimov/beanstalk_console -s dev beanstalk_console

安裝完成后將域名指向beanstalk_console/public目錄下，可查看哥哥tube隊列狀態(tài)

Paste_Image.png

問題：linux 啟動進(jìn)程yii worker 進(jìn)程后，關(guān)閉xshell,如何保證進(jìn)程不關(guān)閉？有待探索