搜索结果: "消息队列" (20)
咖啡养成
连载中 11/20
消费失败与重试:重试队列与死信队列
失败不可怕,不知道失败才可怕。瞬时失败交给退避重试,永久失败送进死信队列,毒消息要有修复重放的自救流程。RocketMQ 的 16 次重试机制,一次拆到底。
咖啡养成
连载中 10/20
事务消息:本地事务与发消息的原子性
先写库还是先发消息,是分布式系统的经典两难。RocketMQ 用半消息机制给出第三种答案:先发一条看不见的消息,事务落库后再放行,Broker 还会主动回查你的业务状态。
咖啡养成
连载中 9/20
延迟消息:订单超时关闭的优雅实现
30 分钟未支付自动关单,从每分钟全表扫描到一条延迟消息搞定:轮询扫表的痛、时间轮的局限、RocketMQ 18 个级别背后的存储设计,以及关单与支付的竞态处理。
咖啡养成
连载中 8/20
消息顺序:全局有序与分区内有序
并行是乱序之源:多队列、消费重试、Rebalance 都能打乱次序。好消息是 99% 的业务只需要「同一个订单内有序」——按 key 路由加分区内串行,加上状态机兜底,顺序问题就这么治。
咖啡养成
连载中 7/20
消息不重复:至少一次投递与消费幂等
积分翻倍不是事故,是机制。「恰好一次」是营销话术,重复投递是 MQ 的出厂设置。唯一键、去重表、状态机,幂等三板斧把重复消费的伤害降到零。
咖啡养成
连载中 6/20
消息不丢(下):Broker 刷盘与消费 ACK
消息进了 Broker 只是中场休息:同步刷盘防断电,同步复制防宕机。消费端更险——先提交还是先干活,选错一边就是丢或重。一篇配齐 Broker 与消费端的防线。
咖啡养成
连载中 5/20
消息不丢(上):生产端确认与重试
消息丢了,先查生产端:oneway 一把梭、异步回调吞异常、进程崩溃消息还在内存——三种死法逐一排查。同步确认、发送重试、本地消息表,三层防线层层加固。
咖啡养成
连载中 4/20
核心模型:消息怎么从生产者走到消费者
Topic 是逻辑分类,Queue 是物理分片,消费者组是并行与广播的开关,拉模式加长轮询是延迟与压垮之间的折中。这一篇把一条消息的完整旅程拆给你看。
咖啡养成
连载中 3/20
主流 MQ 选型:RocketMQ、Kafka、RabbitMQ 怎么挑
三台 MQ 三种性格:RabbitMQ 灵活轻盈、Kafka 吞吐猛兽、RocketMQ 电商全能。一张对比表加上一条按场景走的决策路径,帮老王把选型纠结一次算清。