pfinal/queue

The PFinal queue package.

Queue

一个简单易用的PHP队列组件, _(*1)

使用composer 安装

composer require pfinal/queue

使用示例, _(*2)

<?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 指定的最大次数, _(*3)

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

命令行监听, _(*5)

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

database驱动需要的表:, _(*6)

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;