Mac 安装 Rocketmq

1.首先要保证已经安装好了jdk,并配置好了环境变量

1.1 查看jdk安装目录

java_home -V
/usr/libexec/java_home -V
Matching Java Virtual Machines (1):
    1.8.0_282 (arm64) "Azul Systems, Inc." - "Zulu 8.52.0.23" /Library/Java/JavaVirtualMachines/zulu-8.jdk/Contents/Home
/Library/Java/JavaVirtualMachines/zulu-8.jdk/Contents/Home
lqq@LQQdeMacBook-Pro bin % 

1.2 打开环境变量文件

open -e .bash_profile

编辑环境变量内容

JAVA_HOME=/Library/Java/JavaVirtualMachines/zulu-8.jdk/Contents/Home
PATH=$JAVA_HOME/bin:$PATH:.
CLASSPATH=$JAVA_HOME/lib/tools.jar:$JAVA_HOME/lib/dt.jar:.
export JAVA_HOME
export PATH
export CLASSPATH

1.3 刷新环境变量

source .bash_profile

2.安装 Rocketmq

官网下载地址
在这里插入图片描述
我这里直接下载4.8 Binary

3.修改配置

下载完后,打开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"

参数介绍:
-Xmx4g 初始堆大小 4g
-Xms4g 最大堆大小4g
-Xmn512m 年轻代大小(1.4or lator)整个JVM内存大小=年轻代大小 + 年老代大小 + 持久代大小。持久代一般固定大小为64m,所以增大年轻代后,将会减小年老代大小。此值对系统性能影响较大,Sun官方推荐配置为整个堆的3/8

4.启动 Rocketmq

启动mqnamesrv:

nohup sh ./mqnamesrv &

再启动mqbroker :

nohup sh ./mqbroker -n localhost:9876 &

查看启动日志:

cat nohup.out

在这里插入图片描述
我这边一开始查看日志发现报错:ERROR:Please set the JAVA_HOME…然后又修改了下面配置才成功启动,如果没有报错启动成功跳过下面一步。

上面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/zulu-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)!"

5.关闭 Rocketmq

停止mqbroker

sh ./mqshutdown broker

停止mqnamesrv

sh ./mqshutdown namesrv

6.可以通过启动Rocketmq的web控制台

6.1 从github上拉取rocketmq-console-ng相关代码并启动

在这里插入图片描述

6.2 启动rocketmq-console-ng

在这里插入图片描述

6.3 访问:localhost:8080

可查询生产者消费者队列以及主题信息等

在这里插入图片描述

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