【MQ-01】RocketMQ的安装（mac/linux）

我就是我 2023-06-23 02:55 189阅读 0赞

### 前言 ###

系统：64bit OS, Linux/Unix/Mac都可安装

### 官网 ###

[http://rocketmq.apache.org/][http_rocketmq.apache.org]

### 官方快速开始文档 ###

[http://rocketmq.apache.org/docs/quick-start/][http_rocketmq.apache.org_docs_quick-start]

### 下载地址 ###

[apache.org/dyn/closer.cgi?path=rocketmq/4.2.0/rocketmq-all-4.2.0-source-release.zip][apache.org_dyn_closer.cgi_path_rocketmq_4.2.0_rocketmq-all-4.2.0-source-release.zip]

*  点击这里下载zip  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyMTA2NjQ3_size_16_color_FFFFFF_t_70]

### 安装前要求 ###

1.  **JDK 1.8+;**
2.  **Maven 3.2.x**
3.  **Git**

### 安装 ###

1.  解压刚刚下载的[zip][apache.org_dyn_closer.cgi_path_rocketmq_4.2.0_rocketmq-all-4.2.0-source-release.zip]

unzip rocketmq-all-4.2.0-source-release.zip

1.  进入目录

cd rocketmq-all-4.2.0/

1.  安装

mvn -Prelease-all -DskipTests clean install -U

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyMTA2NjQ3_size_16_color_FFFFFF_t_70 1]

*  安装完成![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyMTA2NjQ3_size_16_color_FFFFFF_t_70 2]
 *  安装完成之后的目录![在这里插入图片描述][20191217102938202.png]

1.  进入启动目录, 启动MQ

# 进入启动目录
    cd distribution/target/apache-rocketmq/
    
    # 启动MQ
    nohup sh bin/mqnamesrv &
    
    # 查看输出日志
    tail -f ~/logs/rocketmqLogs/rocketmq.log

RocketMQ 日志信息默认存放日志为：$USER\_HOME/logs/rocketmqLogs，通过改变此变量可以变更日志路径  
![在这里插入图片描述][20191217103359781.png]

### 发送或者接收消息 ###

在发送/接收消息前，我们需要告诉客户端：消息服务器的地址：端口（本地的话可以用localhost：端口）。RocketMQ提供多种方式来实现它。  
1.下面我们以命令行设置NAMESRV\_ADDR的方式来实现它。  
注意需要进入到mq目录下：`/Users/${HOME}/Desktop/develop/software/rocketmq-all-4.2.0/distribution/target/apache-rocketmq`

export NAMESRV_ADDR=localhost:9876

*  发送一条消息

➜ sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
     SendResult [sendStatus=SEND_OK, msgId= ...

*  接收一条消息

➜ sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
     ConsumeMessageThread_%d Receive New Messages: [MessageExt...

### 关闭服务器和经纪人 ###

# 关闭服务器
    Last login: Tue Dec 17 11:06:53 on ttys001
    ➜  sh bin/mqshutdown namesrv
    The mqnamesrv(2316) is running...
    Send shutdown request to mqnamesrv(2316) OK
    
    # 关闭经纪人
    ➜  sh bin/mqshutdown namesrv
    No mqnamesrv running.

*  参考文章：[https://blog.csdn.net/wd2014610/article/details/79867322][https_blog.csdn.net_wd2014610_article_details_79867322]

### 创建Topic ###

*  以下操作都基于目录`rocketmq-all-4.2.0/distribution/target/apache-rocketmq/bin`下

1.  启动broker

mqbroker -n localhost:9876

1.  创建**Topic**

*  官方文档说这样创建topc:

mqadmin updatetopic -n localhost:9876 -b localhost:10911 -t demo

![在这里插入图片描述][20191217143629343.png]

*  以上自己创建时没什么错，但是如果要结合java就会因为不能自动创建topic报错❌`org.apache.rocketmq.client.exception.MQClientException: No route info of this topic, demo`：![在这里插入图片描述][20191218133934194.png]
 *  因此，改为：

nohup sh mqbroker -n localhost:9876 autoCreateTopicEnable=true &

*  还有其他可能会报这个错，具体参考[https://blog.csdn.net/jiangyu1013/article/details/81478754][https_blog.csdn.net_jiangyu1013_article_details_81478754]

[http_rocketmq.apache.org]: http://rocketmq.apache.org/
[http_rocketmq.apache.org_docs_quick-start]: http://rocketmq.apache.org/docs/quick-start/
[apache.org_dyn_closer.cgi_path_rocketmq_4.2.0_rocketmq-all-4.2.0-source-release.zip]: https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.2.0/rocketmq-all-4.2.0-source-release.zip
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyMTA2NjQ3_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191217101804257.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyMTA2NjQ3,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyMTA2NjQ3_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20191217102715724.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyMTA2NjQ3,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyMTA2NjQ3_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20191217102822289.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyMTA2NjQ3,size_16,color_FFFFFF,t_70
[20191217102938202.png]: https://img-blog.csdnimg.cn/20191217102938202.png
[20191217103359781.png]: https://img-blog.csdnimg.cn/20191217103359781.png
[https_blog.csdn.net_wd2014610_article_details_79867322]: https://blog.csdn.net/wd2014610/article/details/79867322
[20191217143629343.png]: https://img-blog.csdnimg.cn/20191217143629343.png
[20191218133934194.png]: https://img-blog.csdnimg.cn/20191218133934194.png
[https_blog.csdn.net_jiangyu1013_article_details_81478754]: https://blog.csdn.net/jiangyu1013/article/details/81478754