就可以挄照 Producer 収送 的顺序去消费消息。  普通顺序消息 顺序消息的一种，正常情冴下可以保证完全的顺序消息，但是一旦収生通信异常，Broker 重启，由亍队列 总数収生发化，哈希叏模后定位的队列会发化，产生短暂的消息顺序丌一致。 如果业务能容忍在集群异常情冴（如某个 Broker 宕机戒者重启）下，消息短暂的乱序，使用普通顺序方 式比较合适。  严格顺序消息 com/alibaba/RocketMQ 21 索引项）。 3. 遍历索引项列表迒回查询时间范围内的结果集（默讣一次最大迒回的 32 条记彔） 4. Hash 冲突；寻找 key 的 slot 位置时相当亍执行了两次散列函数，一次 key 的 hash，一次 key 的 hash 值叏模， 因此返里存在两次冲突的情冴；第一种，key 的 hash 值丌同但模数相同，此时查询的时候会在比较一次 key 的 hash 值（每个索引项保存了 ORDERID =3001 7.6.2 顺序消息缺陷  収送顺序消息无法利用集群 FailOver 特性  消费顺序消息的幵行度依赖亍队列数量  队列热点问题，个别队列由亍哈希丌均导致消息过多，消费速度跟丌上，产生消息堆积问题  遇到消息失败的消息，无法跳过，当前队列消费暂停 项目开源主页：https://github.com/alibaba/RocketMQ

中存储单元是一个 20 字节定长的数据，是顺序写顺序读 （1） commitLogOffset 是指这条消息在 commitLog 文件实际偏移量 （2） size 就是指消息大小 （3） 消息 tag 的哈希值 ConsumeQueue 文件组织： (1) topic queueId 来组织的，比如 TopicA 配了读写队列 0, 1,那么 TopicA 和 Queue=0 组 成一个 是消息在此文件的中初始偏移量，排好序后组成了一个连续的消息队 当消息到达 broker 时，需要获取最新的 MapedFile 写入数据，调用 MapedFileQueue 的 getLastMapedFile 获取，此函数如果集合中一个也没有创建一个，如果最后一个写满了也创 建一个新的。 MapedFileQueue 在获取 getLastMapedFile 时，如果需要创建新的 MapedFile 会计算出下 字节的定长数据，所以是依次分别取了 Offset long 类型存储了 commitLog 的数据偏移量 Size int 类型存储了在 commitLog 上消息大小 tagcode tag 的哈希值 目前 rocketmq 判断存储的 consumequeue 数据是否有效的方式为判断 offset >= 0 && size > 0 如果数据有效读取下 20 个字节判断是否有效

何商业行为。 1.7 一次 RocketMQ 进程自动退出排查经验分享 < 80 发现 broker 日志中有打印出 shutdownHook，表示在进程退出之前执行了启动时 注册时的退出钩子函数，说明是 broker 是正常停止的，并且也不可能是 kill -9 命令， 肯定是显示的执行了 kill 命令，于是立马使用 history 命令 查看历史命令，都未在指定时 间执行过该命令，并且切换到 抛出 MQBrokerException 该方法会 如何处理。 其关键代码如下图所示： 可以看出在 sendKernelImpl 方法中首先会捕捉异常，先执行注册的钩子函数，即就 算执行失败，对应的消息发送后置钩子函数也会执行，然后再原封不动的将该异常向上抛出。 sendKernelImpl 方法被 DefaultMQProducerImpl 的 sendDefaultImpl 方法调 息的流转）主要是记录消息是何时发送到哪台 Broker，发送耗时多少时间，在什么是被哪 个消费者消费。记录消息的轨迹主要是集中在消息发送前后、消息消费前后，可以通过 RokcetMQ 的 Hook 机制。通过如下两个接口来定义钩子函数。 通过实行上述两个接口，可以实现在消息发送、消息消费前后记录消息轨迹，为了不明 显增加消息发送与消息消费的时延，记录消息轨迹最好使用异步发送模式。 三、如何存储消息轨迹数据 消息轨迹需要存