PUB/SUB根本不支持持久化和ACK，因其是纯内存广播通道，消息一发即焚、无存储、无消费状态记录；必须改用Redis Stream，通过XADD写入、XGROUP创建消费者组、XREADGROUP读取及XACK确认实现真正持久化与可靠投递。
Redis 的 PUB/SUB 本身无法实现消息持久化，强行“加层”或“补 ACK”是徒劳的；必须切换到 Redis Stream 才能真正落地持久化 + ACK。
为什么 PUB/SUB 根本不支持持久化和 ACK
PUB/SUB 是纯内存广播通道，没有存储层：消息一发即焚，订阅者掉线、Redis 重启、甚至网络抖动都会导致消息永久丢失。它连“堆积”这个概念都不存在——因为没地方堆。PUBLISH 返回 1 只表示有至少一个在线订阅者收到了，不保证处理成功；SUBSCRIBE 也不记录任何消费状态，自然谈不上 ACK 或重试。
常见错误现象包括：
- 服务重启后漏掉一批通知（如订单状态变更）
- 消费者临时扩容时，新实例收不到历史消息
- 用
PSUBSCRIBE做日志分发，但某天凌晨丢了一整批告警
用 XADD + XREADGROUP 替换 PUB/SUB 的关键步骤
不是在原有 PUB/SUB 上打补丁，而是用 Stream 重建发布/订阅语义。核心是把“频道”映射为 Stream key，把“消息”转为带 ID 的结构化条目。
Redis Skill - 高性能缓存管理
下载
Redis 缓存和数据结构管理技能。通过自然语言操作 Redis，支持 String、Hash、List、Set、ZSet、Stream 等数据结构操作。当用户提到 Redis、缓存、消息队列、会话存储时使用此技能。
-
XADD写入时必须指定 stream key（如stream:order_events），ID 推荐用*让 Redis 自动生成（格式如1716649200000-0），确保全局有序且可追溯 - 首次使用前需创建消费者组：
XGROUP CREATE stream:order_events mygroup $ MKSTREAM，其中$表示从最新消息开始消费，MKSTREAM自动建 stream（避免NOGROUP错误） - 消费者用
XREADGROUP GROUP mygroup consumer1 STREAMS stream:order_events >阻塞读取新消息（>是特殊符号，表示“上次未确认的下一条”） - 每条消息处理完后，必须调用
XACK stream:order_events mygroup <message_id>，否则该消息会一直留在 PEL（Pending Entries List）中，下次还会被拉取
消息堆积控制与游标管理容易踩的坑
Stream 虽然能存消息，但不设限就会无限膨胀。很多人忽略 MAXLEN 导致磁盘爆满或 XLEN 查询变慢。
- 写入时加长度限制：
XADD stream:logs MAXLEN ~ 10000 * level "warn" msg "disk full"，~表示近似修剪（性能更好），10000 是保留的最大消息数 - 不要依赖
XTRIM定期清理——它不是原子操作，且可能误删正在被消费的消息；MAXLEN是写入时自动裁剪，更安全 - 消费者组游标（
last-delivered-id）只在成功XACK后推进；如果忘记XACK或程序崩溃，游标卡住，新消息永远不下发 - 用
XPENDING stream:order_events mygroup - + 10查看卡在 PEL 里的消息，结合XCLAIM可手动接管超时未确认的消息
Java 客户端中 ACK 的实际调用时机
很多开发者在 xreadgroup 返回后直接 xack，但这是错的——必须等业务逻辑执行完成且无异常后再确认。
- 伪代码逻辑应为：
try { process(msg); client.xack("stream:q", "grp", msgId); } catch (Exception e) { /* 记录日志，不 ack，让 Redis 重发 */ } - Spring Data Redis 的
StreamMessageListenerContainer默认不自动ACK，需显式配置setAutoAcknowledge(false)并在 listener 中手动调用acknowledge() - 若用 Jedis，注意
client.xack()返回值是 Long 类型，成功返回 1，失败返回 0——要检查返回值，不能只看是否抛异常
最常被忽略的一点：Stream 的消息 ID 是时间戳+序列号，同一毫秒内多条消息靠序列号区分。如果你用自定义 ID（比如 UUID），Redis 无法保证顺序，XREADGROUP 可能跳过或重复消费。坚持用 * 生成 ID，才是对“有序队列”最基本的尊重。
