 消息中间件RocketMQ原理解析 - 斩秋commitLogOffset 是指这条消息在 commitLog 文件实际偏移量 (2) size 就是指消息大小 (3) 消息 tag 的哈希值 ConsumeQueue 文件组织: (1) topic queueId 来组织的,比如 TopicA 配了读写队列 0, 1,那么 TopicA 和 Queue=0 组 成一个 ConsumeQueue, TopicA 和 Queue=1 组成一个另一个 表示客户端 ….. 2. 每次心跳会更新 ClientChannelInfo 的时间戳,来表示 client 还活着 3. 注册或者更新 consumer 的订阅关系(是以 group 为单位来组织的, group 下可能有多个 订阅关系) 4. 注册 producer, 其实就是发送 producer 的 group(这个在事物消息中才有点作用) 二:ClientHouseKeepingService0 码力 | 57 页 | 2.39 MB | 1 年前3 消息中间件RocketMQ原理解析 - 斩秋commitLogOffset 是指这条消息在 commitLog 文件实际偏移量 (2) size 就是指消息大小 (3) 消息 tag 的哈希值 ConsumeQueue 文件组织: (1) topic queueId 来组织的,比如 TopicA 配了读写队列 0, 1,那么 TopicA 和 Queue=0 组 成一个 ConsumeQueue, TopicA 和 Queue=1 组成一个另一个 表示客户端 ….. 2. 每次心跳会更新 ClientChannelInfo 的时间戳,来表示 client 还活着 3. 注册或者更新 consumer 的订阅关系(是以 group 为单位来组织的, group 下可能有多个 订阅关系) 4. 注册 producer, 其实就是发送 producer 的 group(这个在事物消息中才有点作用) 二:ClientHouseKeepingService0 码力 | 57 页 | 2.39 MB | 1 年前3
 Apache RocketMQ 介绍2万亿个并发在线消息传输, 后阿里巴巴将RocketMQ捐献给Apache Incubator。 2017年9月25日 – Apache软件基金会,连同350多个开源项目的全体志愿者、开发人员、管理人员 和孵化项目组织,宣布Apache®RocketMQ™从Apache孵化器毕业成为顶级项目,这表明该项目的 区和产品已根据ASF的精英流程和原则得到了很好的管理。 现今,Apache RocketMQ在社区各方面0 码力 | 5 页 | 375.48 KB | 1 年前3 Apache RocketMQ 介绍2万亿个并发在线消息传输, 后阿里巴巴将RocketMQ捐献给Apache Incubator。 2017年9月25日 – Apache软件基金会,连同350多个开源项目的全体志愿者、开发人员、管理人员 和孵化项目组织,宣布Apache®RocketMQ™从Apache孵化器毕业成为顶级项目,这表明该项目的 区和产品已根据ASF的精英流程和原则得到了很好的管理。 现今,Apache RocketMQ在社区各方面0 码力 | 5 页 | 375.48 KB | 1 年前3
共 2 条
- 1













