MacOS RocketMQ安装

一、下载

1. 打开官网，找到下载页面 https://rocketmq.apache.org/

   

2. 下载最新版本的RocketMQ压缩包
   

3. 将下载的压缩包解压到你选择的目录

二、安装

1. 修改JVM参数

   1. 打开打开 runserver.sh 和 runbroker.sh 文件，这两个文件通常位于 bin 目录下

   2. 修改以下 JVM 参数，确保 RocketMQ 可以在你当前环境下正常运行：

      vi bin/runserver.sh
      vi bin/runbroker.sh
      

   3. 在这两个文件中，找到类似如下的 JVM 参数配置，并根据你的需求进行修改：

      JAVA_OPT="${JAVA_OPT} -server -Xms2g -Xmx2g -Xmn1g"
      

      

      

2. 启动关闭测试

   1. 进入bin目录并启动Name Server：

      nohup sh ./bin/mqnamesrv &
      #通过一下命令查看日志，确认Name Server启动成功
      cat nohup.out 或者 less nohup.out
      

      

   2. 进入bin目录并启动broker：

      1. 修改 broker配置文件

         vi ~/.bash_profile #如果你使用的是bash
         #或者
         vi ~/.zshrc #如果你使用的是zsh
         

      2. 在文末尾添加以下行：

         export NAMESRV_ADDR='localhost:9876'
         

      3. 保存关闭并刷新

         source ~/.bash_profile
         #或者
         source ~/.zshrc
         

      4. 验证是否生效

         echo $NAMESRV_ADDR
         

         

   3. 启动broker

      nohup sh bin/mqbroker &
      #查看日志
      tail -f ~/logs/rocketmqlogs/broker.log
      

      

3. 关闭测试

   1. 使用 mqshutdown 命令关闭 Name Server：

      ./bin/mqshutdown namesrv
      

      这种方式安全且正确地关闭服务，确保资源和日志记录。

      

   2. 使用 jps 和 kill 命令关闭进程：

      jps
      kill <pid> #pid为需要关闭的进程ID
      

      这种方式直接强制终止进程，可能导致资源未释放和数据丢失

   3. 关闭broker

      ./bin/mqshutdown broker
      

4. 测试收发消息

   1. 运行自带的生产者测试类

      1. 进入 RocketMQ 的安装目录下的 bin 目录。
      2. 执行生产者测试类：

      ./bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
      

      根据提示输入消息内容，并确认消息发送成功

      

   2. 运行自带的消费者测试类

      1. 进入 RocketMQ 的安装目录下的 bin 目录。

      2. 执行消费者测试类：

         ./bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
         

         等待消费者接收消息并确认消费成功。

         

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