Yii2 대기열에 대한 간략한 설명 shmilyzxt/yii2-queue

*文
풀어 주다: 2023-03-19 08:02:01
원래의
1665명이 탐색했습니다.

이 글은 주로 Yii2 큐 shmilyzxt/yii2-queue에 대한 간단한 개요를 소개합니다. 도움이 필요한 친구들은 참고할 수 있습니다. 그것이 모두에게 도움이 되기를 바랍니다.

shmilyzxt/yii2-queue 간단한 설명:

1. 저는 yii2 고급 버전을 사용합니다. 여기서는 mysql 대기열을 사용합니다. 대기열 구성 항목을 작성합니다. 루트 디렉터리 commonconfigmain-local.php 구성 요소 배열에서 설치 후 composer를 복사하고 데이터베이스 구성을 변경합니다. commonconfigmain-local.php下的 components数组下,更改一下数据库配置.复制composer安装后复制

vendor\shmilyzxt\yii2-queue\jobs\jobs.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'); 我们到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事件类,http://www.digpage.com/event.html

关于入队列: $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()
{
 $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();
  }
 }
로그인 후 복사

最后到了执行的SendMail类的handle($job,$data)

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 发邮件
 }
로그인 후 복사
2 sql 파일을 데이터베이스에 복사하여 작업 실패 시 대기열 데이터 테이블과 데이터 테이블을 생성합니다.

2. 푸시 작업 시작 구문: Yii::$app->queue->pushOn (new SendMial(),[ 'email'=>'49783121@qq.com','title'=>'test','content'=>'email test'],'email'); code> <code>vendorshmilyzxtqueuequeuesDatabaseQueue.php로 이동합니다. 코드를 살펴보겠습니다. pushOn() 메서드는 의 상위 클래스인 <code>vendorshmilyzxtqueuebaseQueue.php에 작성되어 있습니다. DatabaseQueue 클래스:
rrreee
참고: 여기에 가장 많은 yii2 이벤트 이벤트 클래스를 살펴보겠습니다. http://www.digpage.com/event.html

큐 정보: $this ->push($job, $data, $queue);,여기서 큐 클래스 파일과 협력하여 관련 기능으로 이동하고 데이터를 처리하고 데이터베이스에 기록합니다(기능 방향: <code>getQueue()-->createPayload()-->pushToDatabase()), pushOn()은 최종적으로 데이터베이스에 데이터 삽입 결과를 반환합니다. $ret 성공은 1.3입니다. 백그라운드 실행 명령 처리 대기열, 예: php ./yii 작업자/listen default 10 128 3 0 code>여기서 기본값은 대기열의 이름입니다. 위에 푸시된 이메일 대기열은 이메일로 변경되어야 합니다. 명령을 시작한 후 코드를 살펴보겠습니다. 먼저 WorkerControllerController actionListen 메서드를 실행하고 코드를 따라 <code>vendorshmilyzxtqueueWorker.php를 입력합니다. - Listen 메서드는 실제로 항상 반복되며 대기열 운영 작업을 실행합니다.

rrreee

참고: $queue ->pop($queueName);에서는 vendorshmilyzxtqueuequeuesDatabaseQueue.php 메서드 내에서 트랜잭션을 사용하여 SQL을 실행하고 vendorshmilyzxtqueuejobsDatabaseJob.phprrreee의 인스턴스를 생성합니다. $job->execute() ;는 상위 클래스 Job을 상속받은 DatabaseJob에 의해 실행됩니다. yiibaseComponent 트리거에 의해 실행되는 이벤트를 찾으려면 코드를 따르세요. rrreee마지막으로 handle($job,$)이 실행됩니다. data)SendMail 클래스의 개체 및 데이터이며 대기열에 푸시된 다음 처리 논리가 제공됩니다.

rrreee

관련 권장 사항:

🎜🎜Yii2는 Xunsou를 통합합니다. 효율적인 중국어 단어 분할 검색을 달성하기 위해🎜🎜🎜🎜🎜🎜Yii는 테이블 삭제 오류 보고 문제까지 삭제All을 해결합니다🎜🎜🎜🎜🎜🎜Yii가 잘못된 코드를 필터링하는 방법🎜🎜🎜

위 내용은 Yii2 대기열에 대한 간략한 설명 shmilyzxt/yii2-queue의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

관련 라벨:
원천:php.cn
본 웹사이트의 성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
인기 튜토리얼
더>
최신 다운로드
더>
웹 효과
웹사이트 소스 코드
웹사이트 자료
프론트엔드 템플릿
회사 소개 부인 성명 Sitemap
PHP 중국어 웹사이트:공공복지 온라인 PHP 교육,PHP 학습자의 빠른 성장을 도와주세요!