RocketMQ:
为什么要使用 MQ?
因为项目比较大,做了分布式系统,所有远程服务调用请求都是同步执行经常出问题,所以
引入了 mq。
RocketMQ 由哪些角色组成,每个角色作用和特点是什么?
生产者(Producer):负责产生消息,生产者向消息服务器发送由业务应用程序系统
生成的消息。
消费者(Consumer):负责消费消息,消费者从消息服务器拉取信息并将其输入用户
应用程序。
消息服务器(Broker):是消息存储中心,主要作用是接收来自 Producer 的消息并
存储, Consumer 从这里取得消息。
名 称 服 务 器 ( NameServer ) : 用 来 保 存 Broker 相 关 Topic 等 元 信 息 并 给
Producer ,提供 Consumer 查找 Broker 信息。
RocketMQ 消费模式有几种?
消费模型由 Consumer 决定,消费维度为 Topic。
集群消费
1.一条消息只会被同 Group 中的一个 Consumer 消费
2.多个 Group 同时消费一个 Topic 时,每个 Group 都会有一个 Consumer 消费到数
据
广播消费
消息将对一 个 Consumer Group 下的各个 Consumer 实例都消费一遍。即即使这
些 Consumer 属于同一个 Consumer Group ,消息也会被 Consumer Group 中的每个
Consumer 都消费一次。