README

作业队列实现。

安装

通过Composer

$ composer require phlib/jobqueue

或

"require": {
    "phlib/jobqueue": "*"
}

基本用法

引导

$beanstalk = (new \Phlib\Beanstalk\Factory())->create('localhost');
$db        = new \Phlib\Db\Adapter(['host' => '127.0.0.1', 'dbname' => 'example']);

$scheduler = new \Phlib\JobQueue\DbScheduler($db, 300, 600);
$jobQueue  = new \Phlib\JobQueue\Beanstalk\Scheduled($beanstalk, $scheduler);

生产者

$delay = strtotime('+1 week') - time();
$jobQueue->put('my-queue', ['my' => 'jobData'], ['delay' => $delay]);

消费者

do {
    while ($job = $jobQueue->retrieve($queue)) {
        echo "Found new job {$job->getId()}\n", var_export($job->getBody(), true), "\n";
        $jobQueue->markAsComplete($job);
    }

    usleep(500);
} while (true);

作业队列脚本

脚本依赖于两个构造对象。作业队列接口和调度器接口。为了提供这些功能，以下将描述它们如何注入到脚本中。

jobqueue-config.php（可以位于根目录或config文件夹中。）

<?php

$app = new MyApp();

return new \Phlib\JobQueue\Console\MonitorDependencies($app['jobqueue'], $app['scheduler']);

表结构

CREATE TABLE `scheduled_queue` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `tube` varchar(255) NOT NULL DEFAULT 'default',
  `data` blob NOT NULL,
  `scheduled_ts` timestamp NULL DEFAULT NULL,
  `priority` smallint(5) unsigned DEFAULT NULL,
  `ttr` smallint(5) unsigned DEFAULT NULL,
  `picked_by` varchar(20) DEFAULT NULL,
  `picked_ts` timestamp NULL DEFAULT NULL,
  `create_ts` timestamp NOT NULL,
  `update_ts` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  KEY `scheduled_ts` (`scheduled_ts`)
) ENGINE=InnoDB AUTO_INCREMENT=0 DEFAULT CHARSET=utf8mb4;

许可协议

本软件包是免费软件：您可以在GNU Lesser General Public License的条款下重新分发和/或修改它，该许可协议由Free Software Foundation发布，无论是第3版还是（根据您的选择）任何后续版本。

本程序的分发旨在使其有用，但没有任何保证；甚至没有关于其可销售性或适用于特定用途的暗示性保证。有关更多信息，请参阅GNU Lesser General Public License。

您应已收到GNU Lesser General Public License副本。如果没有，请参阅https://gnu.ac.cn/licenses/。