一、简介

二、安装配置

 

一、简介

  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

 

版权声明:本文为whych原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://www.cnblogs.com/whych/p/11173628.html