一、JDK安装
1、更新软件包
sudo apt-get update
2、安装openjdk
sudo apt-get install openjdk-8-jdk
3、查看安装版本号
java -version
二、rocketmq
2.1 创建目录
mkdir /opt/rocketmq
cd /opt/rocketmq/
2.2 下载 RocketMQ
wget https://dist.apache.org/repos/dist/release/rocketmq/5.3.1/rocketmq-all-5.3.1-bin-release.zip
2.3 解压并配置 RocketMQ
解压下载的 RocketMQ 包
sudo apt-get install zip
unzip rocketmq-all-5.3.1-bin-release.zip
2.4 启动 NameServer 和 Broker
进入 bin 目录,然后启动 NameServer 和 Broker
cd /opt/rocketmq/rocketmq-all-5.3.1-bin-release/bin
nohup sh mqnamesrv &
nohup sh mqbroker -n localhost:9876 &
2.5 查看端口
netstat -tuln
2.6 检查 RocketMQ 是否运行正常
你可以使用以下命令来检查 NameServer 和 Broker 是否正常运行:
tail -f ~/logs/rocketmqlogs/namesrv.log # 查看 NameServer 日志
tail -f ~/logs/rocketmqlogs/broker.log # 查看 Broker 日志
2.7 停止
停止 Broker
sh mqshutdown broker
停止 NameServer
sh mqshutdown namesrv
三、安装和配置 RocketMQ 控制台
3.1 将rocketmq-dashboard-2.0.1-SNAPSHOT.jar 包放到该目录下
cd /opt/rocketmq
mkdir rocketmq-dashboard
cd /opt/rocketmq/rocketmq-dashboard
3.2 启动服务
cd /opt/rocketmq/rocketmq-dashboard
sudo su
nohup java -jar rocketmq-dashboard-2.0.1-SNAPSHOT.jar > rocketmq-dashboard.log 2>&1 &
3.3 访问DashBoard
http://192.168.1.100:8080
四、备用指令
nohup sh mqbroker -n localhost:9876 -Djava.net.preferIPv4Stack=true &
五、修改内存大小
RocketMQ 的安装目录下有bin目录,其中包含了启动脚本。主要涉及两个脚本:runserver.sh用于启动 RocketMQ 的 Namesrv 服务,runbroker.sh用于启动 Broker 服务。
5.1 配置 Namesrv 内存
编辑runserver.sh文件,找到以下类似的配置行(通常在文件开头部分)
JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
这里的-Xms表示初始堆内存,-Xmx表示最大堆内存,-Xmn表示新生代内存大小。根据系统内存情况和业务需求调整这些值。
5.2 配置 Broker 内存
编辑runbroker.sh文件,同样找到类似的内存配置行
JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
另外还需修改一处地方的配置
JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx2g"