51工具盒子一、RocketMQ简介
RocketMQ是由阿里捐赠给Apache的一款低延迟、高并发、高可用、高可靠的分布式消息中间件。经历了淘宝双十一的洗礼。RocketMQ既可为分布式应用系统提供异步解耦和削峰填谷的能力，同时也具备互联网应用所需的海量消息堆积、高吞吐、可靠重试等特性。
二、安装JDK
JDK下载地址：https://www.oracle.com/java/technologies/javase/javase8-archive-downloads.html
1、安装JDK-1.8
[root@localhost ~]# yum -y install jdk-8u202-linux-x64.rpm
2、查看是否安装成功
[root@localhost ~]# java -version
java version "1.8.0_202"
Java(TM) SE Runtime Environment (build 1.8.0_202-b08)
Java HotSpot(TM) 64-Bit Server VM (build 25.202-b08, mixed mode)
三、Centos 7.9安装RocketMQ
官网下载地址：https://rocketmq.apache.org/zh/download
1、下载依赖包
[root@localhost ~]# yum -y install wget
2、下载RocketMQ安装包
[root@localhost ~]# wget https://archive.apache.org/dist/rocketmq/4.9.6/rocketmq-all-4.9.6-bin-release.zip
3、解压安装包
[root@localhost ~]# unzip rocketmq-all-4.9.6-bin-release.zip -d /usr/local
[root@localhost ~]# mv /usr/local/rocketmq-all-4.9.6-bin-release/ /usr/local/rocketmq
4、修改broker.conf配置文件
[root@localhost ~]# cd /usr/local/rocketmq/conf
[root@localhost conf]# vim broker.conf
加入以下参数配置，192.168.56.134为本地服务器IP
namesrvAddr=192.168.56.134:9876
brokerIP1=192.168.56.134
autoCreateTopicEnable=true
5、修改runserver.sh和runbroker.sh脚本的启动参数（根据自身配置修改，这里只是为了方便演示，修改成1g）
[root@localhost conf]# cd ../bin/
[root@localhost bin]# sed -i -e 's/4g/1g/g' -e 's/2g/512m/g' runserver.sh
[root@localhost bin]# sed -i 's/8g/1g/g' runbroker.sh
6、启动RocketMQ
注：需要启动NameServer和Broker。
启动NameServer，使用jps命令看到NamesrvStartup就是启动成功了。
[root@localhost bin]# nohup ./mqnamesrv -n 192.168.56.134:9876 &
[root@localhost bin]# jps
2555 NamesrvStartup
2591 Jps
启动Broker，使用jps命令看到BrokerStartup就是启动成功了。
[root@localhost bin]# nohup ./mqbroker -n 192.168.56.134:9876 -c ../conf/broker.conf &
[root@localhost bin]# jps
2854 Jps
2555 NamesrvStartup
2751 BrokerStartup
7、测试数据发送和消费
[root@localhost bin]# export NAMESRV_ADDR=192.168.56.134:9876
[root@localhost bin]# ./tools.sh org.apache.rocketmq.example.quickstart.Producer
8、关闭RocketMQ
注：需要先关闭 Broker，然后再关闭Name Server。
[root@localhost bin]# ./mqshutdown broker
The mqbroker(2751) is running...
Send shutdown request to mqbroker(2751) OK
[root@localhost bin]# ./mqshutdown namesrv
The mqnamesrv(2555) is running...
Send shutdown request to mqnamesrv(2555) OK
[2]+ Exit 143 nohup ./mqbroker -n 192.168.56.134:9876 -c ../conf/broker.conf autoCreateTopicEnable=true
四、安装RocketMQ-Dashboard
1、下载源代码
[root@localhost ~]# wget https://github.com/apache/rocketmq-dashboard/archive/refs/tags/rocketmq-dashboard-1.0.0.zip
[root@localhost ~]# unzip rocketmq-dashboard-1.0.0.zip
2、安装Maven
[root@localhost ~]# wget https://dlcdn.apache.org/maven/maven-3/3.9.3/binaries/apache-maven-3.9.3-bin.zip
[root@localhost ~]# unzip apache-maven-3.9.3-bin.zip
[root@localhost ~]# mv apache-maven-3.9.3 /usr/local/maven
[root@localhost ~]# ln -sf /usr/local/maven/bin/mvn /usr/bin/
3、编译
[root@localhost ~]# cd rocketmq-dashboard-rocketmq-dashboard-1.0.0
[root@localhost rocketmq-dashboard-rocketmq-dashboard-1.0.0]# mvn clean package -Dmaven.test.skip=true
4、启动rocketmq-dashboard
[root@localhost rocketmq-dashboard-rocketmq-dashboard-1.0.0]# cd target
[root@localhost target]# nohup java -jar rocketmq-dashboard-1.0.0.jar &
5、访问rocketmq-dashboard
1）浏览器访问http://192.168.56.134:8080/，如下图所示
2）连接RocketMQ
3）切换中文语言
4）创建Topic
5）创建消费者组consumer
6）扩容Topic队列
7）发送消息
向指定Topic发送消息
发送结果
继续阅读
历史上的今天
7 月
5
