目录

MQ作用

RocketMQ背景

MQ对比

RocketMQ环境搭建

搭建dashboard可视化界面

---

MQ作用

• 异步
• 解耦
• 削峰

RocketMQ背景

​ RocketMQ是阿里巴巴开源的一个消息中间件，在阿里内部历经了双十一等很多高并发场景的考验，能够处理亿万级别的消息。2016年开源后捐赠给Apache，现在是Apache的一个顶级项目。

​ 早期阿里使用ActiveMQ，但是，当消息开始逐渐增多后，ActiveMQ的IO性能很快达到了瓶颈。于是，阿里开始关注Kafka。但是Kafka是针对日志收集场景设计的，他的高级功能并不是很贴合阿里的业务场景。尤其当他的Topic过多时，由于Partition文件也会过多，这就会加大文件索引的耗时，会严重影响IO性能。于是阿里才决定自研中间件，最早叫做MetaQ，后来改名成为RocketMQ。最早他所希望解决的最大问题就是多Topic下的IO性能压力。但是产品在阿里内部的不断改进，RocketMQ开始体现出一些不一样的优势。

MQ对比

优点	缺点	适合场景
Apache Kafka	吞吐量非常大，性能非常好，集群高可用。	会有丢数据的可能，功能比较单一	日志分析、大数据采集
RabbitMQ	消息可靠性高，功能全面。	erlang语言不好定制。吞吐量比较低。	企业内部小规模服务调用
Apache Pulsar	基于Bookeeper构建，消息可靠性非常高。	周边生态还有差距，目前使用的公司比较少。	企业内部大规模服务调用
Apache RocketMQ	高吞吐、高性能、高可用。功能全面。客户端协议丰富。使用java语言开发，方便定制。	服务加载比较慢。	几乎全场景，特别适合金融场景

RocketMQ环境搭建

1. 安装jdk环境，配置环境变量，jdk版本1.8

2. 下载并解压rocketmq安装包，rmq版本4.9.5

 3. 由于虚拟机环境内存很小，而默认jvm内存配置太高， 调低内存（生产环境可不改）

        a 修改bin/runbroker.sh文件

        b 修改bin/runbroker.sh文件 

 4. 设置broker自动创建topic，在conf/broker.conf加如下配置

autoCreateTopicEnable=true

5. 设置环境变量NAMESRV_ADDR（非必须， 测试工具用）

通过vi ~/.bash_profile添加以下配置。然后使用source ~/.bash_profile让配置生效。

export NAMESRV_ADDR='localhost:9876' 

 6. 分别启动nameserver服务和broker服务

# 启动nameserver服务nohup bin/mqnamesrv &# 启动broker服务nohup bin/mqbroker &# 关闭nameserver服务bin/mqshutdown namesrv# 关闭broker服务bin/mqshutdown broker

jps验证是否启动成功

7. 自带tool工具测试发送&消费消息

        a 发送消息

bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

        b 消费消息

bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

搭建dashboard可视化界面

1. 去官网下载dashboard源码

2. 注释默认配置rocketmq.config.namesrvAddr， 后面可动态配置

3. 添加解析yml的maven依赖， 不然启动报错

        <dependency><groupId>org.yaml</groupId><artifactId>snakeyaml</artifactId><version>1.27</version></dependency>

4. maven打包成jar包

mvn clean package -Dmaven.test.skip=true

5. 把jar包拷贝到服务器， 并且在同级目录新建一个application.yml文件，配置namesrv地址

application.yml内容配置：

rocketmq.config.namesrvAddr: 192.168.6.128:9876

6. java -jar启动jar包

java -jar rocketmq-dashboard-1.0.0.jar

7. 访问dashboard界面