消息队列是微服务异步通信的核心组件。对接消息队列不仅仅是发送和接收消息那么简单，还需要考虑消息可靠性、顺序性、幂等性等生产级问题。本文分享消息队列对接的实战经验和常见问题解决方案。
消息生产者设计
消息生产者要确保消息可靠投递。确认机制：生产者发送消息后等待broker的确认回执。如果确认超时或失败，重试发送。重试需要设置最大重试次数和指数退避策略。消息体设计：包含消息ID、业务类型、业务数据和时间戳。消息ID用于去重和追踪。消息内容不宜过大，建议不超过1MB，大数据量使用引用存储。消息的重要性决定投递模式：重要消息用confirm模式，常规消息用fire-and-forget模式。
消息消费者设计
消息消费需要关注并发和顺序。并发消费：多个消费者同时消费消息提高吞吐量，但要注意并发导致的竞态条件。顺序消费：同一业务实体的消息需要顺序处理，如订单状态变更。实现方案：将同一业务ID的消息发送到同一个分区（Kafka）或同一个队列（RabbitMQ）。消费者故障：消息消费失败后重新入队或进入死信队列。死信队列中的消息需要人工处理或定时重试。
幂等消费实现
消息重复投递是常态，消费端必须实现幂等。幂等方案：业务ID去重，消费前检查业务ID是否已处理。数据库唯一约束防止重复插入。利用业务逻辑自身的幂等性，如支付状态机的幂等处理。去重表是最常用的方案：消费前在去重表中插入消息ID，插入成功则处理，插入失败说明已处理。去重记录需要定期清理，避免表数据膨胀。
消息可靠性保证
端到端的消息可靠性需要生产端和消费端共同努力。生产端：消息落盘加确认机制加重试。Broker：持久化消息到磁盘加主从复制。消费端：手动确认加幂等处理加死信队列。事务消息：RocketMQ支持分布式事务的消息投递，确保本地事务和消息发送的一致性。全链路追踪为每条消息关联traceId，追踪从生产到消费的完整路径，便于问题定位。