jar 原文链接：rocketmq 服务部署 ├── jcommander-1.72.jar ├── jna-4.2.2.jar ├── kotlin-stdlib-1.4.10.jar ├── kotlin-stdlib-common-1.4.0.jar ├── libthrift-0.14.1.jar ├── logback-classic-1.0

................................................................................... 25 7.14 单个 JVM 迕程也能利用机器超大内存 ..................................................................................... mmap + write 方式 优点：即使频繁调用，使用小块文件传输，效率也很高 缺点：丌能很好的利用 DMA 方式，会比 sendfile 多消耗 CPU，内存安全性控制复杂，需要避免 JVM Crash 问题。 2. 使用 sendfile 方式 优点：可以利用 DMA 方式，消耗 CPU 较少，大块文件传输效率高，无内存安全新问题。 缺点：小块文件效率低亍 mmap 方式，只能是 Consume Queue 数据结构。整个实现过程基本同 Mysql 主从同步类似。 项目开源主页：https://github.com/alibaba/RocketMQ 26 7.14 单个 JVM 进程也能利用机器超大内存 MEMORY VIRTUAL MEMORY JAVA HEAP DISK Producer Consumer1 Consumer2 Consumer3 ⑤ ④

本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 1.1 RocketMQ 核心概念扫盲篇 < 12 即 order-service-app 部署了 3 台服务器，每一个 jvm 进程可以看做是消费组 order_consumer 消费组的其中一个消费者。 1. 消费模式 那这三个消费者如何来分工来共同消费 order_topic 中的消息呢？ 在 RocketMQ 配置。由于本文主要是搭建一个学习环境，故采取的部署架构为 1 主的部署架构，关于生产 环境下如何搭建 RocketMQ 集群、如何调优参数将在该专栏的后续文章中专门介绍。 Step3：修改 Nameserver jvm 参数 cd bin vi runserver.sh # 定位到如下代码 JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=1 1:9876 brokerIP1=192.168.3.10 brokerIP2=192.168.3.10 autoCreateTopicEnable=false Step6：修改 broker jvm 参数。 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 31 > 1.3 实战：RocketMQ 学习环境搭建指南篇 cd bin vi runbroker.sh #修改如下配置(配置前)

多分⽀支分布式事务 by RocketMQ TxSponsor CallbackReqHeader TxAgent 1 2 TxAgent 1 2 machine/JVM 1 machine/JVM 2 Commit Service Rollback Service Timeout Service TxCoordinator 3 store TxQue Master

消息大小值 msgSize 大于 0 正常数据 等于-1 文件读取错误 恢复结束 等于 0 读到文件末尾 3） 异常数据恢复，OS CRASH 或者 JVM CRASH 或者机器掉电 当${user.home} \store\abort 文件存在，代表异常恢复 读取${user.home} \store\checkpoint 获取最终一致的时间点