适用场景

消息队列的价值是解耦与削峰,风险是积压:消费慢了没人发现,磁盘写满后整个链路停摆。

配置步骤(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
  • 巡检:无死信积压、磁盘充足、名服务器多节点

小结

消息队列的验收:压测达标、积压能告警、消费者扩容有效、磁盘有保护策略。四条缺一条,早晚出事。

> 说明:文中命令为通用写法,不同型号/版本可能略有差异,落地前请对照设备实际版本的官方文档;带外管理与安全设备变更建议先在测试设备验证。