Queue

一个简单易用的PHP队列组件

使用composer 安装

composer require pfinal/queue

使用示例

<?php

$queue->push(function (Job $job) use ($email, $text) {
    if( Mail::send($email, $text) ){
    
        //任务执行成功后删除job
        $job->delete();
        
    }else{
        
        if ($this->attempts() > 10) {
        
            //todo 处理任务失败业务逻辑
            //...
             
            $job->fail();
            
        }else{
        
            //延时重试
            $delay = $this->attempts() * 5;
            $job->release($delay);
            
        }
    }
});

代码中没有调用 $job->delete() 或 $job->release() 的情况下，job执行完后(无论是否报错)，都会自动执行 $job->release()，一直持续达到 --tries 指定的最大次数

在代码中调用了 $job->release() 时，不受 --tries 限制

命令行监听

php console queue:listen
php console queue:listen --queue=default
console queue:listen --memory=1024 --timeout=3600 --tries=3 --delay=10

database驱动需要的表:

CREATE TABLE `pre_job` (
  `id` bigint unsigned NOT NULL AUTO_INCREMENT,
  `queue` varchar(255) NOT NULL,
  `payload` longtext  NOT NULL,
  `attempts` tinyint unsigned NOT NULL,      -- 第一次执行失败后，记录重试次数(加1等于总执行次数)
  `reserved` int unsigned NOT NULL,
  `reserved_at` DATETIME NOT NULL,
  `available_at` DATETIME NOT NULL,      -- 设置job生效时间，用于创建延时任务(delay)
  `created_at` DATETIME NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

DROP TABLE IF EXISTS pre_job_failed;
CREATE TABLE `pre_job_failed` (
  `id` bigint unsigned NOT NULL AUTO_INCREMENT,
  `queue` varchar(255),
  `payload` longtext,
  `exception` longtext,
  `failed_at` DATETIME NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;