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

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

2.Linux环境下搭建

2.1 环境准备

Java环境

Maven环境

2.1.1 Linux环境搭建Jdk

下载JDK:https://www.oracle.com/techne...

下载需要的版本:

fad4533095f6ce8720893d2bb91b75f.png

上传到创建的目录/usr/java

解压命令
tar -zxvf jdk-8u181-linux-x64.tar.gz
配置环境变量命令
vim /etc/profile
JAVA_HOME=/usr/java/jdk1.8.0_161
JRE_HOME=/usr/java/jdk1.8.0_161/jre
CLASS_PATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar:$JRE_HOME/lib
PATH=$PATH:$JAVA_HOME/bin:$JRE_HOME/bin
export JAVA_HOME JRE_HOME CLASS_PATH PATH
source /etc/profile
验证是否成功命令
 java -version

3939bf21fd8379fb4069086e2851476.png

按照以上操作,完成JDK的安装。接下来安装Maven环境。

2.1.2 Linux环境搭建Maven

1.下载命令:

wget http://mirror.bit.edu.cn/apache/maven/binaries/apache-maven-3.2.2-bin.tar.gz

1.解压命令:

tar -zxvf apache-maven-3.2.2-bin.tar.gz

1.配置Maven环境命令:

vim /etc/profile
#配置maven环境变量
export MAVEN_HOME=/usr/maven/apache-maven-3.5.4
export MAVEN_HOME
export PATH=$PATH:$MAVEN_HOME/bin
source /etc/profile

1.验证是否成功命令:

mvn -v

31b18d64bd881137c0e9025b012ffbf.png

2.2 下载RocketMQ

1.下载命令:

wget http://mirrors.hust.edu.cn/apache/rocketmq/4.4.0/rocketmq-all-4.4.0-source-release.zip

1.解压命令:

unzip rocketmq-all-4.4.0-source-release.zip

d341ed1f69504186fc75043a574b6c0.png

1.构建二进制文件命令

进入解压后的文件目录。

mvn -Prelease-all -DskipTests clean install -U

f952f2db6dbca7f8a6e1e2d2290d53e.png

2.3 修改JVM配置

同Windows环境一样,修改JVM配置。

移动到目录 /home/rocketmq/rocketmq-all-4.4.0/distribution/target/apache-rocketmq/bin 中。编辑bin目录下runserver.sh 与 runbroker.sh文件。

根据个人虚拟机大小进行修改

vim runserver.sh 
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:PermSize=64m -XX:MaxPermSize=128m"
vim runbroker.sh
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:PermSize=64m -XX:MaxPermSize=128m"

63c00dc38989856d994ded911347902.png

2.4 配置RocketMQ环境变量

分别执行如下命令:

#修改环境变量
vim /etc/profile
export ROCKETMQ=/home/rocketmq/rocketmq-all-4.4.0/distribution/target/apache-rocketmq
export PATH=$PATH:$ROCKETMQ/bin
#更新配置
source /etc/profile

75131596cabc800d822f0f864d8c97f.png

2.5 启动NAMESERVER

依然在之前的目录 /home/rocketmq/rocketmq-all-4.4.0/distribution/target/apache-rocketmq

执行命令:

##启动命令
nohup sh bin/mqnamesrv  >/dev/null 2>&1 &
##查看日志
tail -f ~/logs/rocketmqlogs/namesrv.log

08f2d8a6ba322c53aa3756fb681faca.png

可以看图已经成功了!

2.6 启动BROKER

执行命令:

##启动命令
nohup sh bin/mqbroker -n localhost:9876 &
##查看日志
tail -f ~/logs/rocketmqlogs/broker.log

3f052ba92d42b4bf3a5a4e1cf561c1c.png

注意防火墙,如果端口连接失败,注意开通。

2.7 关闭命令

sh bin/mqshutdown broker    //停止 broker
sh bin/mqshutdown namesrv   //停止 nameserver

2.8 配置Console监控平台

同Windows平台搭建

2.8.1 启动Console

我这里直接将Windows平台打包好的jar包直接丢到了Linux系统中

  • 启动命令:
java -jar rocketmq-console-ng-1.0.1.jar

cec449efa4886b1c53bc3645dc0d5e9.png

2.8.2 访问Console管理界面

访问地址:http://192.168.220.72:8082

74d328c82055add6dcd55025de184dc.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
  • 下一篇
    无影云桌面