重大发现!消息中间件——RocketMQ(一) 环境搭建(完整版)上

本文涉及的产品
云原生网关 MSE Higress,422元/月
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
性能测试 PTS,5000VUM额度
简介: 重大发现!消息中间件——RocketMQ(一) 环境搭建(完整版)上

每章一点正能量:自我控制是最强者的本能。——萧伯纳

前言

最近在学习消息中间件——RocketMQ,打算把这个学习过程记录下来。此章主要介绍环境搭建。此次主要是单机搭建(条件有限),包括在Windows、Linux环境下的搭建,以及console监控平台搭建,最后加一demo验证一下。

环境准备

在搭建RocketMQ之前,请先确保如下环境已经搭建完毕

Java环境(我的JDK1.8)

Maven环境(我的3.6.1目前最新版)

Git环境

没有搭建的同学走传送门:

JDK环境搭建: JAVA8环境搭建

Maven环境搭建: Windows环境下使用Nexus 3.X 搭建Maven私服及使用介绍

Git环境搭建:Git环境搭建及配置

1. Windows环境下搭建

1.1 下载

官方网站:http://rocketmq.apache.org/

6051edbf9573ffda5b4cbb56b2a5c0a.png

目前最新版的是V4.5.0,点击进去。

3ad8bc83f2a39004f375bf10073e97e.png

选择下载 rocketmq-all-4.5.0-bin-release.zip。弹出另外一个页面,这里选择rocketmq-all-4.5.0-bin-release.zip进行下载。

5e89cc079a668efc2a77f5c41891b22.png

下载成功后,选择一个目录放好并解压。

d7b872a12a8228b82da6a8de5e61919.png

1.2 修改JVM配置

以上操作完毕之后,进入目录bin目录,我这里是

H:\rocketmq\rocketmq-all-4.5.0-bin-release\rocketmq-all-4.5.0-bin-release\bin。

找到runserver.cmd和runbroker.cmd中的JAVA_OPT。

e6256df59376c5a29cab9bea5f7afe9.png

原JAVA_OPT:

set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

将 Xms Xmx 这两个值改小一些,改为1g,如:

set "JAVA_OPT=%JAVA_OPT% -server -Xms1g -Xmx1g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
自己根据虚拟机内存大小设置,超出内存大小可能会报错。

1.3 配置环境变量

上述步骤执行完毕后,我们需要将RocketMQ安装目录的bin目录配置到环境变量中。

2dfd1d473d1a15f2d753e7d572e3538.png

1.4 启动

以上配置都完成,接下来就是启动过程。中间有点坑,请务必按步骤安装。

在RocketMQ安装目录的bin目录下,执行命令cmd:

我的目录:

H:\rocketmq\rocketmq-all-4.5.0-bin-release\rocketmq-all-4.5.0-bin-release\bin

可以通过shift+鼠标右击 触发cmd窗口选项。也可以通过win+R 在窗口输入cmd,进入cmd窗口后移动到bin目录下。

1.4.1 启动NAMESERVER

执行命令:start mqnamesrv.cmd

成功后会弹出提示框,此框勿关闭。

5a804c6c007c6ac8e842bd26d9ca7dc.png

1.4.3 启动BROKER

执行命令:‘start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true’

注意:假如弹出提示框提示‘错误: 找不到或无法加载主类 xxxxxx’。打开runbroker.cmd,然后将‘%CLASSPATH%’加上英文双引号。

2722d82a65ca104811484872a212a21.png

打开 runbroker.cmd 进行修改

原:

set "JAVA_OPT=%JAVA_OPT% -cp %CLASSPATH%"

修改后:

set "JAVA_OPT=%JAVA_OPT% -cp "%CLASSPATH%""

2533def0e359bbd62455d965f81cdf8.png

再次执行命令:

启动成功!

0b2041b4721020dd9caf1daa20ee6a1.png

这时候一共有三个窗口。

2. 安装Console监控

2.1 下载

下载地址:https://github.com/apache/roc...

下载完后如图所示:选择——>rocketmq-console

ec7fc5f7781a10170db9b3f966e49a3.png

2.2 配置

下载完成之后,进入‘rocketmq-externalsrocketmq-consolesrcmainresources’文件夹,打开‘application.properties’进行配置。

6d2504ee6f8fadf1805b92e7727ebab.png

