当前位置: 首页>后端>正文

Mac环境安装RocketMQ以及RocketMq-console

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


https://www.xamrdz.com/backend/32c1936955.html

相关文章: