一:RocketMQ 简介
RocketMQ 是一款分布式、队列模型的消息中间件,具有以下特点:
- 能够保证严格的消息顺序。
- 提供丰富的消息拉取模式。
- 高效的订阅者水平扩展能力。
- 实时的消息订阅机制。
- 亿级消息堆积能力。
二:RocketMQ的安装
1.下载RocketMQ源码
下载地址 rocketmq-4.4.0
2.解压 , 进入解压目录
unzip rocketmq-all-4.2.0-source-release.zip
cd rocketmq-all-4.4.0
3.执行安装命令
mvn -Prelease-all -DskipTests clean install -U
4.安装完成后进入启动文件所在目录
cd distribution/target/apache-rocketmq
5.启动服务器, 查看启动日志
nohup sh bin/mqnamesrv &
tail -f ~/logs/rocketmqlogs/namesrv.log
6.启动broker , 查看broker启动日志
nohup sh bin/mqbroker -n localhost:9876 &
tail -f ~/logs/rocketmqlogs/broker.log
7.查看是否启动成功jps
8.停止服务,停止broker
sh bin/mqshutdown broker
sh bin/mqshutdown namesrv
8.常见问题
- JAVA_HOME 环境变量未配置,可设置RocketMQ的JDK环境 , 打开bin目录下
runserver.sh
和runbroker.sh
, 将设置JAVA_HOME的第二三行注释掉,在第一行设置JDK的安装目录。如下所示:
[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/Library/Java/JavaVirtualMachines/jdk1.8.0_181.jdk/Contents/Home
#[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/usr/java
#[ ! -e "$JAVA_HOME/bin/java" ] && error_exit "Please set the JAVA_HOME variable in your environment, We need java(x64)!