有一些粉丝在问我，您对 RocketMQ 研究的这么深入，为什么不考虑贡献代码，成 为一名 Committer 呢？这是因为参与开源项目需要具备一些基本条件，当下我的实际情 况不符合，那成为一个开源项目的 Committer 有些什么条件呢？ 1. 扎实的 Java 基础功底 一个开源项目的底层都会涉及到存储，这就要求具备一定的数据结构基础，JAVA 集 合框架中的类自然成为了我们突破数据结构最好的老师，其次是 尝试谢谢单元测试用例，测试驱动开发，借此学习该框架。 后面的事情就是坚持不懈，朝着目标不断前进，中途可以放慢速度，但千万别放弃，因 为只有坚持，才能胜利，只要前进，就离目标更近。 参与开源，一个最基本的条件是拥有大量的连续时间，想要成为一个开源框架的 Committer ,唯有坚持不懈，持续投入，持续产出。 最后再次感谢 RocketMQ 社区对我的认可，我会尽努力做出更大的贡献，也希望广 大读 1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h 五、消息过滤 消息过滤是指消费端可以根据某些条件对一个 topic 中的消息进行过滤，即只消费一个 主题下满足过滤条件的消息。 RocketMQ 目前主要的过滤机制是基于 tag 的过滤与基于消息属性的过滤，基于消息 属性的过滤支持 SQL92 表达式，对消息进行过滤。 六、小结

RocketMQ 可以很好的支持此特性。 4.9 Exactly Only Once (1). 収送消息阶段，丌允许収送重复的消息。 (2). 消费消息阶段，丌允许消费重复的消息。 只有以上两个条件都满足情冴下，才能讣为消息是“Exactly Only Once”，而要实现以上两点，在分布式系统环 境下，丌可避免要产生巨大的开销。所以 RocketMQ 为了追求高性能，幵丌保证此特性，要求在业务上迕行去重， 要在业务局面去重，有以下几种去重方式 1. 将消息的唯一键，可以是 msgId，也可以是消息内容中的唯一标识字段，例如订单 Id 等，消费乀前判断是否在 Db 戒 Tair(全尿 KV 存储)中存在，如果丌存在则揑入，幵消费，否则跳过。（实际过程要考虑原子性问题，判断 是否存在可以尝试揑入，如果报主键冲突，则揑入失败，直接跳过） msgId 一定是全尿唯一标识符，但是可能会存在同样的消息有两个丌同 1，即一次只消费一条消息，例如设置为 N，那举每次消费的 消息数小亍等亍 N。 14.3.3 跳过非重要消息 収生消息堆积时，如果消费速度一直追丌上収送速度，可以选择丢弃丌重要的消息 如何判断消费収生了堆积？ public ConsumeConcurrentlyStatus consumeMessage(// List msgs

消费一批消息的个数是 可配置的 consumeMessageBatchMaxSize = 1， 默认批量个数为一个 ConsumeRequest 任务 run 方法执行 判断 proccessQueue 是否被 droped 的， 废弃直接返回，不在消费消息 构建并行消费上下文 给消息设置消费失败时候的 retry topic，当消息发送失败的时候发送到 Messagequeue 组成。 ConsumeRequest 任务的 run 方法 判断 proccessQueue 是否被 droped 的， 废弃直接返回，不在消费消息 每个 messagequeue 都会生成一个队列锁来保证在当前 consumer 内，同一个队列串行 消费， 判断 processQueue 的 lock 属性是否为 true，lock 属性是否过期，如果为 checkpoint 作用是当异常恢复时需要根据 checkpoint 点来恢复消息 f) 加载索引服务 indexService g) recover 尝试数据恢复 判断是否是正常恢复，系统启动的启动存储服务(DefaultMessageStore)的时候会创 建一个临时文件 abort, 当系统正常关闭的时候会把这个文件删掉 ，这个类似在 linux 下打开 vi

CREATE_COMPLETE，此时堆栈创建成功。Apache RocketMQ 集群以及其他需要的组 件均已创建完毕。下图列出了默认设置部署完成后在 EC2 Console 的一个 截图，可以从 Name 属性判断这个 Instance 安装的是哪种类型的节点。 Page 13 of 18 使⽤ Apache RocketMQ Apache RocketMQ 在 EC2

CREATE_COMPLETE，此时堆栈创建成功。Apache RocketMQ 集群以及 其他需要的组件均已创建完毕。下图列出了默认设置部署完成后在 EC2 Console 的一 个 截图，可以从 Name 属性判断这个 Instance 安装的是哪种类型的节点。 使用 Apache RocketMQ Apache RocketMQ 在 EC2 上部署所在目录说明： Nameserver