leocarmo / php-redis-queue
PHP Redis 队列
1.0.0
2019-07-23 22:13 UTC
Requires (Dev)
- phpunit/php-code-coverage: ^6.1
- phpunit/phpunit: ~7.0
- symfony/var-dumper: ^4.3
This package is auto-updated.
Last update: 2024-09-15 02:09:01 UTC
README
从 composer 开始
composer require leocarmo/php-redis-queue
示例请参考此项目的
examples
文件夹
发布者
use LeoCarmo\RedisQueue\Publisher; $redis = new Redis(); $redis->connect('localhost'); Publisher::setQueueClient('my-queue', $redis); Publisher::pushMessage('my-queue', [ 'message' => 'Hello World!' ]);
监听者
use LeoCarmo\RedisQueue\Listener; $redis = new Redis(); $redis->connect('localhost'); Listener::setQueueClient('my-queue', $redis); Listener::restoreMessagesFromProcessingQueue('my-queue', 1); while (true) { Listener::processMessages('my-queue', 1, 1, function ($events) { dump($events); }); }
测试即将推出