说在前面的话,注意我这里先简单说明一下,看不懂没关系,如果遇到了这个异常再说这是我搭建过程中遇到的:
RocketMQ下载地址:http://rocketmq.apache.org/release_notes/release-notes-4.3.2/
RocketMQ控制台rocketmq-externals下载地址:https://github.com/apache/rocketmq-externals
切记rocketmq-externals中rocketmq-console下的pom文件里的rocketmq版本必须与开发的SpringBoot项目或者SSM项目里需要用到的rocketmq-client版本一致,否则报以下异常:
MQClientException: CODE: 17 DESC: No topic route info in name server for the topic: TOPIC_INVOICE_SYNC_DEV
1 .介绍 RocketMQ是阿里巴巴在2012年开源的分布式消息中间件,目前已经捐赠给Apache基金会,并于2016年11月成为 Apache 孵化项目。消息中间件中有两个角色:消息生产者和消息消费者。RocketMQ里同样有这两个概念,消息生产者负责创建消息并发送到RocketMQ服务器,RocketMQ服务器会将消息持久化到磁盘,消息消费者从RocketMQ服务器拉取消息并提交给应用消费。2. 特点
RocketMQ是一款分布式、队列模型的消息中间件,具有以下特点:
支持发布/订阅(Pub/Sub)和点对点(P2P)消息模型在一个队列中可靠的先进先出(FIFO)和严格的顺序传递支持拉(pull)和推(push)两种消息模式单一队列百万消息的堆积能力支持多种消息协议,如 JMS、MQTT 等分布式高可用的部署架构,满足至少一次消息传递语义提供 docker 镜像用于隔离测试和云集群部署提供配置、指标和监控等功能丰富的 DashboardRocketMQ在Windows开发环境下安装的教程,第一次了解接触RocketMQ的可能相比ActiveMQ自带的控制台Console登录略显麻烦
1. 环境需要
Windows环境、JDK1.8、Maven(我用的3.5.0)
2. Windows下RocketMQ部署和配置
(1)、RocketMQ下载地址:http://rocketmq.apache.org/release_notes/release-notes-4.3.2/
(2)、下载Binary 二进制的这个
(3)、解压到目录
(4)、配置系统环境变量:
变量名:ROCKETMQ_HOME
变量值:MQ解压路径\MQ文件夹名
1.启动NameServer
(1)、新建一个xxx.txt文件,输入命令:start mqnamesrv.cmd 保存,然后将txt文件命名为bat结尾文件
(2)、将文件放到bin目录下(E:\path\Soft\JMS\RocketMQ\RocketMQ-4.3.2\rocketmq-all-4.3.2\bin)下
(3)、然后启动caowencaoServer.bat文件,这个就是启动RocketMQ服务,显示如下图所示,表明RocketMQ启动成功,无异常
2. 启动启动Broker
Broker其实也就是类似于ActiveMQ的那种观看生成者和消费者队列信息的控制台, 只不过阿里使用SpringBoot1.4.3版本编写的,然后开源到GitHub上去了,我们下载下来,更改端口配置,然后使用Maven打成一个Jar即可,由于SpringBoot项目直接可以运行Jar,我们打成Jar包后运行即可访问
(1). 下载
地址:https://github.com/apache/rocketmq-externals.git 或者直接下载我上传的文件
(2). 下载完成之后,进入‘rocketmq-externals\rocketmq-console\src\main\resources’文件夹,打开‘application.properties’进行配置。
(3)、 新建一个xxx.txt文件,输入命令:start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true 保存,然后将txt文件命名为bat结尾文件
(4)、将文件放到bin目录下(E:\path\Soft\JMS\RocketMQ\RocketMQ-4.3.2\rocketmq-all-4.3.2\bin)下
(5)、然后启动caowencaoBroker.bat文件,这个就是启动Broker服务,显示如下图所示,表明Broker启动成功,无异常
(6)、使用Maven命令将rocketmq-console打成Jar包
进入‘E:\path\Soft\JMS\RocketMQ\rocketmq\externals\rocketmq-externals\rocketmq-console’文件夹,cmd里执行‘mvn clean package -Dmaven.test.skip=true’,编译生成。
(7)、最后一步,编译成功之后,Cmd进入‘target’文件夹,执行‘java -jar rocketmq-console-ng-1.0.0.jar’,启动‘rocketmq-console-ng-1.0.0.jar’。
(8)、测试,输入地址:http://127.0.0.1:8082
以上就是在Windows下,一般是开发环境下配置部署RocketMQ的步骤
Thinkingcao 认证博客专家 Java Spring Boot 微服务 2019年度博客之星、博客专家,专注架构、Java、Spring、SpringBoot、SpringCloud、微服务、分布式、中间件、源码分析、JVM性能调优、K8S等领域微信搜索公众号:「Thinking曹」,一个执着于架构的JAVA基层码农,每天带你学习新知识。