PHPackages                             shali/redis-delayedmq - PHPackages - PHPackages  [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register)

1. [Directory](/)
2. /
3. [Caching](/categories/caching)
4. /
5. shali/redis-delayedmq

ActiveLibrary[Caching](/categories/caching)

shali/redis-delayedmq
=====================

this is a delayed message queue base on redis sorted set.

1.1.0(3y ago)03MITPHPPHP >=5.4

Since Jul 7Pushed 3y ago1 watchersCompare

[ Source](https://github.com/goodbugood/redis-delayedmq)[ Packagist](https://packagist.org/packages/shali/redis-delayedmq)[ RSS](/packages/shali-redis-delayedmq/feed)WikiDiscussions main Synced 3d ago

READMEChangelog (2)Dependencies (1)Versions (3)Used By (0)

基于redis有序集合的延时消息队列
==================

[](#基于redis有序集合的延时消息队列)

最小，最简洁的延时消息队列，支持ACK。 支持分布式，高并发的延时消息队列。线程安全。

消息状态流转
------

[](#消息状态流转)

```
   put            reserve               delete
  -----> [READY] ---------> [RESERVED] --------> *poof*

```

更多的信息

```
   put with delay               release with delay
  ----------------> [DELAYED]  [READY] ---------> [RESERVED] --------> *poof*
                       ^  ^                |  |
                       |   \  release      |  |
                       |    `-------------'   |
                       |                      |
                       | kick                 |
                       |                      |
                       |       bury           |
                    [BURIED]