4.8.0 19 NameServer Intance type NameServerInstanceType m5.large Nameserver 节点的 EC2 实例类 型 20 Broker Node Instance Type BrokerNodeInstanceType m5.xlarge Broker 节点 EC2 实例类型 21 Apache Apache RocketMQ flush Disk Type FlushDiskType ASYNC_FLUSH Apache RocketMQ Flush Disk 的类 型(ASYNC_FLUSH or SYNC_FLUSH) 22 Volume Size VolumeSize 400 要挂载到 RocketMQ 所有节点的 Amazon EBS ( 数据) 点的数量 11 BrokerNodeInst anceType BrokerNodeInstanceType m5.xlarge Broker 节点的 EC2 Instance 的类 型 12 FlushDiskType FlushDiskType ASYNC_FLUSH Apache RocketMQ 的刷盘方式， 支持 ASYNC_FLUSH 和 SYNC_FLUSH

绝大部分消息消费行为属亍 IO 密集型，即可能是操作数据库，戒者调用 RPC，返类消费行为的消费速度在亍 后端数据库戒者外系统的吞吏量，通过增加消费幵行度，可以提高总的消费吞吏量，但是幵行度增加到一定程度， 项目开源主页：https://github.com/alibaba/RocketMQ 44 反而会下降，如图所示，呈现抛物线形式。所以应用必须要设置合理的幵行度。CPU 密集型应用除外。 修改消费幵行度方法

first ? Member service Account service Send message Receive message 先执⾏行行本地事务还是先发送消息？ 交易易型分布式事务的 RocketMQ使⽤用场景 分布式事务解决⽅方案 半消息 远程事务 特点： 1. 稳定，⽀支持⾼高并发 2. 回查机制可靠易易⽤用 3. 不不引⼊入额外的依赖 注意：回查⽅方法需要幂等

则消费会 积压。 三、事务消息 事务消息并不是为了解决分布式事务，而是提供消息发送与业务落库的一致性，其实现 原理就是一次分布式事务的具体运用，请看如下示例： 上述伪代码中，将订单存储关系型数据库中和将消息发送到 MQ 这是两个不同介质的 两个操作，如果能保证消息发送、数据库存储这两个操作要么同时成功，要么同时失败， RocketMQ 为了解决该问题引入了事务消息。 温馨提示，本节 但问题来了，为什么在生产实际过程中一台 Broker 由于内存故障重启,10 分钟后重启 成功后业务才恢复，即业务才真正感知 Broker 宕机呢？ 既然出现了，我们就需要对其进行分析，给出解决方案，避免不会在生产环境出现同类 型的错误。 2. 故障排查经过 先查询客户端的日志(/home/{user}/logs/rocketmqlogs/rocketmq_client.log)，从 中可以看到从客户端第一次报消息发送超时的时间是