CentOS7 安装RocketMQ并使用

àì夳堔傛蜴生んèń 2022-06-08 01:48 258阅读 0赞

# RocketMQ 介绍 #

> Apache RocketMQ™是一个开源的分布式消息传递和流数据平台。

*  RocketMQ Github： [https://github.com/apache/incubator-rocketmq/][https_github.com_apache_incubator-rocketmq]
 *  RocketMQ 文档：[http://rocketmq.apache.org/docs][http_rocketmq.apache.org_docs]

## 安装依赖 ##

> 64bit OS, Linux/Unix/Mac + 64bit OS, Linux/Unix/Mac + Maven 3.2.x + Git

*  安装相关依赖

# 安装maven
    [root@linuxprobe ~]# sudo wget http://repos.fedorapeople.org/repos/dchen/apache-maven/epel-apache-maven.repo -O /etc/yum.repos.d/epel-apache-maven.repo
    [root@linuxprobe ~]# yum install apache-maven -y
    
    # 安装git
    [root@linuxprobe ~]# yum install git -y

![install-maven][]

*  克隆和打包

[root@linuxprobe ~]# cd /opt
    [root@linuxprobe opt]# git clone -b develop https://github.com/apache/incubator-rocketmq.git
    [root@linuxprobe ~]# cd incubator-rocketmq
    [root@linuxprobe incubator-rocketmq]# mvn -Prelease-all -DskipTests clean install -U （打包过程可能会比较久）
    [root@linuxprobe incubator-rocketmq]# cd distribution/target/apache-rocketmq

![mvn-install][]

*  启动服务

[root@linuxprobe apache-rocketmq]# nohup sh bin/mqnamesrv &
    # 查看日志
    [root@linuxprobe apache-rocketmq]# tail -f ~/logs/rocketmqlogs/namesrv.log

![log-rocketmq][]

*  启动Broker

# 查看hosts解析
    [root@linuxprobe ~]# cat /etc/hosts
    127.0.0.1   localhost localhost.localdomain linuxprobe.com 
    10.1.1.87 linuxprobe.com 
    # 
    [root@linuxprobe apache-rocketmq]# nohup sh bin/mqbroker -n linuxprobe.com:9876 &
    [root@linuxprobe apache-rocketmq]# tail -f ~/logs/rocketmqlogs/broker.log

![这里写图片描述][SouthEast]

![这里写图片描述][SouthEast 1]

> 从图中可以看出Broker服务已经启动成功

*  发送和接送消息

> 提前设置环境变量：NAMESRV\_ADDR

[root@linuxprobe apache-rocketmq]# export NAMESRV_ADDR=linuxprobe.com:9876
    # 生产环境使用建议设置全局变量
    [root@linuxprobe apache-rocketmq]# sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
    SendResult [sendStatus=SEND_OK, msgId= ...
    [root@linuxprobe apache-rocketmq]# sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
    ConsumeMessageThread_%d Receive New Messages: [MessageExt...

![Producer][]

![Consumer][]

> 笔者这里执行获取消息程序的时候出现啦阻塞（暂未解决）

*  停止服务

[root@linuxprobe apache-rocketmq]# export NAMESRV_ADDR=linuxprobe.com:9876
    [root@linuxprobe apache-rocketmq]# sh bin/mqshutdown namesrv

![mqshutdown-rocketmq][]

## 参考链接 ##

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

[https_github.com_apache_incubator-rocketmq]: https://github.com/apache/incubator-rocketmq/
[http_rocketmq.apache.org_docs]: http://rocketmq.apache.org/docs
[install-maven]: /images/20220608/bcf24bfeaa5140088c3ace6f92b6f7a8.png
[mvn-install]: /images/20220608/0956b12dda564b9c822dea4b05f6d2b0.png
[log-rocketmq]: /images/20220608/6af998f057f84d51a6e237c4243643fa.png
[SouthEast]: /images/20220608/92716b721b004d1d9d35c2d03ca13cfe.png
[SouthEast 1]: /images/20220608/c3b8cbe1d6e145ccabf3eb1bda13e645.png
[Producer]: /images/20220608/3d7822af07d742aab3d856bb5d766380.png
[Consumer]: /images/20220608/fe538765fa9a4dcc8beac2542a07927f.png
[mqshutdown-rocketmq]: /images/20220608/5becfb44ea9c4852b9a425641a21238e.png
[http_rocketmq.apache.org_docs_quick-start]: http://rocketmq.apache.org/docs/quick-start/
[http_rocketmq.apache.org_docs_faq]: http://rocketmq.apache.org/docs/faq/