1. 安装 Rocketmq
下载地址:https://rocketmq.apache.org/dowloading/releases/
2. 修改配置
- 在bin目录下修改文件runserver.sh,修改下面这部分配置,将:
JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
修改为:
AVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
- 在bin目录下修改文件runbroker.sh,修改下面这部分配置,将:
JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g"
修改为:
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m"
- 在conf目录下修改文件broker.conf,添加下面这部分配置:
# 添加如下配置
brokerIP1 = 127.0.0.1
brokerIP2 = 127.0.0.1
namesrvAddr = 127.0.0.1:9876
3. 添加java_home路径配置
由于在启动nameServer和broker时报错提示:
Please set the JAVA_HOME variable in your [environment](https://so.csdn.net/so/search?q=environment&spm=1001.2101.3001.7020), We need java(x64)
解决方法:
在上面runserver.sh和runbroker.sh两个文件修改:
[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=$HOME/jdk/java
[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/usr/java
[ ! -e "$JAVA_HOME/bin/java" ] && error_exit "Please set the JAVA_HOMEvariable in your environment, We need java(x64)!"
修改为:(注释后两行,第一行$HOME/jdk/java改为自己配置的JAVA_HOME路径)
[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/Library/Java/JavaVirtualMachines/....1.8.jdk/Contents/Home
#[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/usr/java
#[ ! -e "$JAVA_HOME/bin/java" ] && error_exit "Please set the JAVA_HOMEvariable in your environment, We need java(x64)!"
注意:java_home路径查询命令:
1./usr/libexec/java_home
查询出的路径在我mac环境下路径也有问题(/Library/Internet Plug-Ins/JavaAppletPlugin.plugin/Contents/Home
)
2.建议使用/usr/libexec/java_home -V
查询出完整、详细信息(/Library/Java/JavaVirtualMachines/jdk1.8.0_311.jdk/Contents/Home
)
到此nameServer和broker都可以跑起来了,如果发送消息的时候发现又提示错误信息,说明在其他文件地方也需要配置java_home路径(比如startfsrv.sh、tools.sh文件)
4. 启动 Rocketmq
启动mqnamesrv:
nohup sh ./mqnamesrv &
再启动mqbroker :
nohup sh ./mqbroker -n localhost:9876 &
查看启动日志:
cat nohup.out
5. 关闭 Rocketmq
停止mqbroker
sh ./mqshutdown broker
停止mqnamesrv
sh ./mqshutdown namesrv
6. 启动Rocketmq的web控制台
下载地址:https://github.com/apache/rocketmq-externals/releases/tag/rocketmq-console-1.0.0
修改配置文件application.porperties
添加端口以及namesrv
server.port = 8080
rocketmq.config.namesrvAddr = 127.0.0.1:9876
最后启动项目即可
- 直接运行App启动类
- 控制台命令启动
mvn clean package -Dmaven.test.skip=true
java -jar target/rocketmq-console-ng-1.0.0.jar
访问localhost:8080