yii2 beanstalk异步队列使用教程

安装

linux安装(window用户我暂时没有更好的方案，请安装虚拟机，我使用的是vagrant)

yum install beanstalk

yii2项目安装

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

安装管理 Beanstalk 队列的 Web 系统,此项目是一个单独的系统，可以查看和管理队列任务

composer create-project ptrofimov/beanstalk_console -s dev beanstalk_console

如何使用

首先，服务端开启

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',
    ]
],

执行队列在 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 优先级 值越小优先级越高，默认为1024
     */
    const DELAY_PRIORITY = 1000;

    /**
     * @var integer 延迟执行的秒数
     */
    const DELAY_TIME = 5;

    /**
     * @var  integer 当 delay_max 达到 删除或延迟
     */
    const DELAY_MAX = 3;

    public function listenTubes()
    {
        return ['tube', 'track'];
    }


    /**
     * 采集数据
     * @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;
    }

    // ...
}

然后执行php yii worker

安装管理 Beanstalk 队列的 Web 系统,此项目是一个单独的系统，可以查看和管理队列任务

composer create-project ptrofimov/beanstalk_console -s dev beanstalk_console

安装完成后将域名指向beanstalk_console/public目录下，可查看哥哥tube队列状态

Paste_Image.png

问题：linux 启动进程yii worker 进程后，关闭xshell,如何保证进程不关闭？有待探索