3fc0b2b87b879043e032fbe23e7bbec.png

2.2 编译启动

进入‘rocketmq-externalsrocketmq-console’文件夹,执行‘mvn clean package -Dmaven.test.skip=true’,编译生成。中间有个比较慢的下载过程需要等待。

ca68b601ac9fc0375891c3ca693b653.png

编译成功之后,cmd进入‘target’文件夹,执行‘java -jar rocketmq-console-ng-1.0.1.jar’,启动‘rocketmq-console-ng-1.0.1.jar’。

2c1cd4c0a0dd9cf52d8eab15038aca7.png

1abac72240d1adf21ad8163f9e11bf5.png

2.3 查看

访问地址:localhost:8082

5c897c81f4d5e44557aa5921101b600.png

相关实践学习
消息队列RocketMQ版:基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能,涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
29天前
|
消息中间件 存储 Java
RocketMQ(一):消息中间件缘起,一览整体架构及核心组件
【10月更文挑战第15天】本文介绍了消息中间件的基本概念和特点,重点解析了RocketMQ的整体架构和核心组件。消息中间件如RocketMQ、RabbitMQ、Kafka等,具备异步通信、持久化、削峰填谷、系统解耦等特点,适用于分布式系统。RocketMQ的架构包括NameServer、Broker、Producer、Consumer等组件,通过这些组件实现消息的生产、存储和消费。文章还提供了Spring Boot快速上手RocketMQ的示例代码,帮助读者快速入门。
|
2月前
|
消息中间件 存储 RocketMQ
消息中间件-RocketMQ技术(二)
消息中间件-RocketMQ技术(二)
|
2月前
|
消息中间件 存储 中间件
消息中间件-RocketMQ技术(一)
消息中间件-RocketMQ技术(一)
|
1月前
|
消息中间件 编解码 Docker
【Docker项目实战】Docker部署RabbitMQ消息中间件
【10月更文挑战第8天】Docker部署RabbitMQ消息中间件
93 1
【Docker项目实战】Docker部署RabbitMQ消息中间件
|
22天前
|
消息中间件 存储 Java
吃透 RocketMQ 消息中间件,看这篇就够了!
本文详细介绍 RocketMQ 的五大要点、核心特性及应用场景,涵盖高并发业务场景下的消息中间件关键知识点。关注【mikechen的互联网架构】,10年+BAT架构经验倾囊相授。
吃透 RocketMQ 消息中间件,看这篇就够了!
|
3月前
|
消息中间件 Java 测试技术
消息中间件RabbitMQ---SpringBoot整合RabbitMQ【三】
这篇文章是关于如何在SpringBoot应用中整合RabbitMQ的消息中间件。内容包括了在SpringBoot项目中添加RabbitMQ的依赖、配置文件设置、启动类注解,以及如何通过单元测试来创建交换器、队列、绑定,并发送和接收消息。文章还介绍了如何配置消息转换器以支持对象的序列化和反序列化,以及如何使用注解`@RabbitListener`来接收消息。
消息中间件RabbitMQ---SpringBoot整合RabbitMQ【三】
|
6月前
|
消息中间件 存储 负载均衡
消息中间件的选择:RabbitMQ是一个明智的选择
消息中间件的选择:RabbitMQ是一个明智的选择
112 0
|
5月前
|
消息中间件 存储 中间件
【消息中间件】详解三大MQ:RabbitMQ、RocketMQ、Kafka
【消息中间件】详解三大MQ:RabbitMQ、RocketMQ、Kafka
1427 0
|
4月前
|
消息中间件 编解码 Docker
Docker部署RabbitMQ消息中间件
【7月更文挑战第4天】Docker部署RabbitMQ消息中间件
277 3
|
3月前
|
消息中间件 Docker 容器
消息中间件RabbitMQ---Docker安装RabbitMQ、以及RabbitMQ的基本使用【二】
这篇文章提供了RabbitMQ的安装和基本使用教程,包括如何使用Docker拉取RabbitMQ镜像、创建容器、通过浏览器访问管理界面,以及如何创建交换机、队列、绑定和使用direct、fanout和topic三种类型的交换器进行消息发布和接收的测试。
消息中间件RabbitMQ---Docker安装RabbitMQ、以及RabbitMQ的基本使用【二】

相关产品

  • 云消息队列 MQ
  • 下一篇
    无影云桌面