| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253 | <?php/** * FecShop file. * * @link http://www.fecshop.com/ * @copyright Copyright (c) 2016 FecShop Software LLC * @license http://www.fecshop.com/license/ */namespace fec\helpers;use Yii;use yii\base\InvalidConfigException;use yii\redis\Connection;use fec\helpers\credisqueue\Queue;use fec\helpers\credisqueue\Job;/** * @author Terry Zhao <2358269014@qq.com> * @since 1.0 */class CRedisQueue extends Queue{	/*	在使用之前,您需要先进行配置如下:	'components' => [		'queue' => [			'class' => 'fec\component\RedisQueue',		],	],		'controllerMap' => [        'queue' => 'fec\component\redisqueue\QueueController'    ],			*/	/*		1. 定义TestJob文件		   实现run方法()		2. 执行命令行:./yii queue/listen MyTestQueue		3. 使用push方法,把参数传入		$job = '\fec\component\redisqueue\TestJob';		$data = ['a', 'b', 'c'];		$queue  = 'MyTestQueue';		CRedisQuery::push($job,$data);				\fec\component\redisqueue\TestJob 里面的run方法将会被执行		*/	public static function push($job,$data,$queue = null){		//return  Yii::$app->queue->push('\fec\component\redisqueue\TestJob', ['a', 'b', 'c']);		return  Yii::$app->queue->push($job,$data,$queue);			}} 
 |