rocket mq知识点
1 消费类型
广播消费 : 一条消息被多个消费者消费
集群消费:一个 Consumer Group 中的 Consumer 实例平均分摊消费消息。例如某个 Topic 有 9 条消息,其中一个
Consumer Group 有 3 个实例(可能是 3 个进程,或者 3 台机器) ,那么每个实例只消费其中的 3 条消息。
2 rocket mq的部署
RocketMQ 网络部署特点
Name Server 是一个几乎无状态节点,可集群部署,节点之间无任何信息同步。
Broker 部署相对复杂,Broker 分为 Master 与 Slave,一个 Master 可以对应多个 Slave,但是一个 Slave 只能
对应一个Master, Master与 Slave的对应关系通过指定相同的BrokerName, 不同的BrokerId来定义, BrokerId
为 0 表示 Master,非 0 表示 Slave。Master 也可以部署多个。每个 Broker 与 Name Server 集群中的所有节
点建立长连接,定时注册 Topic 信息到所有 Name Server。
Producer 与 Name Server 集群中的其中一个节点(随机选择)建立长连接,定期从 Name Server 取 Topic 路
由信息,并向提供 Topic 服务的 Master 建立长连接,且定时向 Master 发送心跳。Producer 完全无状态,可
集群部署。
Consumer 与 Name Server 集群中的其中一个节点(随机选择)建立长连接,定期从 Name Server 取 Topic 路
项目开源主页:https://github.com/alibaba/RocketMQ
12
由信息,并向提供 Topic 服务的 Master、Slave 建立长连接,且定时向 Master、Slave 发送心跳。Consumer
既可以从 Master 订阅消息,也可以从 Slave 订阅消息,订阅规则由 Broker 配置决定。
最新文章
- Ubuntu install Docker
- Ubuntu 上安装 MongoDB
- bat学习
- POJ 2446 最小点覆盖
- opc 方面研究
- jQuery 效果 - animate() 方法
- iOS 左右滑动 手势 响应方法
- sBPM产品介绍
- winow.open打开窗口被拦截的解决方法
- OpenGL中glRotatef()函数究竟对矩阵做了什么
- [LeetCode]题解(python):130-Surrounded Regions
- 类似的微博推断客户关系sql声明
- hdu 5016 点分治(2014 ACM/ICPC Asia Regional Xi'an Online)
- javaweb异常提示信息统一处理(使用springmvc,附源码)
- For each...in / For...in / For...of 的解释与例子
- [模板] 匈牙利算法&;&;二分图最小字典序匹配
- 为什么 EXISTS(NOT EXIST) 与 JOIN(LEFT JOIN) 的性能会比 IN(NOT IN) 好
- Android游戏引擎总汇 原文出处:http://software.intel.com/en-us/blogs/2012/03/13/game-engines-for-android?page=1
- Spark源码剖析 - SparkContext的初始化(十)_Spark环境更新
- sql中的函数