前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >CentOS7 安装RocketMQ并使用

CentOS7 安装RocketMQ并使用

作者头像
shaonbean
发布2018-01-02 11:06:47
2.2K0
发布2018-01-02 11:06:47
举报
文章被收录于专栏:运维前线运维前线

RocketMQ 介绍

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

安装依赖

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

  • 安装相关依赖
代码语言:javascript
复制
# 安装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
install-maven
  • 克隆和打包
代码语言:javascript
复制
[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
mvn-install
  • 启动服务
代码语言:javascript
复制
[root@linuxprobe apache-rocketmq]# nohup sh bin/mqnamesrv &
# 查看日志
[root@linuxprobe apache-rocketmq]# tail -f ~/logs/rocketmqlogs/namesrv.log
log-rocketmq
log-rocketmq
  • 启动Broker
代码语言:javascript
复制
# 查看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
这里写图片描述
这里写图片描述
这里写图片描述
这里写图片描述

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

  • 发送和接送消息

提前设置环境变量:NAMESRV_ADDR

代码语言:javascript
复制
[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
Producer
Consumer
Consumer

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

  • 停止服务
代码语言:javascript
复制
[root@linuxprobe apache-rocketmq]# export NAMESRV_ADDR=linuxprobe.com:9876
[root@linuxprobe apache-rocketmq]# sh bin/mqshutdown namesrv
mqshutdown-rocketmq
mqshutdown-rocketmq

参考链接

本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • RocketMQ 介绍
    • 安装依赖
      • 参考链接
      领券
      问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档