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 配置决定。

最新文章

  1. Ubuntu install Docker
  2. Ubuntu 上安装 MongoDB
  3. bat学习
  4. POJ 2446 最小点覆盖
  5. opc 方面研究
  6. jQuery 效果 - animate() 方法
  7. iOS 左右滑动 手势 响应方法
  8. sBPM产品介绍
  9. winow.open打开窗口被拦截的解决方法
  10. OpenGL中glRotatef()函数究竟对矩阵做了什么
  11. [LeetCode]题解(python):130-Surrounded Regions
  12. 类似的微博推断客户关系sql声明
  13. hdu 5016 点分治(2014 ACM/ICPC Asia Regional Xi'an Online)
  14. javaweb异常提示信息统一处理(使用springmvc,附源码)
  15. For each...in / For...in / For...of 的解释与例子
  16. [模板] 匈牙利算法&&二分图最小字典序匹配
  17. 为什么 EXISTS(NOT EXIST) 与 JOIN(LEFT JOIN) 的性能会比 IN(NOT IN) 好
  18. Android游戏引擎总汇 原文出处:http://software.intel.com/en-us/blogs/2012/03/13/game-engines-for-android?page=1
  19. Spark源码剖析 - SparkContext的初始化(十)_Spark环境更新
  20. sql中的函数

热门文章

  1. 启动matlab时总是直接跳转到安装界面的解决方案
  2. golang加油!
  3. Spring-Cloud-Ribbon学习笔记(一):入门
  4. 3 ansible-playbook 条件语句-外部变量使用
  5. 关于vmware虚拟机硬件里没有软盘驱动器,而操作系统里还有的解决方法
  6. 基于Schema配置切面
  7. react Context
  8. laravel 5.4 导出excel表格
  9. 【漏洞复现】Tomcat CVE-2017-12615 远程代码执行漏洞
  10. CF3A Shortest path of the king