Middleware/mq-starter
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

docs(README): batchSize 能力格对齐全景手册——两端一致(core 内存攒批/no idle flush/重启丢未满批),纠正 redis 侧 ✅ 伪差异

Browse Source 
Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
This commit is contained in:
hongawen
2026-07-10 15:33:53 +08:00
parent 3c14b0cca3
commit 5191f5ace9
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
README.md
View File

@@ -147,7 +147,7 @@ public class MyErrorHandler implements MqConsumeErrorHandler {
| 去重 `idempotent` | ✅（需 Redis） | ✅（需 Redis） | | 去重 `idempotent` | ✅（需 Redis） | ✅（需 Redis） |
| 失败落库 `RETRY_EXHAUSTED` | ✅ | ✅ 落库并 ACK | | 失败落库 `RETRY_EXHAUSTED` | ✅ | ✅ 落库并 ACK |
| 失败落库 `SINGLE` | ⚠️ 单条：落库+重投；批量：失败被吞（两端一致） | ⚠️ 单条：落库+重投；批量：失败被吞（两端一致） | | 失败落库 `SINGLE` | ⚠️ 单条：落库+重投；批量：失败被吞（两端一致） | ⚠️ 单条：落库+重投；批量：失败被吞（两端一致） |
| 批量 `batchSize` | ✅ | ⚠️ 逐条回调，靠 core 内存攒批 | | 批量 `batchSize` | ⚠️ core 内存攒批（driver 逐条喂）；无 idle flush，低频停滞/重启丢未满批（两端一致） | ⚠️ core 内存攒批（driver 逐条喂）；无 idle flush，低频停滞/重启丢未满批（两端一致） |
| 重试 | ✅ PEL reclaim | ✅ 原生重投 | | 重试 | ✅ PEL reclaim | ✅ 原生重投 |
| 死信队列 | ❌ 只落库 | ✅ 原生 `%DLQ%` | | 死信队列 | ❌ 只落库 | ✅ 原生 `%DLQ%` |
| 顺序消息 | ❌ | ❌ 用的 Concurrently | | 顺序消息 | ❌ | ❌ 用的 Concurrently |