jiaozi/redis-queue

There is no license information available for the latest version (v1.1.0) of this package.

v1.1.0 2018-11-14 15:02 UTC

Requires

• php: >=5.6
• ext-redis: *
• monolog/monolog: ^1.23
• psr/log: ^1.0

Unknown License

• jiaozi

README

一个Redis queue工具, 封装常用的队列相关操作, 简化队列的使用.

特性(FEATURES)

• 封装数据的序列化与反序列化
• 封装信号量处理, 便于代码更新时平滑重启
• 重试机制

代码

守护进程端

$redis = new Redis();
$redis->connect("127.0.0.1", 6379, 30);
$redis->auth("xxx");

$queue = new RedisQueue($redis, "testQueue");
$queue->consume(function($data){
    var_dump($data);
});

以上代码中, consume调用平时不会退出, 除非有信号量进入. 有消息进入时, 回调函数将被自动调用.

投递一个消息.

$redis = new Redis();
$redis->connect("127.0.0.1", 6379, 30);
$redis->auth("xxx");

$queue = new RedisQueue($redis, "testQueue");
$queue->publish("hello");