wangjian / queue
消息队列,支持多种驱动,以及完善的容错机制
Installs: 4 336
Dependents: 1
Suggesters: 0
Security: 0
Stars: 8
Watchers: 2
Forks: 3
Open Issues: 0
Requires
- php: >=5.6.0
- predis/predis: ^1.1.0
- symfony/console: ^3.4
Requires (Dev)
- phpunit/phpunit: ^4.8
This package is not auto-updated.
Last update: 2024-11-06 08:55:52 UTC
README
消息队列库,支持多种消息驱动,具有完善的容错机制,命令执行失败时,可以在一段时间之后进行重试。
Usage
使用redis驱动
<?php require_once __DIR__ . '/vendor/autoload.php'; $redis = new Predis\Client([ 'schema' => $this->getConfig('QUEUE_REDIS_SCHEMA', 'tcp'), 'host' => $this->getConfig('QUEUE_REDIS_HOST', '127.0.0.1'), 'port' => $this->getConfig('QUEUE_REDIS_PORT', 6379), 'database' => $this->getConfig('QUEUE_REDIS_DATABASE', 0) ]); $queue = new \Wangjian\Queue\RedisQueue($redis, 'queue'); $queue->push((new \Wangjian\Queue\Job\TestJob()));
使用mysql驱动
在使用mysql消息队列驱动之前,还必须先执行migrate命令完成表格迁移工作。
php bin/worker migrate -c queue.ini
<?php require_once __DIR__ . '/vendor/autoload.php'; $pdo = new PDO('mysql:host=mysql;dbname=test', 'root', 'root'); $queue = new \Wangjian\Queue\MysqlQueue($pdo, 'queue'); $queue->push((new \Wangjian\Queue\Job\TestJob()));
添加定时任务
# 只要将任务的执行时间设置成未来的某个时刻,该任务就会成为定时任务 $queue->push((new \Wangjian\Queue\Job\TestJob())->setRunAt(time() + 10)); //十秒后执行该任务
定时任务执行时间并不一定精确,因为如果队列没有数据的时候,消费者进程会堵塞,因此,可能会有一些延迟,这个取决于QUEUE_SLEEP_INTERVAL配置项的值
消费者进程
开启消费者进程,就可以执行消息队列。开启之前,首先我们要对消费者进程进行配置,配置文件可以参考queue.ini.example。
php bin/worker start default -c queue.ini
执行如上命令,就可以开启一个名称为default,配置文件为queue.ini的消费者进程,除了使用配置文件外,还可以使用如下两种方式进行配置:
- 使用环境变量
export QUEUE_SLEEP_INTERVAL=3
- 使用-e参数
php bin/worker start default -c queue.ini -e "QUEUE_SLEEP_INTERVAL=3"
配置参数优先级为:-e参数 > 配置文件 > 环境变量
关闭消费者进程
# 关闭名称为default的消息队列消费者进程
php bin/worker stop default
重启消费者进程
当修改了配置之后,可以直接执行此命令进行重启
php bin/worker reload default