PHP
发布时间：2019-11-11 发布网站：大佬教程 code.js-code.com
大佬教程收集整理的这篇文章主要介绍了Yii2 队列 shmilyzxt/yii2-queue 简单概述，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。
shmilyzxt/yii2-queue 简单解释:
1.我用的yii2高级版,我们从配置开始看代码,这里我用的是mysql队列,首先配置文件,我把queue配置项写在根目录common\config\main-local.php下的 components数组下,更改一下数据库配置.复制composer安装后复制
php;">
vendor\shmilyzxt\yii2-queue\jobs\job
s.sql
vendor\shmilyzxt\yii2-queue\failed\failed.sql
2个sql文件到数据库中建立队列数据表和执行任务失败时的数据表.
2.推送任务开始语法:\Yii::$app->queue->pushOn(new SendMial(),['email'=>'49783121@qq.com','title'=>'test','content'=>'email test'],'email'); 我们到vendor\shmilyzxt\queue\queues\DatabaseQueue.php去看看代码,pushOn()方法写在了DatabaseQueue类的父类vendor\shmilyzxt\queue\base\Queue.php中:
canPush())
{
//beforePush 入队列前的事件
$this->
trigger(self::EVEN
T_BEFORE_PUSH
);
//入队列
$ret = $this->push($job,$data,$queu
E);
//afterPush 入队列后的事件
$this->
trigger(self::EVENT_AFTER_PUSH
);
return $ret;
} else
{
throw new \Exception("max jobs
number exceed! the max jobs
number is
{$this->maxJob}"
);
}
}
注释:这里最好去看看yii2 event事件类,http://www.digpage.com/event.html
关于入队列: $this->push($job,$queuE);,这里在配合queue类文件查看,相关函数跳转,处理一下数据记录到数据库中.(函数走向:getQueue()-->createPayload()-->pushToDatabase()),pushOn()最终返回数据插入数据库的结果,成功$ret是1.
3.后台运行命令处理队列,例:php ./yii worker/listen default 10 128 3 0 其中default是队列的名称,上面推送了一个email队列 应该改为email.
启动命令后,我们来看代码:首先执行:WorkerController控制器 actionListen方法,我们跟着代码进入到 vendor\shmilyzxt\queue\Worker.php -- listen方法中,这里其实就是一直在循环,执行操作队列的任务:
pop($queue
Name);
}catch (\Exception $
E){
throw $e;
con
Tinue;
}
if($job instanceof Job)
{
//判断执行错误的次数是否大于传入的执行次数
if($attempt > 0 && $job->getAttempts() > $attempt)
{
$job->failed(
);
}else
{
try
{
//throw new \Exception("test failed"
);
$job->execute(
);
}catch (\Exception $
E){
//执行失败,判断是否被删除,重新入队
if (! $job->is
deleted())
{
$job->release($delay
);
}
}
}
}else
{
self::sleep($slee
p);
}
if (self::memoryExceeded($memory))
{
self::stop(
);
}
}
}
注释:在$queue->pop($queueName);是vendor\shmilyzxt\queue\queues\DatabaseQueue.php方法内使用事务执行sql,并且创建vendor\shmilyzxt\queue\jobs\DatabaseJob.php的实例
getQueue($queu
E);
if (!is_null($this->expir
E))
{
//$this->releaseJobsThatHaveBeenReservedTooLong($queu
E);
}
$tran = $this->connector->begin
transaction(
);
//判断是否有一个可用的任务需要执行
if ($job = $this->getNextAvailableJob($queu
E))
{
$this->markJobAsReserved($job->id
);
$tran->commit(
);
$config = array_merge($this->jobEvent,[
'class' => 'shmilyzxt\queue\jobs\DatabaseJob','queue' => $queue,'job' => $job,'queueInstance' => $this,]
);
return \Yii::createOb
ject($config
);
}
$tran->commit(
);
return
false;
}
至于:$job->execute();是DatabaseJob继承父类Job执行的,顺着代码找下去是yii\base\Component trigger执行的事件,
trigger(self::EVEN
T_BEFORE_EXECUTE,new JobEvent(["job" => $this,'payload' => $this->getPayload()])
);//beforeExecute 执行任务之前的一个事件 在JobEvent中并没有什么可执行的代码
$this->resolveAndFire(
);//真正执行的任务的方法
}
/
**
* 真正任务执行方法（调用hander的handle方法）
* @param array $payload
* @return void
*/
protected function resolveAndFire()
{
$payload = $this->getPayload(
);
$payload = un
serialize($payload
); //反序列化数据
$type = $payload['type'];
$class = $payload['job'];
if ($type == 'closure' && ($closure = (new
serializer())->un
serialize($class[1])) instanceof \Closur
E) {
$this->handler = $this->getHander($class
[0]);
$this->handler->closure = $closure;
$this->handler->handle($this,$payload['data']
);
} else if ($type == 'classMethod')
{
$payload['job']
[0]->$payload['job'][1]($this,$payload['data']
);
} else if ($type == 'staticMethod')
{
$payload['job']
[0]::$payload['job'][1]($this,$payload['data']
);
} else
{//执行的`SendMail`类的`handle($job,$data)`方法
$this->handler = $this->getHander($class
);
$this->handler->handle($this,$payload['data']
);
}
//执行完任务后删除
if (!$this->is
deletedOrReleased())
{
$this->
delete();
}
}
最后到了执行的SendMail类的handle($job,$data),在这里就是推送到队列的对象和数据,接着就是我们的处理逻辑了.
getAttempts() > 3)
{
$this->failed($job
);
}
$payload = $job->getPayload(
);
echo '
';print_r($payload);
//$payload即任务的数据，你拿到任务数据后就可以执行发邮件了
//TODO 发邮件
}
总结
以上所述是小编给大家介绍的Yii2 队列 shmilyzxt/yii2-queue简介，希望对大家有所帮助。程序员遇到问题都会上（菜鸟教程jb51.cc）查找问题解答方法！如果觉得站点还不错，随手转发给程序员朋友一下！
大佬总结
以上是大佬教程为你收集整理的Yii2 队列 shmilyzxt/yii2-queue 简单概述全部内容，希望文章能够帮你解决Yii2 队列 shmilyzxt/yii2-queue 简单概述所遇到的程序开发问题。
如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。
本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。
