PHPackages                             solarseahorse/webman-redis-queue - 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. solarseahorse/webman-redis-queue

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

solarseahorse/webman-redis-queue
================================

A webman redis queue plug-in

v1.0.1(2y ago)6447[2 issues](https://github.com/SolarSeahorse/webman-redis-queue/issues)MITPHPPHP >=8.0

Since Jan 17Pushed 2y ago1 watchersCompare

[ Source](https://github.com/SolarSeahorse/webman-redis-queue)[ Packagist](https://packagist.org/packages/solarseahorse/webman-redis-queue)[ RSS](/packages/solarseahorse-webman-redis-queue/feed)WikiDiscussions main Synced 1mo ago

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

Webman Redis Queue 插件
=====================

[](#webman-redis-queue-插件)

简介
--

[](#简介)

`webman-redis-queue` 是为 [Webman](https://www.workerman.net/doc/webman/install.html) 框架设计的高效、灵活的 Redis 队列插件。利用 Redis Stream 的强大特性，该插件专注于提供可靠和高性能的消息队列解决方案，适合处理大规模的数据流和复杂的队列操作。

### 主要特性

[](#主要特性)

- **基于 Redis Stream：** 使用 Redis 最新的 Stream 数据类型，为消息队列和事件流提供优化的存储和访问。
- **自定义异常重试：** 支持自定义的消息处理失败重试机制，提高消息处理的可靠性。
- **死信队列处理：** 集成死信队列管理，确保消息不会因处理失败而丢失。
- **延时队列支持：** 实现延时消息处理，使得定时任务和延迟执行变得简单易行。
- **高效的异常处理机制：** 强化的异常处理策略，确保队列的稳定运行。

安装
--

[](#安装)

通过 Composer 安装 `webman-redis-queue`：

```
composer require solarseahorse/webman-redis-queue:^1.0.1
```

版本变更记录
------

[](#版本变更记录)

### v1.0.1 (20240128)

[](#v101-20240128)

#### 新增功能

[](#新增功能)

- **删除延时消息**： 新增 `removeDelayedMessage` 方法，允许移除一条延时消息。
- **批量删除延时消息**： 新增 `removeDelayedMessages` 方法，允许一次性移除多个指定的延时消息。
- **检查延时消息存在性**： 新增 `hasDelayedMessageExists` 方法，用于检查延时消息是否存在。
- **批量检查延时消息存在性**： 新增 `hasDelayedMessagesExist` 方法，用于批量检查多个延时消息是否存在。

#### 异常处理

[](#异常处理)

- **引入新的异常类型**： 为延时消息的移除和存在性检查操作引入了 `DelayedMessageRemoveException` 和 `DelayedMessageCheckException` 异常类型。

#### 文档修正

[](#文档修正)

- **修正文档中的几处错误**： 对插件的官方文档进行了更新，修正了之前版本中存在的一些描述不准确和排版错误。

### 测试和反馈

[](#测试和反馈)

我们非常欢迎并鼓励您在测试环境中尝试这个插件，并且分享您的使用体验。您的反馈对我们改进插件、修复潜在的问题以及发布未来的稳定版本非常重要。如果您在使用过程中遇到任何问题或有任何建议，请通过 [GitHub Issues](https://github.com/SolarSeahorse/webman-redis-queue/issues)与我联系。

### 参与贡献

[](#参与贡献)

如果您对改进 webman-redis-queue 有兴趣，欢迎任何形式的贡献，包括但不限于：提交问题、提供反馈、或直接向代码库提交改进。您的贡献将帮助我们更快地推出稳定、功能丰富的正式版本。

配置
--

[](#配置)

配置文件自动生成在 config/plugin/solarseahorse/webman-redis-queue目录下。

### 1. Redis配置 redis.php

[](#1-redis配置-redisphp)

```