Windows下安装配置RocketMQ

    xiaoxiao2022-07-12  181

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

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

        

       

    (3)、解压到目录

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

     变量名:ROCKETMQ_HOME

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

    三、RocketMQ启动

    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基层码农,每天带你学习新知识。
    最新回复(0)