用户问题 ：

RocketMQ 的最佳实践有哪些？

---

专家官方解答 ：

RocketMQ的最佳实践涵盖了生产者、消费者、Broker等多个方面，旨在提高消息传递的效率和可靠性。以下是根据提供的我了解的信息整理的具体最佳实践：

生产者

发送消息注意事项

1. Tag的使用：在发送消息时利用tags来标识消息子类型，这有助于消费端通过broker做消息过滤。可以使用如下代码设置标签：

   messageBuilder.setTag("messageTag");

2. Keys的使用：将业务中的唯一标识符（如订单ID、用户ID等）设置为消息的keys字段，便于后续基于这些标识查询或定位消息。
3. 日志打印：对消息发送成功或失败的情况进行日志记录，便于问题排查。如果send方法没有抛出异常，则表示发送成功。

消息发送失败处理

• 利用Producer的内部重试机制，并参考发送重试策略。
• 对于关键消息，建议实现额外的故障转移方案，比如当同步发送失败时尝试将消息存储到数据库(DB)，再由后台线程定期重试以确保消息最终送达Broker。

消费者

消费过程幂等

• 由于RocketMQ不能保证Exactly-Once语义，因此对于重复敏感的应用场景，需自行实现去重逻辑，例如借助关系型数据库检查消息是否已被处理过。
• 确定唯一的标识符（如msgId或特定业务字段），并依据此标识符执行插入操作来判断是否存在冲突，从而避免重复消费。

提高消费速度

• 增加并行度：可以通过添加更多Consumer实例或者调整单个Consumer内的并发线程数来提升消费速率。
• 批量消费：对于支持批处理的应用场景，采用批量拉取消息的方式能够显著改善性能。
• 跳过非重要消息：在数据准确性要求较低的情况下，可以选择直接调整消费位点以跳过堆积的消息。
• 优化DB交互：尽量减少每条消息消费过程中与数据库之间的交互次数，以降低总体延迟。

日志记录

• 在TPS不高的情况下，在消费入口处记录每条消息及其耗时，有助于后期的问题诊断。

Broker

角色配置

• 根据业务需求选择合适的Broker角色组合，比如为了保证消息的高可靠性可采用SYNC_MASTER加SLAVE的模式。

FlushDiskType

• 权衡性能与可靠性选择合适的刷盘方式，如对实时性有较高要求但可接受一定数据丢失风险时选用ASYNC_FLUSH。

以上提到的所有措施都是为了使RocketMQ应用更加健壮、高效。通过合理地设计和配置，可以最大化发挥RocketMQ的功能优势。希望这些建议能帮助您更好地理解和运用RocketMQ。

---------------

参考链接 ：

• 专家经验：rocketmq 最佳实践

• 专家经验：rocketmq Apache RocketMQ开发者指南

---------------

答疑服务说明：

本内容经由技术专家审阅的用户问答的镜像生成，我们提供了专家智能答疑服务,使用方法： 用法1： 在页面的右下的浮窗”专家答疑“。 用法2： 点击专家答疑页（针对部分网站不支持插件嵌入的情况）

另：

有其他开源产品的使用问题？点击访问阿里AI专家答疑服务。

反馈

如问答有错漏，欢迎点：差评给我们反馈。