runner/queue

This package is abandoned and no longer maintained. No replacement package was suggested.

v1.0.4 2018-01-16 11:40 UTC

Requires

• php: >=5.6
• fastd/swoole: ^2.0
• predis/predis: ^1.1

Requires (Dev)

• phpunit/phpunit: ^5.0

MIT

• RunnerLee

README

基于 Swoole Process 实现多消费者任务队列. 功能:

• 多驱动支持
• 消费者进程异常退出自动重启
• 任务超时自动中止
• 任务异常自动重试

嗯.. 没错又是抄的, laravel 的队列.

驱动要求

使用

<?php

$queueFactory = new \Runner\Queue\QueueFactory([
    'redis' => [
        'host'     => '127.0.0.1',
        'port'     => '6379',
        'auth'     => null,
        'database' => 5,
    ],
]);

$schedule = new \Runner\Queue\Schedule(
    [
        'name'         => 'runner',     // 任务名称
        'listen'       => 'default',    // 监听队列
        'pid_path'     => __DIR__,      // pid 文件目录
        'consumer_num' => 3,            // 消费者数量
        'queue_key'    => 1000000,      // 消息队列 key
        'retry_after'  => 60,           // 失败 / 超时 重试时间
        'sleep'        => 2,            // 睡眠时间
    ]
);

$schedule->setQueue($queueFactory->connection('redis'));

$schedule->on('consumerReboot', function () {
    echo "consumer reboot\n";
});

$schedule->on('start', function () {
    echo "mission started\n";
});

$schedule->on('shutdown', function () {
    echo "mission stop\n";
});

$schedule->start();