MacOS RocketMQ安装
文章目录
一、下载
-  
打开官网,找到下载页面 https://rocketmq.apache.org/

 -  
下载最新版本的RocketMQ压缩包

 -  
将下载的压缩包解压到你选择的目录
 
二、安装
-  
修改JVM参数
-  
打开打开
runserver.sh和runbroker.sh文件,这两个文件通常位于bin目录下 -  
修改以下 JVM 参数,确保 RocketMQ 可以在你当前环境下正常运行:
vi bin/runserver.sh vi bin/runbroker.sh -  
在这两个文件中,找到类似如下的 JVM 参数配置,并根据你的需求进行修改:
JAVA_OPT="${JAVA_OPT} -server -Xms2g -Xmx2g -Xmn1g"

 
 -  
 -  
启动关闭测试
-  
进入bin目录并启动Name Server:
nohup sh ./bin/mqnamesrv & #通过一下命令查看日志,确认Name Server启动成功 cat nohup.out 或者 less nohup.out
 -  
进入bin目录并启动broker:
-  
修改 broker配置文件
vi ~/.bash_profile #如果你使用的是bash #或者 vi ~/.zshrc #如果你使用的是zsh -  
在文末尾添加以下行:
export NAMESRV_ADDR='localhost:9876' -  
保存关闭并刷新
source ~/.bash_profile #或者 source ~/.zshrc -  
验证是否生效
echo $NAMESRV_ADDR
 
 -  
 -  
启动broker
nohup sh bin/mqbroker & #查看日志 tail -f ~/logs/rocketmqlogs/broker.log
 
 -  
 -  
关闭测试
-  
使用
mqshutdown命令关闭 Name Server:./bin/mqshutdown namesrv这种方式安全且正确地关闭服务,确保资源和日志记录。

 -  
使用
jps和kill命令关闭进程:jps kill <pid> #pid为需要关闭的进程ID这种方式直接强制终止进程,可能导致资源未释放和数据丢失
 -  
关闭broker
./bin/mqshutdown broker 
 -  
 -  
测试收发消息
-  
运行自带的生产者测试类
- 进入 RocketMQ 的安装目录下的 
bin目录。 - 执行生产者测试类:
 
./bin/tools.sh org.apache.rocketmq.example.quickstart.Producer根据提示输入消息内容,并确认消息发送成功

 - 进入 RocketMQ 的安装目录下的 
 -  
运行自带的消费者测试类
-  
进入 RocketMQ 的安装目录下的
bin目录。 -  
执行消费者测试类:
./bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer等待消费者接收消息并确认消费成功。

参考博客:https://blog.csdn.net/zhiyikeji/article/details/140911649
 
 -  
 
 -  
 










