Download the PHP package goletter/hyperf-queue without Composer

goletter/hyperf-queue

Millisecond-precision async queue for Hyperf, built on top of hyperf/async-queue.

Official RedisDriver stores delay scores with time() (second precision). This package provides RedisMsDriver that:

• stores delayed / reserved scores in milliseconds
• exposes pushMs() / Queue::laterMs() / dispatch_ms()
• runs a lightweight mover coroutine (default every 5ms) so due jobs are pushed into waiting without waiting for BRPOP timeout
• uses a Lua script to move due jobs atomically (safe under multiple consumers)

Requirements

• PHP >= 8.1
• Hyperf 3.1.x
• hyperf/async-queue
• Redis

Install

Path repository (monorepo):

Publish config (or merge into existing config/autoload/async_queue.php):

Configuration

Keep the official default pool unchanged, and add a separate ms pool:

The ms pool uses the same keys as the official pool. Optional tuning keys:

• Official jobs: existing AsyncQueueConsumer (default pool)
• Millisecond jobs: package process Goletter\Queue\Process\MsQueueConsumer (ms pool, auto-registered via #[Process])

Usage

Convention: on RedisMsDriver (ms pool), DriverInterface::push($job, $delay) treats $delay as milliseconds, so existing QueueService::push($job, 'ms', 10) works without API changes. On official RedisDriver, $delay remains seconds.

Jobs are normal Hyperf\AsyncQueue\Job classes — no special base class required.

Ops

Production notes

1. Do not share channel between RedisDriver and RedisMsDriver. Score units differ (seconds vs milliseconds).
2. Prefer Redis Cluster hash tags in channel names, e.g. {queue-ms}, so related keys stay in one slot.
3. move_interval_ms trades CPU vs delay accuracy. 5 is a good default (typical wake latency ≈ 5–20ms + Redis RTT).
4. On ms pool, push($job, $delay) delay unit is milliseconds; on default it is seconds.
5. Retry after failure uses retry_seconds (converted to ms), or retry_milliseconds if set.
6. Multi-tenant: put tenantId on the Job and restore context in handle(); rate-limit at push time if needed.

How it works

License

MIT