RocketMq
-
- 一: RocketMq是什么?
-
-
-
- 1) Name Server
- 2) Broker
- 3) Producer
- 4) Consumer
-
-
- 二: RocketMq安装过程?
- 三: RocketMq安装过程中遇到的问题?
- 四:怎么关闭Name server和broker?
- 五: 大神链接
一: RocketMq是什么?
RocketMq是一个消息中间件,和 kafka,RabbitMq 一样,类似一个装零食的篮子,我们(生产者)向篮子上放零食(消息),其他人或者自己(消费者)再从篮子上往下取零食,这样,就算你放好多零食,我只拿我能吃得下的,保证自己不会撑破肚皮就好,而且,如果篮子装满了,还可以再加几个篮子,这就是集群,零食有好多种类,那每种零食都是一条主题(topic)
推荐一篇博客(解释得很到位)
1) Name Server
Name Server是一个几乎无状态节点,可集群部署,节点之间无任何信息同步。
2) Broker
Broker分为Master与Slave,一个Master可以对应多个Slave,但是一个Slave只能对应一个Master,(就类似于做单机demo时咱们自己的电脑)
3) Producer
Producer与Name Server集群中的其中一个节点(随机选择)建立长连接,定期从Name Server取Topic路由信息(获取~就比如我这个生产者需要生产哪几个主题的消息,这几个主题的消息我又发到那几个broker上呢?),并向提供Topic服务的Master(需要操作的broker下的Master)建立长连接,且定时向Master发送心跳。Producer完全无状态,可集群部署。
4) Consumer
Consumer与Name Server集群中的其中一个节点(随机选择)建立长连接,定期从Name Server取Topic路由信息,并向提供Topic服务的Master、Slave建立长连接,且定时向Master、Slave发送心跳。Consumer既可以从Master订阅消息,也可以从Slave订阅消息,订阅规则由Broker配置决定。
二: RocketMq安装过程?
1-1 下载RocketMq:
下载地址:http://rocketmq.apache/release_notes/release-notes-4.3.0/
RocketMq
-
- 一: RocketMq是什么?
-
-
-
- 1) Name Server
- 2) Broker
- 3) Producer
- 4) Consumer
-
-
- 二: RocketMq安装过程?
- 三: RocketMq安装过程中遇到的问题?
- 四:怎么关闭Name server和broker?
- 五: 大神链接
一: RocketMq是什么?
RocketMq是一个消息中间件,和 kafka,RabbitMq 一样,类似一个装零食的篮子,我们(生产者)向篮子上放零食(消息),其他人或者自己(消费者)再从篮子上往下取零食,这样,就算你放好多零食,我只拿我能吃得下的,保证自己不会撑破肚皮就好,而且,如果篮子装满了,还可以再加几个篮子,这就是集群,零食有好多种类,那每种零食都是一条主题(topic)
推荐一篇博客(解释得很到位)
1) Name Server
Name Server是一个几乎无状态节点,可集群部署,节点之间无任何信息同步。
2) Broker
Broker分为Master与Slave,一个Master可以对应多个Slave,但是一个Slave只能对应一个Master,(就类似于做单机demo时咱们自己的电脑)
3) Producer
Producer与Name Server集群中的其中一个节点(随机选择)建立长连接,定期从Name Server取Topic路由信息(获取~就比如我这个生产者需要生产哪几个主题的消息,这几个主题的消息我又发到那几个broker上呢?),并向提供Topic服务的Master(需要操作的broker下的Master)建立长连接,且定时向Master发送心跳。Producer完全无状态,可集群部署。
4) Consumer
Consumer与Name Server集群中的其中一个节点(随机选择)建立长连接,定期从Name Server取Topic路由信息,并向提供Topic服务的Master、Slave建立长连接,且定时向Master、Slave发送心跳。Consumer既可以从Master订阅消息,也可以从Slave订阅消息,订阅规则由Broker配置决定。
二: RocketMq安装过程?
1-1 下载RocketMq:
下载地址:http://rocketmq.apache/release_notes/release-notes-4.3.0/