【RocketMQ】Mac安装【1】安装RocketMQ1下载2修改 JVM 参数3启动测试4关闭测试5启动关闭broker测试6查看版本【2】测试收发消息1运行自带的生产者测试类2运行自带的消费者测试类【3】安装 RocketMQ Dashboard 可视化1官网下载压缩包并解压2idea打开项目3启动jar包4打开浏览器输入以下地址访问 RocketMQ Dashboard【1】安装RocketMQ首先你需要安装好 Java 环境、Maven。1下载网址http://rocketmq.apache.org/dowloading/releases/ 下载 rocketmq-all-4.8.0-source-release.zip 解压。2修改 JVM 参数打开 runserver.sh 和 runbroker.sh 文件这两个文件通常位于 bin 目录下。修改以下 JVM 参数确保 RocketMQ 可以在你当前环境下正常运行vibin/runserver.shvibin/runbroker.sh在这两个文件中找到类似如下的 JVM 参数配置并根据你的需求进行修改JAVA_OPT${JAVA_OPT} -server -Xms2g -Xmx2g -Xmn1g3启动测试进入 bin 目录并启动 Name Servernohupsh./bin/mqnamesrv通过以下命令查看日志确认 Name Server 启动成功catnohup.out4关闭测试使用 mqshutdown 命令关闭 Name Server./bin/mqshutdown namesrv这种方式安全且正确地关闭服务确保资源和日志记录。如果使用jps 和 kill 命令关闭进程jpskillpid 为需要关闭的进程ID这种方式直接强制终止进程可能导致资源未释放和数据丢失。5启动关闭broker测试1修改 broker 配置文件vim~/.zshrcexportNAMESRV_ADDRlocalhost:9876# 刷新生效source~/.zshrc# 测试是否生效echo$NAMESRV_ADDR2修改broker 配置文件允许自动创建 topicopenconf/broker.conf autoCreateTopicEnabletrue3启动 Brokernohupshbin/mqbroker可以通过以下命令查看日志确认 Broker 启动成功tail-f~/logs/rocketmqlogs/broker.log4关闭 Broker ./bin/mqshutdown broker6查看版本shbin/mqbroker-v【2】测试收发消息1运行自带的生产者测试类1进入 RocketMQ 的安装目录下的 bin 目录。2执行生产者测试类./bin/tools.sh org.apache.rocketmq.example.quickstart.Producer根据提示输入消息内容并确认消息发送成功。2运行自带的消费者测试类1进入 RocketMQ 的安装目录下的 bin 目录。2执行消费者测试类./bin/tools.shorg.apache.rocketmq.example.quickstart.Consumer等待消费者接收消息并确认消费成功。【3】安装 RocketMQ Dashboard 可视化1官网下载压缩包并解压https://gitcode.com/gh_mirrors/ro/rocketmq-dashboard?utm_sourcecsdn_github_accelerator下载解压2idea打开项目修改application.yml里的端口默认的是8080改成9527打开maven关闭test执行clean和package可能会有如下报错需要手动下载代码下载地址https://github.com/yarnpkg/yarn/releases/download/v1.22.10/yarn-v1.22.10.tar.gz下载完成后放到maven本地仓库里去/Library/Java/AllenMaven/repository/com/github/eirslett/yarn/yarn-1.22.10.tar.gz此时再次打包自动安装这个包了。3启动jar包可以直接 java 启动或者使用 nohup 命令将其放到后台运行java-jartarget/rocketmq-dashboard-1.0.0.jarnohupjava-jarrocketmq-dashboard-1.0.0.jar4打开浏览器输入以下地址访问 RocketMQ Dashboardhttp://localhost:9527/