RocketMQ 教程 应用场景一 参考资料https://rocketmq-learning.com/course/baseLearn/rocketmq_learning-scene/?spm5176.29160081.0.0.42c67833db4aZpsourcehome二 笔记总结1 RocketMQ 中的相关概念RocketMQ 作为一款分布式消息中间件主要应用于异步解耦流量削峰填谷等场景。如上图所示RocketMQ 中消息的生命周期主要分为“消息生产、消息存储、消息消费”这三部分。生产者生产消息并发送至 RocketMQ 服务端消息被存储在服务端的主题的队列中消费者通过订阅主题消费消息。1.1 消息生产生产者ProducerRocketMQ 中用于产生消息的实体。1.2 消息存储主题TopicRocketMQ 消息传输和存储的分组容器主题内部由多个队列组成。队列MessageQueueRocketMQ 消息传输和存储的实际单元容器消息在队列内具备顺序性存储特征。消息MessageRocketMQ 的最小传输单元。消息具备不可变性在初始化发送和完成存储后即不可变。1.3 消息消费消费者分组ConsumerGroup同一个消费组的多个消费者必须保持消费逻辑和配置一致共同分担该消费组订阅的消息实现消费能力的水平扩展。消费者ConsumerRocketMQ 消费消息的实体。消费者必须被指定到某一个消费组中。订阅关系Subscription订阅关系以消费组粒度进行管理消费组通过定义订阅关系控制指定消费组下的消费者如何实现消息过滤、消费重试及消费进度恢复等。2 RocketMQ 典型应用场景作为一款消息中间件RocketMQ 的典型应用场景有削峰填谷与流量控制、异步解耦。2.1 削峰填谷与流量控制在秒杀、大促等高并发场景下RocketMQ 可以作为缓冲区暂时存储大量涌入的请求从而避免系统直接承受峰值压力实现流量削峰。通过异步处理这些消息系统可以平稳地处理高峰流量保障服务稳定性。2.2 异步解耦RocketMQ 可以用来解耦系统组件允许服务间的异步通信。这样服务就可以独立部署、升级而不影响彼此提高了系统的可扩展性和灵活性。例如不能因为物流系统发货失败就导致交易系统交易失败在交易系统下单支付成功后物流系统出了问题可以去修复物流系统不能影响用户先完成下单支付所以交易系统与物流系统之间应该是解耦的。3 RocketMQ 特性消息的应用场景3.1 顺序消息处理RocketMQ 支持顺序消息功能确保消息严格按照发送顺序被消费。RocketMQ 顺序消息的特性非常适合那些对消息处理顺序有严格要求的业务场景以下是一些典型的使用 RocketMQ 顺序消息的业务场景金融交易系统如先扣除金额再执行充值会导致短暂的账户透支问题应该先完成充值操作再完成扣除金额操作。消息驱动的流程引擎在工作流或业务流程自动化系统中顺序消息可以作为流程节点之间的驱动器确保每个步骤按照预定的顺序执行。3.2 分布式事务支持RocketMQ 提供了分布式事务消息功能能够在分布式系统中实现事务的最终一致性。这使得跨服务的事务操作得以原子化执行确保数据的一致性。RocketMQ 的事务消息特性主要用于解决分布式系统中需要保持数据一致性的复杂场景特别是当业务操作需要跨多个服务或数据库且这些操作必须保持原子性时。以下是事务消息的几个典型业务场景订单支付场景用户在电商平台下单后需要同时更新订单状态、扣减库存、处理支付等操作。事务消息可以确保这一系列操作要么全部成功要么全部失败避免出现订单已确认但库存未扣减或支付未完成的情况。库存扣减与订单创建在库存管理中当用户下单时需确保库存扣减与订单创建同时成功或失败避免超卖或订单错误。事务消息可以保证这一流程的原子性。票务系统火车票、飞机票的预订和出票过程中座位锁定与订单生成必须同步事务消息可以确保不会出现座位已分配但订单未创建或相反的情况。3.3 延时消息与定时任务RocketMQ 支持延时消息功能可以设定消息在未来某一时间点被消费适用于如订单超时自动取消、定时提醒等场景。订单超时处理在电子商务平台中可以利用定时消息来处理未支付的订单。例如当用户下单后系统发送一个延迟几分钟至几小时的定时消息如果到时仍未支付则自动取消订单释放库存。系统任务调度定时消息可以作为轻量级的任务调度工具比如定期数据统计、报表生成、缓存清理、数据库维护任务等无需额外的复杂调度系统。消息重试机制在消息处理失败时可以通过发送一个延迟的定时消息来实现自动重试机制比如支付确认、通知发送失败等情况避免即时重试带来的系统压力。营销活动触发在营销活动中可以预先设定好活动开始或结束的通知通过定时消息在特定时间点自动触发达成营销效果如促销活动的开始提醒、优惠券到期提醒等。系统通知与提醒如用户生日祝福、账户到期提醒、定期报告发送等通过定时消息自动触发确保消息按时送达。社交应用的消息定时发送如定时发送节日祝福、生日祝福等提升用户体验。4 日志与监控数据收集RocketMQ 可以作为日志或监控数据的收集管道从各个服务收集信息统一处理后发送至数据分析或监控平台便于系统监控和故障排查。5 服务编排与工作流通过消息驱动的方式RocketMQ 可以作为服务编排的工具实现复杂工作流的自动化如订单处理流程中的多个服务协同工作。6 消息驱动的微服务架构RocketMQ 可以作为微服务间通信的基础设施实现事件驱动的微服务架构提高系统的响应速度和可维护性。