Brève description de la file d'attente Yii2 shmilyzxt/yii2-queue

Cet article présente principalement un aperçu simple de la file d'attente Yii2 shmilyzxt/yii2-queue Les amis dans le besoin peuvent s'y référer. J'espère que cela aide tout le monde.

shmilyzxt/yii2-queue Explication simple :

1 J'utilise la version avancée de yii2 et regardons la. Ici, j'utilise la file d'attente mysql. Tout d'abord, configurez le fichier. J'écris les éléments de configuration de la file d'attente sous le tableau commonconfigmain-local.php sous le répertoire racine components et je modifie la configuration de la base de données. composer2 fichiers SQL dans la base de données pour créer une table de données de file d'attente et une table de données en cas d'échec de la tâche.

vendor\shmilyzxt\yii2-queue\jobs\jobs.sql
vendor\shmilyzxt\yii2-queue\failed\failed.sql

2. Syntaxe de démarrage de la tâche Push :

Passons à <.> pour jeter un œil au code, pushOn() La méthode est écrite dans la classe parent

de la classe

: Yii::$app->queue->pushOn(new SendMial(),['email'=>'49783121@qq.com','title'=>'test','content'=>'email test'],'email');vendorshmilyzxtqueuequeuesDatabaseQueue.phpDatabaseQueue Remarque : Il est préférable de jeter un œil à la classe d'événements d'événement yii2 ici, http://www.digpage.com/event.htmlvendorshmilyzxtqueuebaseQueue.php

À propos de l'entrée dans la file d'attente :

//入队列
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}");
 }
 }

Ici, nous coopérons avec le fichier de classe de file d'attente pour afficher, passer aux fonctions associées, traiter les données et les enregistrer dans la base de données. (Direction de la fonction :

Renvoie enfin le résultat de l'insertion des données dans la base de données, $ret réussi est 1.

3. Exécutez la file d'attente de traitement des commandes en arrière-plan. , par exemple : $this->push($job, $data, $queue);, où default est le nom de la file d'attente. Une file d'attente de courrier électronique poussée ci-dessus doit être remplacée par email.getQueue()-->createPayload()-->pushToDatabase()),pushOn()

start Après la commande, regardons le code : exécutez d'abord :

Contrôleur aphp ./yii worker/listen default 10 128 3 0 méthode, nous suivons le code dans la méthode

, ici il boucle en fait tout le temps, exécutant la tâche de la file d'attente des opérations :

WorkerControllerctionListen Remarque : vendorshmilyzxtqueueWorker.php -- listen utilise transactions pour exécuter SQL dans la méthode

et crée une instance de

/**
 * 启用一个队列后台监听任务
 * @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 Quant à : vendorshmilyzxtqueuejobsDatabaseJob.php ; DatabaseJob hérite de la classe parent Job Executed, suivez le code pour trouver le événements exécutés par

,

 //取出一个任务
 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(), et arrivent enfin au yiibaseComponent trigger de la classe

exécutée. Voici les objets et les données poussés vers la file d'attente, puis voici notre traitement. logique

/**
 * 执行任务
 */
public function execute()
{
 $this->trigger(self::EVENT_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 = 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();
  }
 }

SendMailhandle($job,$data)Recommandations associées :

public function handle($job,$data)
 {
  if($job->getAttempts() > 3){
   $this->failed($job);
  }
  $payload = $job->getPayload();
  echo &#39;<pre class="brush:php;toolbar:false">&#39;;print_r($payload);
  //$payload即任务的数据，你拿到任务数据后就可以执行发邮件了
  //TODO 发邮件
 }

Yii2 intègre Xunsou pour obtenir une récupération efficace de la segmentation des mots chinois

Yii résout le problème d'erreur de suppression de la table de connexion DeleteAll

Comment Yii filtre le mauvais code

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!