 Apache RocketMQ 从入门到实战技术内幕》第二、三章。 Step1:在 Broker 启动流程中,会构建 TopicConfigManager 对象,其构造方法中 首先会判断是否开启了允许自动创建主题,如果启用了自动创建主题,则向 topicConfigT able 中添加默认主题的路由信息。 TopicConfigManager 构造方法: 本文来自『中间件兴趣圈』公众号,仅作技术交流,未授权任何商业行为。 21 > 1.2 生产环 何商业行为。 1.7 一次 RocketMQ 进程自动退出排查经验分享 < 80 发现 broker 日志中有打印出 shutdownHook,表示在进程退出之前执行了启动时 注册时的退出钩子函数,说明是 broker 是正常停止的,并且也不可能是 kill -9 命令, 肯定是显示的执行了 kill 命令,于是立马使用 history 命令 查看历史命令,都未在指定时 间执行过该命令,并且切换到 抛出 MQBrokerException 该方法会 如何处理。 其关键代码如下图所示: 可以看出在 sendKernelImpl 方法中首先会捕捉异常,先执行注册的钩子函数,即就 算执行失败,对应的消息发送后置钩子函数也会执行,然后再原封不动的将该异常向上抛出。 sendKernelImpl 方法被 DefaultMQProducerImpl 的 sendDefaultImpl 方法调0 码力 | 165 页 | 12.53 MB | 1 年前3 Apache RocketMQ 从入门到实战技术内幕》第二、三章。 Step1:在 Broker 启动流程中,会构建 TopicConfigManager 对象,其构造方法中 首先会判断是否开启了允许自动创建主题,如果启用了自动创建主题,则向 topicConfigT able 中添加默认主题的路由信息。 TopicConfigManager 构造方法: 本文来自『中间件兴趣圈』公众号,仅作技术交流,未授权任何商业行为。 21 > 1.2 生产环 何商业行为。 1.7 一次 RocketMQ 进程自动退出排查经验分享 < 80 发现 broker 日志中有打印出 shutdownHook,表示在进程退出之前执行了启动时 注册时的退出钩子函数,说明是 broker 是正常停止的,并且也不可能是 kill -9 命令, 肯定是显示的执行了 kill 命令,于是立马使用 history 命令 查看历史命令,都未在指定时 间执行过该命令,并且切换到 抛出 MQBrokerException 该方法会 如何处理。 其关键代码如下图所示: 可以看出在 sendKernelImpl 方法中首先会捕捉异常,先执行注册的钩子函数,即就 算执行失败,对应的消息发送后置钩子函数也会执行,然后再原封不动的将该异常向上抛出。 sendKernelImpl 方法被 DefaultMQProducerImpl 的 sendDefaultImpl 方法调0 码力 | 165 页 | 12.53 MB | 1 年前3
 消息中间件RocketMQ原理解析 - 斩秋是消息在此文件的中初始偏移量,排好序后组成了一个连续的消息队 当消息到达 broker 时,需要获取最新的 MapedFile 写入数据,调用 MapedFileQueue 的 getLastMapedFile 获取,此函数如果集合中一个也没有创建一个,如果最后一个写满了也创 建一个新的。 MapedFileQueue 在获取 getLastMapedFile 时,如果需要创建新的 MapedFile 会计算出下 exception NettyClientHandler netty 处理请求的业 Client 与通信层的交互封装了 MQClientAPIImpl 统一处理,在 MQClientAPIImpl 构造的时候注 册了 ClientRemotingProcessor 来处理 server 的请求 四:底层传输协议 RocketMq0 码力 | 57 页 | 2.39 MB | 1 年前3 消息中间件RocketMQ原理解析 - 斩秋是消息在此文件的中初始偏移量,排好序后组成了一个连续的消息队 当消息到达 broker 时,需要获取最新的 MapedFile 写入数据,调用 MapedFileQueue 的 getLastMapedFile 获取,此函数如果集合中一个也没有创建一个,如果最后一个写满了也创 建一个新的。 MapedFileQueue 在获取 getLastMapedFile 时,如果需要创建新的 MapedFile 会计算出下 exception NettyClientHandler netty 处理请求的业 Client 与通信层的交互封装了 MQClientAPIImpl 统一处理,在 MQClientAPIImpl 构造的时候注 册了 ClientRemotingProcessor 来处理 server 的请求 四:底层传输协议 RocketMq0 码力 | 57 页 | 2.39 MB | 1 年前3
 RocketMQ v3.2.4 开发指南com/alibaba/RocketMQ 21 索引项)。 3. 遍历索引项列表迒回查询时间范围内的结果集(默讣一次最大迒回的 32 条记彔) 4. Hash 冲突;寻找 key 的 slot 位置时相当亍执行了两次散列函数,一次 key 的 hash,一次 key 的 hash 值叏模, 因此返里存在两次冲突的情冴;第一种,key 的 hash 值丌同但模数相同,此时查询的时候会在比较一次 key 的 hash 值(每个索引项保存了0 码力 | 52 页 | 1.61 MB | 1 年前3 RocketMQ v3.2.4 开发指南com/alibaba/RocketMQ 21 索引项)。 3. 遍历索引项列表迒回查询时间范围内的结果集(默讣一次最大迒回的 32 条记彔) 4. Hash 冲突;寻找 key 的 slot 位置时相当亍执行了两次散列函数,一次 key 的 hash,一次 key 的 hash 值叏模, 因此返里存在两次冲突的情冴;第一种,key 的 hash 值丌同但模数相同,此时查询的时候会在比较一次 key 的 hash 值(每个索引项保存了0 码力 | 52 页 | 1.61 MB | 1 年前3
共 3 条
- 1













