RocketMQ 5.1 安装
一、安装
1、下载 rocketmq-all-5.1.0-bin-release.zip 。
地址:https://rocketmq.apache.org/zh/download/
2、解压缩到 D:\java\rocketmq-all-5.1.0-bin-release。
3、设置环境变量。(另外需要安装jdk1.8)
新建 ROCKETMQ_HOME
在PATH里面添加 %ROCKETMQ_HOME%\bin
一、安装
1、下载 rocketmq-all-5.1.0-bin-release.zip 。
地址:https://rocketmq.apache.org/zh/download/
2、解压缩到 D:\java\rocketmq-all-5.1.0-bin-release。
3、设置环境变量。(另外需要安装jdk1.8)
新建 ROCKETMQ_HOME
在PATH里面添加 %ROCKETMQ_HOME%\bin
1、官网。http://rocketmq.apache.org/
2、文档。https://github.com/apache/rocketmq/tree/master/docs/cn
3、介绍。
RocketMQ架构上主要分为四部分,如上图所示:
Producer:消息发布的角色,支持分布式集群方式部署。Producer通过MQ的负载均衡模块选择相应的Broker集群队列进行消息投递,投递的过程支持快速失败并且低延迟。
Consumer:消息消费的角色,支持分布式集群