关于rocketmq:RocketMQ学习一RocketMQ初探

44次阅读

共计 613 个字符,预计需要花费 2 分钟才能阅读完成。

RocketMQ 架构图

次要组件如下:
NameServer
NameServer 集群,Topic 的路由注册核心,为客户端依据 Topic 提供路由服务,从而为客户端获取对应的 Broker 进而向 Broker 发送音讯。NamerServer 将 Topic 信息保留在内存里。NameServer 之间的节点不通信,NameServer 集群里的路由信息采纳的是最终一致性。NameServer 对于 RokcetMQ 好比 ZK 对于 Kafka。
Broker
音讯存储服务器,分 Master 与 Slave,Master 承当读写操作,Slave 作为一个备份。每 30s Master 与 Slave 会向 NameServer 发送心跳包,心跳包里有 Broker 上所有的 Topic 路由信息。Broker 会将 Topic 信息长久化。
Client
音讯客户端,包含 Producer 与 Consumer。个别状况下同一时间一个客户端只会连贯一台 NameServer,只有在异样的时候才会尝试连贯另外一台。客户端每 30s 向 NamerServer 发动 Topic 的路由信息查问

音讯订阅模型

RocketMQ 音讯生产模式采纳的是公布与订阅模式。

  • Topic:一类音讯的汇合,不同类型的音讯归属于不同的主题
  • ConsumerGroup:音讯生产组,一个生产单位的汇合,生产组启动时须要订阅须要生产的 Topic。一个 Topic 能够被多个生产组订阅,同样一个生产组也能够订阅多个主题。一个生产组有多个消费者。
正文完
 0