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

消息 事件 Subscription 多租户 Store Store Store Store Store Store 存储集群 高可用架构升级： • 秒级故障转移，多场景容灾支持 • 无外部依赖，节点间松散耦合 • 自建及云上异构 IaaS 基础设施支持，降低成本 轻量级SDK： • 全面支持云原生通信标准 gRPC 协议 • 无状态 Pop 消费模式，多语言友好，易集成 从业务走向数据： 消息与流融合索引支持 核心问题 • 消息体小且存储结构面向单 条消息，导致提升吞吐困难 • 在进行状态存储时，无 KV 语义支撑 挑战 • Commitlog 格式存储， 统一复制算法 • 不借助外部依赖，提供 状态存储能力 • 单一数据文件，支持面向流的索引及面向 批的索引 • 批量发，批量存，批量读，吞吐提升十倍 • 统一消息，KV 语义，统一 API，提供 状态存储能力 • 流表二象性支持

Access CIDR RemoteAccessCIDR 必填项 允许对堡垒主机进⾏外部 SSH 访 问的 CIDR IP 范围。我们建议您 将此值设置为受信任的 IP 范 围。例如，您可能希望仅对公司 网 络 IP 段授予访问权限。如果 允许所有的外部主机访问，可以 设置为 0.0.0.0/0 Security Configuration 安全配置

Access CIDR RemoteAccessCIDR 必填项 允许对堡垒主机进⾏外部 SSH 访问的 CIDR IP 范围。我们建 议您 将此值设置为受信任的 IP 范围。例如，您可能希望仅对公 司⽹ 络 IP 段授予访问权限。如 果允许所有的外部主机访问，可 以设置为 0.0.0.0/0 Security Configuration 安全配置

是消息在此文件的中初始偏移量，排好序后组成了一个连续的消息队 当消息到达 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 值（每个索引项保存了