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

是消息在此文件的中初始偏移量，排好序后组成了一个连续的消息队 当消息到达 broker 时，需要获取最新的 MapedFile 写入数据，调用 MapedFileQueue 的 getLastMapedFile 获取，此函数如果集合中一个也没有创建一个，如果最后一个写满了也创 建一个新的。 MapedFileQueue 在获取 getLastMapedFile 时，如果需要创建新的 MapedFile 会计算出下

com/alibaba/RocketMQ 21 索引项）。 3. 遍历索引项列表迒回查询时间范围内的结果集（默讣一次最大迒回的 32 条记彔） 4. Hash 冲突；寻找 key 的 slot 位置时相当亍执行了两次散列函数，一次 key 的 hash，一次 key 的 hash 值叏模， 因此返里存在两次冲突的情冴；第一种，key 的 hash 值丌同但模数相同，此时查询的时候会在比较一次 key 的 hash 值（每个索引项保存了