kafka

rocketmq整体架构

2018-08-13  本文已影响0人  划水者

rocketmq整体包含4个模块

1 nameServer 命名服务器,类似zk
2 broker 代理服务器,存储消息
3 producer 消息发送者
4 consumer 消息消费者

整体架构图


image

各模块之间的关系分析
nameServer 轻量级的注册中心,broker,producer,consumer可以到nameServer注册信息

broker 用于存储消息,启动后,和集群中所有的nameServer服务器建立长连接,注册topic信息,broker集群可用的地址等

producer 发送者,启动后和集群中一台可用的nameServer建立长连接,从nameServer中获取发送该topic下消息相关的broker地址,并和这些所有相关的broker机器建立长连接

consumer 消费者,启动后和集群中一台可用的nameServer建立长连接,从nameServer中获取订阅该topic相关的broker地址,并和这些所有相关的broker地址建立长连接

上一篇下一篇

猜你喜欢

热点阅读