饺子/redis-queue

此包的最新版本（v1.1.0）没有可用的许可信息。

维护者

详细信息

github.com/gaohuia/redis-queue

源代码

问题

安装: 10

依赖: 0

建议者: 0

安全性: 0

星标: 0

关注者: 1

分支: 0

开放问题: 0

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

Requires

Unknown License 5580c51389cc2ffb787dfae5b8a7081b93d4cfb4

  • jiaozi <www.woop@zeroplace.cn>

This package is not auto-updated.

Last update: 2024-09-29 06:14:17 UTC

README

一个Redis队列工具，封装常用的队列相关操作，简化队列的使用。

特性(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");