ROCKETMQ-消息发送与消费（二）
💡
原文中文，约9400字，阅读约需23分钟。
📝
内容提要
本文介绍了ROCKETMQ的消息发送和消费相关关注点，包括可靠发送消息、将消息发送到broker、消息发送类型和行列选择，以及中心类和推拉形式的使用示例。还讨论了消息消费的一致性和并发消费时的问题。
🎯
关键要点
- ROCKETMQ的消息发送和消费关注点包括可靠性、发送到broker、发送类型和行列选择。
- MQAdmin是ROCKETMQ的基本管理接口，MQProducer是消息发送者接口。
- 消息发送类型包括同步发送、异步发送、单向发送和批量发送。
- 消息发送的负载均衡策略有轮询和Hash算法，分别适用于非顺序和顺序消息。
- 引入重试机制和故障规避机制以提高消息发送的高可用性。
- 事务消息处理需要保证与数据库事务的一致性，可以使用本地事务表方法。
- MQConsumer是消息消费者，分为推模式和拉模式，DefaultMQPushConsumer和DefaultMQPullConsumer是其默认实现。
- 推模式封装了拉模式的复杂性，简化了用户的使用。
- 消息消费进展的存储策略在集群和广播模式下有所不同。
- DefaultLitePullConsumer是对PULL形式的简化，提供更方便的API。
- 顺序消息需要保证在同一队列中按顺序消费，可能会遇到消费失败和重试导致的顺序性问题。
➡️
