rocketmq模型
2021-09-09 16:07:22 11 举报rocketmq模型
作者其他创作
大纲/内容
nameServer1
消费者组： 同组内执行单次集群消费消息
nameServer2
名称服务集群： 高可用名称服务集群。名称服务节点间无同步，各自保存完整的broker信息。 两个功能：1.broker 注册（注册信息管理+心跳检测）;2.保存topic与broker映射关系
代理服务集群： master与slave一对多实现。master与slave相同的brokerName，不同的brokerId（0为主，非0为slave） broker与topic多对多。
2. 启动broker，注册到nameServer
producer group
生产者组： 同组内消息回查实现相同。 发送消息的原始生产者发送后奔溃，broker会请求同一生产者组其他实例实现提交或回溯消费
broker cluster
broker master2
broker discovery
producer2
broker master1
producer cluster
1. 启动nameServer，等待节点注册
rouing info
consumer2
consumer1
producer1
broker slave2
pull messagepush message
consumer group
broker slave1
3. 创建topic，心跳时发送topic和broker映射关系
sync
send message
手动创建topic
consumer cluster
name cluster
自动创建topic
nameServer3
4. 启动producer，与某个nameServer长连接，轮训从队列列表获一个队列，nameServer中获取当前topic所在的borker，与交集borker（交集：在队列中&&topic关联）建立长连接，开始发送
5. 创建consumer，（与producer相同）选择一个broker建立长连接，开始消费
0 条评论
下一页
