CentOS7 安装RocketMQ并使用

RocketMQ 介绍

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

安装依赖

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
  • 克隆和打包
[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
  • 启动服务
[root@linuxprobe apache-rocketmq]# nohup sh bin/mqnamesrv &
# 查看日志
[root@linuxprobe apache-rocketmq]# tail -f ~/logs/rocketmqlogs/namesrv.log
  • 启动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

从图中可以看出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...

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

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

参考链接

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏FreeBuf

FACT:一款固件类比分析测试平台

1.FACT 全称 Firmware Analysis and Comparison Tool 是一个拥有WEB端的自动化固件测试平台。

832
来自专栏哎_小羊

部署 Kubernetes 集群日志插件 Fluentd、Elasticsearch、Kibana

目录 Kubernetes 日志架构介绍 环境、软件准备 启动 Fluentd 启动 Elasticsearch 启动 Kibana 浏览器添加证书 RBAC...

1.4K9
来自专栏Ken的杂谈

Spring Cloud 入门教程5、服务容错监控:Hystrix Dashboard

上一篇我们介绍了Hystrix的基础使用,我们可以通过Hystrix做到依赖隔离和熔断等操作。但是只有工具的使用而没有监控,我们就无法在第一时间发现出现问题的依...

481
来自专栏云计算教程系列

使用Galera部署MariaDB集群

使用Galera进行MariaDB复制可为站点数据库添加冗余。通过数据库复制,多个服务器充当数据库集群。数据库群集对于高可用性网站配置特别有用。本教程使用三个单...

1064
来自专栏老安的博客

openstack octavia 简介以及手工安装过程

2332
来自专栏Jay的后台开发笔记

低成本高收益的PHP性能提升方案

OPcache通过将 PHP 脚本预编译的字节码存储到共享内存中来提升 PHP 的性能, 存储预编译字节码的好处就是 省去了每次加载和解析 PHP 脚本的开销。

1533
来自专栏GreenLeaves

邮件发送功能开发

作为一名.Net开发,"邮件发送"功能的开发和使用是必须要掌握的,因为这个功能作为“消息推送”的一种手段经常出现在各种.Net系统中,所以本文将对.Net平台下...

2137
来自专栏菩提树下的杨过

mysql benchmark基准测试

git项目地址: https://github.com/akopytov/sysbench 利用sysbench很容易对mysql做性能基准测试(当然这个工具很...

2425
来自专栏信安之路

linux下反弹shell的姿势

通常在获得webshell之后,如果是linux的服务器,一般会返回一个shell来对linux服务器做进一步的渗透,如:溢出提权、信息收集等。下面就说说lin...

950
来自专栏熊二哥

JMeter快速入门

今天的年会已过,仍然是空手而归,不过俺坚信能让生活稳定永远都是努力。由于隔壁组负责年会的抢红包项目,因而趁此机会把通过工具模拟高并发的知识补了补,通过和身边大师...

2165

扫码关注云+社区