目录

1.安装配置jdk8

         1.1将文件jdk-8u212-linux-x64.tar.gz上传到/root目录

        1.2.解压缩jdk压缩文件 

        1.3.配置jdk环境变量

        1.4验证jdk是否安装成功

 2.安装RocketMQ

        2.1下载rocketmq二进制文件

        2.2解压缩rocketmq文件

        2.3配置环境变量ROCKETMQ_HOME和PATH

        2.4减小rocketmq使用的内存

        2.5启动RocketMQ

        2.6RocketMQ测试需要关闭防火墙

        2.7测试步骤

        2.7.1克隆项目

        2.7.2maven打包管理界面项目

        2.7.3运行启动管理界面

        2.7.4访问管理界面

1.安装配置jdk8

         1.1将文件jdk-8u212-linux-x64.tar.gz上传到/root目录

        1.2.解压缩jdk压缩文件 

        执行解压缩命令

        # 将jdk解压到 /usr/local/ 目录
        tar -xf jdk-8u212-linux-x64.tar.gz -C /usr/local/

        # 切换到 /usr/local/ 目录, 显示列表, 查看解压缩的jdk目录
        cd /usr/local
        ls

        1.3.配置jdk环境变量

         修改 /etc/profile 配置文件, 配置环境变量

        vim /etc/profile

        # 在文件末尾添加以下内容:
        export JAVA_HOME=/usr/local/jdk1.8.0_212
        export PATH=$JAVA_HOME/bin:$PATH

        修改完后,让环境变量立即生效

        source  /etc/profile

        1.4验证jdk是否安装成功

        java -version

 2.安装RocketMQ

        2.1下载rocketmq二进制文件

        wget https://mirror.bit.edu.cn/apache/rocketmq/4.7.0/rocketmq-all-4.7.0-bin-release.zip 
 

        2.2解压缩rocketmq文件

        rocketmq解压到/usr/local/目录

        

unzip rocketmq-all-4.7.0-bin-release.zip -d /usr/local/

# 修改一下文件夹名，改成 rocketmq 方便使用
mv /usr/local/rocketmq-all-4.7.0-bin-release /usr/local/rocketmq
 

        2.3配置环境变量ROCKETMQ_HOME和PATH

vim /etc/profile

# 在文件末尾添加以下内容:
export ROCKETMQ_HOME=/usr/local/rocketmq
export PATH=$ROCKETMQ_HOME/bin:$PATH
 

修改完后,让环境变量立即生效

source  /etc/profile

        2.4减小rocketmq使用的内存

rocketmq需要启动两个服务:name server 和 broker, name server 默认配置JVM使用的内存是4G,broker默认配置JVM使用的内存是8G,内存设置的过大,可能导致开发环境中内存不足,服务无法启动,可以通过适当降低两个服务的内存解决.

早期rocketmq使用的注册中心是zookeeper,但由于它包含的功能过于强大,而rocketmq使用zookeeper包含的内容过于丰富,导致我们在使用时往往需要搭建zookeeper的服务,以致后来rocketmq自己开发了符合自己应用场景的注册服务,name server和broker

修改name server内存256m

cd /usr/local/rocketmq/

# 编辑 bin/runserver.sh
vim bin/runserver.sh

# 找到文件中下面这一行:
JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:metaspaceSize=128m -XX:MaxmetaspaceSize=320m"

# 将 -Xms4g -Xmx4g -Xmn2g 修改为 -Xms256m -Xmx256m -Xmn128m
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:metaspaceSize=128m -XX:MaxmetaspaceSize=320m"
 

修改broker内存256m

# 编辑 bin/runbroker.sh
vim bin/runbroker.sh

# 找到文件中下面这一行:
JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g"

# 将 -Xms8g -Xmx8g -Xmn4g 修改为 -Xms256m -Xmx256m -Xmn128m
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"
 

        2.5启动RocketMQ

        先启动name server

# 进入 rocketmq 目录
cd /usr/local/rocketmq/

# 启动 name server
nohup sh bin/mqnamesrv &

# 查看运行日志, 看到"The Name Server boot success."表示启动成功
tail -f ~/logs/rocketmqlogs/namesrv.log
 

再启动broker

# 启动 broker, 连接name server: localhost:9876
nohup sh bin/mqbroker -n localhost:9876 &

# 查看运行日志, 看到"The broker[......:10911] boot success."表示启动成功
tail -f ~/logs/rocketmqlogs/broker.log 
 

        2.6RocketMQ测试需要关闭防火墙

# 关闭防火墙
systemctl stop firewalld.service

# 禁止防火墙开机启动
systemctl disable firewalld.service
 

        2.7测试步骤

启动生产者发送消息,启动消费者接收消息

# 通过环境变量, 告诉客户端程序name server的地址
export NAMESRV_ADDR=localhost:9876

# 启动生产者来测试发送消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

# 启动消费者来测试接收消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
 

        2.7.1克隆项目

在开源项目 rocketmq-externals 中提供了rocketmq 的管理界面: 地址为: https://gitee.com/mirrors/RocketMQ-Externals

cd /usr/local/rocketmq/

# 克隆 rocketmq-externals 项目
git clone https://gitee.com/mirrors/RocketMQ-Externals
 

        2.7.2maven打包管理界面项目

如果没有安装maven,先执行安装maven的命令

yum install -y maven
 

打包管理界面项目 rocketmq-console,打包过程中,下载的依赖会比较多,所以时间可能比较久.

# 进入管理界面项目的文件夹
cd RocketMQ-Externals/rocketmq-console

# 执行maven 打包命令, 执行时间较长, 请耐心等待
mvn clean package -Dmaven.test.skip=true

        2.7.3运行启动管理界面

# 进入 target 目录
cd target

# 运行管理界面
nohup java -jar rocketmq-console-ng-1.0.1.jar --server.port=8080 --rocketmq.config.namesrvAddr=localhost:9876 &
 

        2.7.4访问管理界面

http://192.168.64.141:8080