说在前面的话,注意我这里先简单说明一下,看不懂没关系,如果遇到了这个异常再说这是我搭建过程中遇到的:

     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

一、RocketMQ简介   

1 .介绍
       
RocketMQ是阿里巴巴在2012年开源的分布式消息中间件,目前已经捐赠给Apache基金会,并于2016年11月成为 Apache 孵化项目。消息中间件中有两个角色:消息生产者和消息消费者。RocketMQ里同样有这两个概念,消息生产者负责创建消息并发送到RocketMQ服务器,RocketMQ服务器会将消息持久化到磁盘,消息消费者从RocketMQ服务器拉取消息并提交给应用消费。
2. 特点

     RocketMQ是一款分布式、队列模型的消息中间件,具有以下特点:

  • 支持发布/订阅(Pub/Sub)和点对点(P2P)消息模型
  • 在一个队列中可靠的先进先出(FIFO)和严格的顺序传递
  • 支持拉(pull)和推(push)两种消息模式
  • 单一队列百万消息的堆积能力
  • 支持多种消息协议,如 JMS、MQTT 等
  • 分布式高可用的部署架构,满足至少一次消息传递语义
  • 提供 docker 镜像用于隔离测试和云集群部署
  • 提供配置、指标和监控等功能丰富的 Dashboard

二、RocketMQ配置  

     RocketMQ在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 二进制的这个

    Windows下安装配置RocketMQ

   

(3)、解压到目录

Windows下安装配置RocketMQ

(4)、配置系统环境变量:

 变量名:ROCKETMQ_HOME

 变量值:MQ解压路径\MQ文件夹名

Windows下安装配置RocketMQ

三、RocketMQ启动

1.启动NameServer

  (1)、新建一个xxx.txt文件,输入命令:start mqnamesrv.cmd 保存,然后将txt文件命名为bat结尾文件Windows下安装配置RocketMQ

(2)、将文件放到bin目录下(E:\path\Soft\JMS\RocketMQ\RocketMQ-4.3.2\rocketmq-all-4.3.2\bin)下

Windows下安装配置RocketMQ

(3)、然后启动caowencaoServer.bat文件,这个就是启动RocketMQ服务,显示如下图所示,表明RocketMQ启动成功,无异常

Windows下安装配置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’进行配置。

Windows下安装配置RocketMQ

(3)、 新建一个xxx.txt文件,输入命令:start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true 保存,然后将txt文件命名为bat结尾文件

Windows下安装配置RocketMQ

(4)、将文件放到bin目录下(E:\path\Soft\JMS\RocketMQ\RocketMQ-4.3.2\rocketmq-all-4.3.2\bin)下

Windows下安装配置RocketMQ

(5)、然后启动caowencaoBroker.bat文件,这个就是启动Broker服务,显示如下图所示,表明Broker启动成功,无异常Windows下安装配置RocketMQ

 

(6)、使用Maven命令将rocketmq-console打成Jar包

进入‘E:\path\Soft\JMS\RocketMQ\rocketmq\externals\rocketmq-externals\rocketmq-console’文件夹,cmd里执行‘mvn clean package -Dmaven.test.skip=true’,编译生成。

Windows下安装配置RocketMQ

(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

Windows下安装配置RocketMQ

以上就是在Windows下,一般是开发环境下配置部署RocketMQ的步骤

相关文章:

  • 2022-12-23
  • 2021-04-19
  • 2021-09-25
  • 2021-10-25
  • 2021-04-29
  • 2021-08-09
  • 2021-08-03
猜你喜欢
  • 2021-08-22
  • 2022-01-12
  • 2021-07-04
  • 2021-10-04
  • 2022-12-23
  • 2021-05-24
  • 2021-10-10
相关资源
相似解决方案