PHPyii2 キューの概要 shmilyzxt/yii2-queue
- 炎欲天舞オリジナル
- 2017-08-04 10:42:311831ブラウズ
使用中は非常に優れていると思います。
shmilyzxt/yii2-queue簡単な説明:shmilyzxt/yii2-queue简单解释:
我用的yii2高级版,我们从配置开始看代码,这里我用的是mysql队列,首先配置文件,我把
queue配置项写在根目录commonconfigmain-local.php下的components数组下,更改一下数据库配置.复制composer安装后复制vendorshmilyzxtyii2-queuejobsjobs.sqlvendorshmilyzxtyii2-queuefailedfailed.sql
2个sql文件到数据库中建立队列数据表和执行任务失败时的数据表.推送任务开始语法:
Yii::$app->queue->pushOn(new SendMial(),['email'=>'49783121@qq.com','title'=>'test','content'=>'email test'],'email');我们到vendorshmilyzxtqueuequeuesDatabaseQueue.php去看看代码,pushOn()方法写在了DatabaseQueue类的父类vendorshmilyzxtqueuebaseQueue.php中:
//入队列public function pushOn($job, $data = '', $queue = null)
{ //canPush 检查队列是否已达最大任务量
if ($this->canPush()) {
//beforePush 入队列前的事件
$this->trigger(self::EVENT_BEFORE_PUSH);
//入队列
$ret = $this->push($job, $data, $queue);
//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事件类.
关于入队列: $this->push($job, $data, $queue);,这里在配合queue类文件查看,相关函数跳转,处理一下数据记录到数据库中.(函数走向:getQueue()-->createPayload()-->pushToDatabase()),pushOn()最终返回数据插入数据库的结果,成功$ret是1.
3.后台运行命令处理队列,例:php ./yii worker/listen default 10 128 3 0 其中default是队列的名称,上面推送了一个email队列 应该改为email.
启动命令后,我们来看代码:首先执行:WorkerController控制器 actionListen方法,我们跟着代码进入到 vendorshmilyzxtqueueWorker.php -- listen方法中,这里其实就是一直在循环,执行操作队列的任务:
/**
* 启用一个队列后台监听任务
* @param Queue $queue
* @param string $queueName 监听队列的名称(在pushon的时候把任务推送到哪个队列，则需要监听相应的队列才能获取任务)
* @param int $attempt 队列任务失败尝试次数，0为不限制 * @param int $memory 允许使用的最大内存
* @param int $sleep 每次检测的时间间隔
*/
public static function listen(Queue $queue, $queueName = 'default', $attempt = 10, $memory = 512, $sleep = 3, $delay = 0){
while (true){
try{
//DatabaseQueue从数据库队列取出一个可用任务(实例),并且更新任务
$job = $queue->pop($queueName);
}catch (\Exception $e){
throw $e;
continue;
}
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->isDeleted()) {
$job->release($delay);
}
}
}
}else{
self::sleep($sleep);
}
if (self::memoryExceeded($memory)) {
self::stop();
}
}
}注释:在$queue->pop($queueName);是vendorshmilyzxtqueuequeuesDatabaseQueue.php方法内使用事务执行SQL,并且创建vendorshmilyzxtqueuejobsDatabaseJob.php的实例
//取出一个任务
public function pop($queue = null)
{ $queue = $this->getQueue($queue);
if (!is_null($this->expire)) { //$this->releaseJobsThatHaveBeenReservedTooLong($queue);
} $tran = $this->connector->beginTransaction();
//判断是否有一个可用的任务需要执行
if ($job = $this->getNextAvailableJob($queue)) { $this->markJobAsReserved($job->id);
$tran->commit();
$config = array_merge($this->jobEvent, [
'class' => 'shmilyzxt\queue\jobs\DatabaseJob',
'queue' => $queue,
'job' => $job,
'queueInstance' => $this,
]);
return \Yii::createObject($config);
} $tran->commit();
return false;
}至于:$job->execute();是DatabaseJob继承父类Job执行的,顺着代码找下去是yiibaseComponent trigger执行的事件,
/**
* 执行任务
*/
public function execute(){
//beforeExecute 执行任务之前的一个事件 在JobEvent中并没有什么可执行的代码
$this->trigger(self::EVENT_BEFORE_EXECUTE, new JobEvent(["job" => $this, 'payload' => $this->getPayload()]));
$this->resolveAndFire();//真正执行的任务的方法
} /** * 真正任务执行方法（调用hander的handle方法） * @param array $payload * @return void */
protected function resolveAndFire()
{ $payload = $this->getPayload();
$payload = unserialize($payload); //反序列化数据
$type = $payload['type'];
$class = $payload['job'];
if ($type == 'closure' && ($closure = (new Serializer())->unserialize($class[1])) instanceof \Closure) {
$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->isDeletedOrReleased()) { $this->delete();
}
}最后到了执行的SendMail类的handle($job,$data)
yii2 アドバンスト バージョンを使用します。まず、mysql キューを使用して、queue というファイルを設定します。 code> 構成アイテムのルート ディレクトリ <code>commonconfigmain-local.php の components 配列の下で、インストール後に composer をコピーします。 vendorshmilyzxtyii2- queuejobsjobs.sql
vendorshmilyzxtyii2-queuefailedfailed.sql🎜 2 つの SQL ファイルをデータベースに追加して、キュー データ テーブルとタスクが失敗したときのデータ テーブルを確立します。🎜🎜🎜 🎜プッシュタスク開始構文: Yii::$app->queue->pushOn(new SendMial(),['email'=>'49783121@qq.com','title'=>' test','content' =>'email test'],'email'); vendorshmilyzxtqueuequeuesDatabaseQueue.php に移動して、pushOn のコードを見てみましょう。 () メソッドは DatabaseQueue に記述されています。 class is in vendorshmilyzxtqueuebaseQueue.php: 🎜🎜public function handle($job,$data)
{ if($job->getAttempts() > 3){ $this->failed($job);
} $payload = $job->getPayload();
echo '<pre class="brush:php;toolbar:false">';print_r($payload);
//$payload即任务的数据，你拿到任务数据后就可以执行发邮件了
//TODO 发邮件
}🎜注:ここで yii2 イベント イベント クラスを確認するのが最善です。🎜🎜キューに入る: $this->push($job, $data, $queue);、ここで確認します。 queue クラス ファイルを使用して、関連する関数にジャンプして処理します。データはデータベースに記録されます (関数の指示: getQueue()-->createPayload()-- >pushToDatabase())、pushOn() は最終的にデータ挿入を返します。データベースの結果、成功した $ret は 1.🎜🎜3 バックグラウンド実行です。コマンド処理キュー、例: php ./yii worker/listendefault 10 128 3 0 ここで、default はキューの名前です。 > 上記でプッシュされたキューを email に変更する必要があります。 コマンドを開始したら、コードを見てみましょう: まず、WorkerController コントローラーの actionListen メソッドを実行します。コードに従って、vendorshmilyzxtqueueWorker.php -- listen メソッドを入力します。これは実際にはキュー タスクを実行し続けるループです: 🎜🎜🎜🎜rrreee🎜 注: $queue- >pop($queueName); は、トランザクションを使用して SQL を実行する vendorshmilyzxtqueuequeuesDatabaseQueue.php メソッドであり、vendorshmilyzxtqueuejobsDatabaseJob.php のインスタンスを作成します🎜🎜🎜🎜 rrreee🎜: $job->execute(); については、DatabaseJob が親クラスを継承して Job が実行されます。コードに従ってください。 yiibaseComponent トリガー によって実行されたイベントを見つけます。🎜🎜🎜🎜rrreee🎜🎜🎜rrreee🎜 最後に、実行された SendMailhandle($job,$data) に到達します。 ) クラスの、ここにキューにプッシュされたオブジェクトとデータ、そして処理ロジックがあります。🎜🎜🎜🎜rrreee以上がPHPyii2 キューの概要 shmilyzxt/yii2-queueの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。