消息队列
已收录文章：25篇
-
Go 服务在数据库事务提交后发送消息、刷新缓存或调用外部接口时，最难处理的是提交成功与副作用失败之间的时间窗。本文用 Outbox 表、事务内写入、独立投递与幂等消费拆开重试边界，并给出可验证的 Go 实现与验收清单。238 收藏
-
Redis Stream 消费组出现消息堆积时，先用 XPENDING 判断待处理消息的数量、最老时间和消费者归属，再用 XAUTOCLAIM 接管超时消息，最后按小批量确认、失败重试和监控恢复顺序处理。439 收藏
-
Python logging 的 QueueHandler 能把业务线程和日志写入解耦，但队列满、监听线程退出顺序不对时会出现丢日志。本文拆开背压处理、队列容量和优雅退出的边界，给出可复现的验收代码。473 收藏
-
Redis LMPOP 可以从多个 List 中选择一个非空队列并批量取出元素，但它不是轮询器。本文核对 LEFT、RIGHT、COUNT、空结果和多键顺序，给出多队列消费的安全写法与上线检查点。115 收藏
-
Redis Streams 使用 XREADGROUP 时，空结果不一定代表没有消息。本文从 BLOCK 超时、已确认消息和 XPENDING 消费者状态三条线核对消息是否真正读到，并给出可复查的命令与边界。382 收藏
-
在 Redis Streams 下游，ACK 只是消费确认，不是消息删除；pending 列表、last-delivered-id 与重试窗口一起决定消息是否真正安全出队。本文用 redis-cli 的最小链路验证常见误区和可上线检查点。339 收藏
-
Redis BZMPOP 能从多个有序集合中按最低或最高分值批量弹出成员，空集合时还能等待生产者写入。本文通过最小命令、返回结构、COUNT 边界和超时路径，说明它与 BZPOPMIN、ZMPOP 的差异以及上线前的阻塞连接检查。348 收藏
-
Redis 列表做轻量任务队列时，单独使用 RPOP 容易在消费进程崩溃后丢任务。本文用 LMOVE/BLMOVE 把任务先移入 processing list，再用 LREM 确认完成，拆开重复消费、幂等和集群同槽边界。300 收藏
-
Redis 8.4 为 XREADGROUP 增加 CLAIM 选项，可在一次读取中优先接管达到空闲阈值的 Pending 消息，再读取新消息。本文用订单通知流说明 COUNT、BLOCK、重试计数和 XACK 的生产边界。266 收藏
-
Redis 8.2 为 Streams 增加 XACKDEL 和 XDELEX，可在多消费组场景中把确认与删除、删除与消费组引用处理放进同一条命令。本文用可复现实验比较旧式客户端清理流程与 ACKED 策略的延迟、删除结果和边界。136 收藏
-
Redis Streams 消费者组出现积压时，XAUTOCLAIM 可以把超过最小空闲时间的 pending 消息交给健康消费者继续处理。本文用故障接管场景说明 start 游标、COUNT、JUSTID、重试次数和删除幽灵消息的验收边界。148 收藏
-
文章 · java教程 | 1个月前 | 消息队列 · Java · 事务 · 架构设计 · Spring Boot · spring boot 最终一致性 事务消息表 Outbox Pattern 订单通知订单状态写入数据库后再发送通知，最容易出现数据库成功而消息丢失的窗口。本文用 Spring Boot 和 outbox_event 表，把业务写入与待发送事件放进同一个事务，再用独立发送器处理重试、幂等和失败回退。498 收藏