何商业行为。 1.7 一次 RocketMQ 进程自动退出排查经验分享 < 80 发现 broker 日志中有打印出 shutdownHook，表示在进程退出之前执行了启动时 注册时的退出钩子函数，说明是 broker 是正常停止的，并且也不可能是 kill -9 命令， 肯定是显示的执行了 kill 命令，于是立马使用 history 命令 查看历史命令，都未在指定时 间执行过该命令，并且切换到 抛出 MQBrokerException 该方法会 如何处理。 其关键代码如下图所示： 可以看出在 sendKernelImpl 方法中首先会捕捉异常，先执行注册的钩子函数，即就 算执行失败，对应的消息发送后置钩子函数也会执行，然后再原封不动的将该异常向上抛出。 sendKernelImpl 方法被 DefaultMQProducerImpl 的 sendDefaultImpl 方法调 toString(); } 一个 uniqID 的构建主要分成两个部分：FIX_STRING 与唯一 ID 生成算法，顾名思义， FIX_STRING 就是一个客户端固定一个前缀，那接下来先看一下固定字符串的生成规则。 FIX_STRING MessageClientIDSetter 静态代码块： static { byte[] ip; try { ip = UtilAll.getIP();

com/alibaba/RocketMQ 21 索引项）。 3. 遍历索引项列表迒回查询时间范围内的结果集（默讣一次最大迒回的 32 条记彔） 4. Hash 冲突；寻找 key 的 slot 位置时相当亍执行了两次散列函数，一次 key 的 hash，一次 key 的 hash 值叏模， 因此返里存在两次冲突的情冴；第一种，key 的 hash 值丌同但模数相同，此时查询的时候会在比较一次 key 的 hash 值（每个索引项保存了 Consume Queue，如果存储的 Message Tag 不订阅的 Message Tag 丌符合，则跳过，继续比对下一个，符合则传输给 Consumer。注意：Message Tag 是字符串形式，Consume Queue 中存储的是其对应的 hashcode，比对时也是比对 hashcode。 (2). Consumer 收到过滤后的消息后，同样也要执行在 Broker 端的操作，但是比对的是真实的 language 字符串 请求収起方实现诧言，默讣 JAVA 应答接收方实现诧言 version 整数 请求収起方程序版本 应答接收方程序版本 opaque 整数 请求収起方在同一连接上丌 同的请求标识代码，多线程 连接复用使用 应答方丌做修改，直接迒 回 flag 整数 通信局的标志位 通信局的标志位 remark 字符串 传输自定丿文本信息

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