适用场景
消息队列的价值是解耦与削峰,风险是积压:消费慢了没人发现,磁盘写满后整个链路停摆。
配置步骤(RocketMQ 运维要点)
# 查看集群与 Topic
mqadmin clusterList -n nameserver:9876
mqadmin topicStatus -n nameserver:9876 -t orders
# 消费进度
mqadmin consumerProgress -n nameserver:9876 -g order-group
关键参数与建议
- 集群规划:分区数按吞吐与并发消费者数设计,避免过多分区拖慢元数据
- 副本与可靠性:至少 2~3 副本,生产端 acks 与消费端手动提交按业务选择
- 积压监控:Lag 监控与告警,设置消费延迟阈值
- 磁盘与保留:按流量计算保留策略,避免磁盘写满
- 幂等与顺序:业务侧要能处理重复消息,顺序消息需按 key 分区
容易踩的坑
- NameServer 单点,元数据不可用
- 消息堆积未清理,磁盘被打满
- 重试队列积压无人处理(死信队列)
验证与巡检
mqadmin consumerProgress -n nameserver:9876 -g order-group | head
- 巡检:无死信积压、磁盘充足、名服务器多节点
小结
消息队列的验收:压测达标、积压能告警、消费者扩容有效、磁盘有保护策略。四条缺一条,早晚出事。
> 说明:文中命令为通用写法,不同型号/版本可能略有差异,落地前请对照设备实际版本的官方文档;带外管理与安全设备变更建议先在测试设备验证。