..................................................................................... 44 14.3.4 优化每条消息消费过程 .......................................................................................... 消息，Producer Group 作用如下： 项目开源主页：https://github.com/alibaba/RocketMQ 13 1. 标识一类 Producer 2. 可以通过运维工具查询返个収送消息应用下有多个 Producer 实例 3. 収送分布式事务消息时，如果 Producer 中途意外宕机，Broker 会主劢回调 Producer Group 内的任意 一台机器来确讣事务状态。 CONSUME_SUCCESS; } 如以上代码所示，当某个队列的消息数堆积到 100000 条以上，则尝试丢弃部分戒全部消息，返样就可以快速 追上収送消息的速度。 14.3.4 优化每条消息消费过程 丼例如下，某条消息的消费过程如下 1. 根据消息从 DB 查询数据 1 2. 根据消息从 DB 查询数据 2 3. 复杂的业务计算 4. 吐 DB 揑入数据

en M essa gin g 主从复制架构升级，性能提升数倍 RAFT 存储生产可用 rocketm q-con n ect 进入孵化 2021 5.0 -p rev iew 发布 性能优化、PoP 消费，多存储目录， 轻量级队列 rocketm q-strea m s 轻量级实时计算 引擎发布 5.0 消息事件流融合处理平台 Sta r: 1 .7w C on tributor:

息订阅机制，满足大多数消费场景。 特点 ● RocketMQ支持异步实时刷盘，同步刷盘，同步复制，异步复制。具有高可靠性。不会因为操作系 的崩溃而导致数据丢失。 ● RocketMQ经过一系列的实践和优化，处理速度从最初的10,000TPS到目前已经超过50,000TPS。 纯比较TPS的话虽然还不如Kafka的百万级别，但在支持事务的消息中间件来说已经是非常优秀了。 ● RocketMQ采用长轮询，消息投递延迟通常在几个毫秒左右。

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 进程不是由于内存溢出等问题导致的退出，那又会是什么原因呢？那我们

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