本文深入探讨了云时代 EDA 的新内涵及它在云时代再次流行的主要驱动力，包括技术驱动力和商业驱动力，随后重点介绍了 RocketMQ 5.0 推出的子产品 EventBridge，并通过几个云时代事件驱动的典型案例，进一步叙述了云时代事件驱动的常见场景和最佳实践。
RocketMQ RocketMQ是一个统一的消息传递引擎，轻量级的数据处理平台。 Name Server Name Server充当路由消息的提供者，生产者(Producer)或消费者(Customer)可以通过Name Server查找各主题对应的Broker IP列表，多个Name Serve
https://rocketmq.apache.org/ Apache RocketMQ是一款开源的、分布式的消息投递与流数据平台。出生自阿里巴巴，在阿里巴巴内部经历了3个版本后，作为Apache 顶级开源项目之一直到现在。在GitHub上有10000+star、5000+fork、170+cont
生产者启动流程 DefaultMQProducer是RocketMQ中默认的生产者实现 核心属性： namesrvAddr: 继承自 ClientConfig，表示 RocketMQ 集群的Namesrv 地址，如果是多个则用分号分开。比如：127.0.0.1：9876;127.0.0.2：9876
RocketMQ客户端的消息发送通常分为以下3层 业务层：通常指直接调用RocketMQ Client发送API的业务代码。 消息处理层：指RocketMQ Client获取业务发送的消息对象后，一系列的参数检查、消息发送准备、参数包装等操作。 通信层：指RocketMQ基于Netty封装的一个RP
相对消费者而言，生产者的使用更加简单，一般关注消息类型、消息发送方法和发送参数，即可正常使用RocketMQ发送消息 常用消息类型 | 消息类型 | 优点 | 缺 点 | 备注 | | | | | | | 普通消息(并发消息) | 性能最好。单机TPS的级别为100 000 | 消息的生产和消费都无
消费流程 消费者组： 一个逻辑概念，在使用消费者时需要指定一个组名。一个消费者组可以订阅多个Topic。 消费者实例： 一个消费者组程序部署了多个进程，每个进程都可以称为一个消费者实例。 订阅关系： 一个消费者组订阅一个 Topic 的某一个 Tag，这种记录被称为订阅关系。RocketMQ规定消费
RocketMQ客户端中有两个独立的消费者实现类：org.apache.rocketmq.client.consumer.DefaultMQPullConsumer 和 org.apache.rocketmq.client.consumer.DefaultMQPushConsumer Default
客户端是通过Rebalance服务做到高可靠的。当发生Broker掉线、消费者实例掉线、Topic 扩容等各种突发情况时，消费者组中的消费者实例是怎么重平衡，以支持全部队列的正常消费的呢？ RebalancePullImpl 和 RebalancePushImpl 两个重平衡实现类，分别被 Defa
RocketMQ设计了远程位点管理和本地位点管理两种位点管理方式。集群消费时，位点由客户端提交给Broker保存，具体实现代码在RemoteBrokerOffsetStore.java文件中；广播消费时，位点保存在消费者本地磁盘上，实现代码在LocalFileOffsetStore.java文件中
RocketMQ的消费方式包含Pull和Push两种 Pull方式：用户主动Pull消息，自主管理位点，可以灵活地掌控消费进度和消费速度，适合流计算、消费特别耗时等特殊的消费场景。缺点也显而易见，需要从代码层面精准地控制消费，对开发人员有一定要求。 在 RocketMQ 中org.apache.ro
主从同步的实现逻辑主要在`HAService`中，在`DefaultMessageStore`的构造函数中，对`HAService`进行了实例化，并在start方法中，启动了`HAService`： ```java public class DefaultMessageStore implement
RocketMQ在集群模式下，同一个消费组内，一个消息队列同一时间只能分配给组内的某一个消费者，也就是一条消息只能被组内的一个消费者进行消费，为了合理的对消息队列进行分配，于是就有了负载均衡。 