PHPackages                             tinywan/redis-stream - 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. [Queues & Workers](/categories/queues)
4. /
5. tinywan/redis-stream

ActiveLibrary[Queues & Workers](/categories/queues)

tinywan/redis-stream
====================

A lightweight queue based on Redis Stream

v0.0.6(7mo ago)6183[2 PRs](https://github.com/Tinywan/redis-stream/pulls)PHPPHP ^7.4||^8.0CI passing

Since Sep 25Pushed 3mo agoCompare

[ Source](https://github.com/Tinywan/redis-stream)[ Packagist](https://packagist.org/packages/tinywan/redis-stream)[ RSS](/packages/tinywan-redis-stream/feed)WikiDiscussions main Synced 1mo ago

READMEChangelogDependencies (2)Versions (8)Used By (0)

🚀 Redis Stream Queue
====================

[](#-redis-stream-queue)

[![Latest Version on Packagist](https://camo.githubusercontent.com/f0c084f830035fb0476b6d2dce89f55a9af154a3c81405ab1811bd591a48a03c/68747470733a2f2f696d672e736869656c64732e696f2f7061636b61676973742f762f74696e7977616e2f72656469732d73747265616d2e7376673f7374796c653d666c61742d737175617265)](https://packagist.org/packages/tinywan/redis-stream)[![Total Downloads](https://camo.githubusercontent.com/7bcf353a09087b1cf34334177ea792f744ed373584a89aeffddd5e29fa6329c4/68747470733a2f2f696d672e736869656c64732e696f2f7061636b61676973742f64742f74696e7977616e2f72656469732d73747265616d2e7376673f7374796c653d666c61742d737175617265)](https://packagist.org/packages/tinywan/redis-stream)[![License](https://camo.githubusercontent.com/23e6db1f9d394c1becbc2280ddae6c33fa9662d4979593d28a9bdfce33f7f4c9/68747470733a2f2f696d672e736869656c64732e696f2f7061636b61676973742f6c2f74696e7977616e2f72656469732d73747265616d2e7376673f7374796c653d666c61742d737175617265)](https://packagist.org/packages/tinywan/redis-stream)[![PHP Version](https://camo.githubusercontent.com/204b1791e3a57f86a93de1422b2a6e584f5045431629c5b9abd4e28dbc8b5357/68747470733a2f2f696d672e736869656c64732e696f2f62616467652f7068702d253345253344372e342d626c75652e737667)](https://www.php.net)[![Redis Version](https://camo.githubusercontent.com/10c11d85c6a81690aa9eaa1d0c4029cccc82ff1da20789ac6ae7bdff2285de20/68747470733a2f2f696d672e736869656c64732e696f2f62616467652f72656469732d253345253344352e302d7265642e737667)](https://redis.io)[![Tests](https://camo.githubusercontent.com/42527a1fdf73579c2bf66405de87288c68bc4d5f57fb7e96956301ff0dd7e032/68747470733a2f2f696d672e736869656c64732e696f2f62616467652f74657374732d363925323070617373696e672d627269676874677265656e2e737667)](https://github.com/Tinywan/redis-stream/actions)

> 🚀 基于 Redis Streams 的高性能轻量级 PHP 队列

✨ 特性
----

[](#-特性)

- ⚡ **高性能** - 基于 Redis 5.0+ Stream，支持高并发
- ⏰ **延时任务** - 基于 Sorted Set，支持秒级到年级延时
- 🔄 **多生产者/消费者** - 支持多个生产者和消费者同时工作
- 💾 **消息持久化** - 可靠的消息持久化存储
- ✅ **ACK 确认机制** - 完善的消息确认机制
- 🔄 **智能重试** - 可配置的重试次数和延迟策略
- 🔄 **消息重放** - 支持重新处理历史消息
- 🔍 **消息审计** - 提供只读模式审计所有消息
- 🧪 **完整测试** - 69个测试，244个断言，100%通过率
- 📝 **PSR-3 日志** - 标准 PSR-3 日志接口
- 🏗️ **单例模式** - 单例模式支持，避免重复创建实例

📋 环境要求
------

[](#-环境要求)

- **PHP** >= 7.4
- **Redis** >= 5.0
- **Composer** >= 2.0
- **ext-redis** 扩展

🚀 快速安装
------

[](#-快速安装)

```
composer require tinywan/redis-stream
```

🎯 快速开始
------

[](#-快速开始)

### 基础使用

[](#基础使用)

创建队列实例

```