cketmqlogs/ rocketmq-console：/home/baseuser/logs/consolelogs 二、IDEA 中安装 RocketMQ 绝大数的程序员最信赖的开发调试工具基本都是 DEBUG，那能在 IDEA 中 debug RocketMQ 的源码吗？答案当然是可以的。本节就来演示如何在 IDEA 中运行 RocketMQ 的 Nameserver、Broker RocketMQ 进程自动退出排查经验分享 这两个参数，不能直接根据 是否生成 dump 文件，那退而求其次去查看其 GC 日志， 将 GC 日志下载到本地，然后可以使用一个在线 gc 日志分析工具：https://gceasy.io/ ， 将 gc 日志上传后会给出图形化的展示，其图如下： 发现垃圾回收很正常。 既然 Java 进程不是由于内存溢出等问题导致的退出，那又会是什么原因呢？那我们 入堆外 内存，消费消息直接从 pagecache 中读，然后定时将堆外内存的消息写入 pagecache。 但这种方案随之带来的就是可能存在消息丢失，如果对消息非常严谨的话，建议扩容集群， 或迁移 topic 到新的集群。 同时在做 Broker 服务器巡检的时候，可以通过去通过如下命令去查看 broker 一次 消息追加是否会超过 500 ms。 在这个图中我们看到在设置了 tran

经典网络/VPC 网络 Overlay/Underlay NVMe 普通云盘 ESSD 云盘 SA TA 独占/混部/独立交付…… • 集群节点异常成为常态 • 依赖服务随时可能在进行迁移或重启 • 对弹性的要求开始从物理资源变为逻辑资源 • IaaS 的多样性对应用交付部署提出了更高要求 • 可运维性、可观测性带来了更大挑战 • 多租环境带来了更高的网络及安全隔离要求 • ？ 无损弹性扩缩 固定分区面临的挑战 • 无切换架构中，主节点宕机，备节点不可写，分区数量减少 • 容量不足，Kafka 分区迁移时，会导致网络风暴，耗时极长 问题重点 • 在主节点宕机时，备节点要有自动切换为主的能力 • 容量调整时，不能产生数据迁移，且要在秒级完成 固定分区使用场景 • 任务计算过程中，会将同一个业务类型的数据发到同一个队列 • Binlog 等数据同步过程中，需要保证严格顺序

力力不不⾜足 • HTTP/RESTful/JSON 灵活调⽤用，监控及运维能⼒力力不不⾜足 • Cloud云⼚厂商⽅方⾯面 • 不不同云⼚厂商之间消息产品互操作性成本较⾼高，⽤用户跨云⼚厂商迁移难 • 云上与云下产品的⽆无缝衔接能⼒力力差 云原⽣生与业界标准 OpenMessaging AMQP • 简单灵活 • 云原⽣生 • ⼚厂商中⽴立 • 语⾔言⽆无关 • ⾯面向消息和流的标准

[ec2-user@ip-10-0-6-235 ~]$ 4. 登录到 Nameserver 或者 Broker Node 之后，您就可以使用 Apache RocketMQ 自带的命令行工具进行操作。

消息，Producer Group 作用如下： 项目开源主页：https://github.com/alibaba/RocketMQ 13 1. 标识一类 Producer 2. 可以通过运维工具查询返个収送消息应用下有多个 Producer 实例 3. 収送分布式事务消息时，如果 Producer 中途意外宕机，Broker 会主劢回调 Producer Group 内的任意 一台机器来确讣事务状态。