RocketMQ简介及配置
一、简介
二、安装配置
一、简介
RocketMQ为阿里的开源消息中间件,第一代的 Notify 主要使用了推模型,解决了事务消息;第二代的 MetaQ 主要使用了拉模型,解决了顺序消息和海量堆积的问题。 RocketMQ 基于长轮询的拉取方式, 兼有两者的优点 。在2017年的双十一,阿里通过RocketMQ流转的线上消息达到了万亿级,峰值tps达到5600万。
2007年Notify
2010年Napoli
2011年升级改为MetaQ
2012年做RocketMQ,随后开源
2016年进入Apache孵化
RocketMQ 是使用 Java 语言开发的,比起 Kafka 的 Scala 语言和RabbitMQ 的 Erlang 语言,更容易找到技术人员进行定制开发 。
二、安装配置
可参考官网:http://rocketmq.apache.org/docs/quick-start/
1.下载
RocketMQ的Binary版是一些编译好的jar和辅助的shell脚本,可以直接从官网找到下载链接( http://rocketmq.apache.org/dowloading/releases/),也可以下载源码自己编译。
系统要求 : 64bit 的 Linux 、 Unix 或 Mac 。 Java 版本大于等于 JDK1.8 。 如果需要从GitHub上下载源码和编译的话需要安装Maven 3.2.x和Git。
rocketmq当前最新版本为4.4,从官网下载二进制文件直接解压:
wget http://mirror.bit.edu.cn/apache/rocketmq/4.4.0/rocketmq-all-4.4.0-bin-release.zip
unzip unzip rocketmq-all-4.4.0-bin-release.zip -d /usr/local
解压出来的benchmark文件夹里包括运行benchmark 程序的脚本,bin文件夹包括一些常用的启动NameServer的脚本mqnamesrv,启动broker的脚本mqbroker,集群管理脚本mqadmin等,conf文件夹包括三种方式的broker配置文件,logback日志配置文件等。
2.启动
启动单机的消息队列服务比较简单,不需要写配置文件,只需要依次启动本机的NameServer和Broker即可。
cd /usr/local/rocketmq-all-4.4.0-bin-release/
nohup sh bin/mqnamesrv &
tail -f ~/logs/rocketmqlogs/namesrv.log 看到如下即启动成功:
The Name Server boot success…
nohup sh bin/mqbroker -n localhost:9876 &
tail -f ~/logs/rocketmqlogs/broker.log 同样能看到启动成功的日志。
3.关闭
sh bin/mqshutdown namesrv
sh bin/mqshutdown broker