RocketMQ实战（一）

野性酷女 2022-06-13 03:24 187阅读 0赞

http://www.jianshu.com/p/3afd610a8f7d

阿里巴巴有2大核心的分布式技术，一个是OceanBase，另一个就是RocketMQ。在实际项目中已经领教过RocketMQ的强大，本人计划写一个RocketMQ实战系列，将涵盖RocketMQ的简介，环境搭建，初步使用、API详解、架构分析、管理员集群操作等知识。

# What is RocketMQ? #

RocketMQ作为一款分布式的消息中间件（阿里的说法是不遵循任何规范的，所以不能完全用JMS的那一套东西来看它），经历了Metaq1.x、Metaq2.x的发展和淘宝双十一的洗礼，在功能和性能上远超ActiveMQ。

> 1.要知道RocketMQ原生就是支持分布式的，而ActiveMQ原生存在单点性。
> 
> 2.RocketMQ可以保证严格的消息顺序，而ActiveMQ无法保证！
> 
> 3.RocketMQ提供亿级消息的堆积能力，这不是重点，重点是堆积了亿级的消息后，依然保持写入低延迟！
> 
> 4.丰富的消息拉取模式（Push or Pull）
> 
> Push好理解，比如在消费者端设置Listener回调；而Pull，控制权在于应用，即应用需要主动的调用拉消息方法从Broker获取消息，这里面存在一个消费位置记录的问题（如果不记录，会导致消息重复消费）。
> 
> 5.在Metaq1.x/2.x的版本中，分布式协调采用的是Zookeeper，而RocketMQ自己实现了一个NameServer，更加轻量级，性能更好！
> 
> 6.消息失败重试机制、高效的订阅者水平扩展能力、强大的API、事务机制等等（后续详细介绍）

#     #

# 初步理解Producer/Consumer Group    #

ActiveMQ中并没有Group这个概念，而在RocketMQ中理解Group的机制很重要。

![1240][]

Group机制

> 想过没有，通过Group机制，让RocketMQ天然的支持消息负载均衡！
> 
> 比如某个Topic有9条消息，其中一个Consumer Group有3个实例（3个进程 OR 3台机器），那么每个实例将均摊3条消息！（注意RocketMQ只有一种模式，即发布订阅模式。）

#     #

# install RocketMQ #

> RocketMQ的Broker集群部署模式还挺多的，比如单Master模式、多Master模式、多Master多Slave模式（异步复制）、多Master多Slave模式（同步双写）等。明确个概念，RocketMQ Slave不可以写，可以读，类似于MySQL的主从机制。
> 
> 单Master模式：  
> 
> 
> 无需多言，一旦单个broker重启或宕机，一切都结束了！很显然，线上不可以使用。
> 
> 多Master模式：
> 
> 全是Master，没有Slave。当然，一个broker宕机了，应用是无影响的，缺点在于宕机的Master上未被消费的消息在Master没有恢复之前不可以订阅。
> 
> 多Master多Slave模式（异步复制）：
> 
> 多对Master-Slave，高可用！采用异步复制的方式，主备之间短暂延迟，MS级别。Master宕机，消费者可以从Slave上进行消费，不受影响，但是Master的宕机，会导致丢失掉极少量的消息。
> 
> 多Master多Slave模式（同步双写）：
> 
> 和上面的区别点在于采用的是同步方式，也就是在Master/Slave都写成功的前提下，向应用返回成功，可见不论是数据，还是服务都没有单点，都非常可靠！缺点在于同步的性能比异步稍低。

这里我将采用2个Master的方式进行搭建演示，会了双Master，其他的将很简单。（多Master在实际中也是非常常用的，如果并发非常大，考虑多Master多Slave模式）

![1240 1][]

双Master模式架构

> 在192.168.99.121/122机器上各一个NameServer、Master进程。

以192.168.99.121为例：

第一步，修改/etc/hosts文件

![1240 2][]

hosts配置

![1240 3][]

确保相互之间可以ping通

第二步，解压并创建存储路径

> tar -xvf alibaba-rocketmq-3.2.6.tar.gz  
> 
> 
> mkdir -p alibaba-rocketmq/store/\{commitlog,consumequeue,index\}  
>

第三步，配置文件

![1240 4][]

broker-x.properties

![1240 5][]

配置项

> 上面已经将实际中常用的配置项给出来了！

第四步，修改日志配置文件

![1240 6][]

注意到logback.\*.xml配置文件中：

![1240 7][]

需要替换$\{user.name\}

可以使用sed进行替换：

> sed -i 's\#$\{user.home\}\#/software/alibaba-rocketmq\#g' \*.xml  
>

第五步，修改启动脚本中的JVM参数

![1240 8][]

vim runbroker.sh/rumserver.sh

> 注意，在这里我将JVM的堆的初始化和最大大小统一设置为1G，并将新生代大小设置为512M。主要是考虑到我的虚拟机内存，实际上在线上是可以走默认的4G堆内存的。

第六步，启动NameServer

> nohup sh mqnamesrv &  
>

![1240 9][]

NameServer

![1240 10][]

nameserver启动日志

第七步，启动broker-X

![1240 11][]

启动broker

注意观察日志：

![1240 12][]

broker.log

![1240 13][]

进程与端口

第八步：RocketMQ Console

> 把rocketmq-console.war部署到Tomcat下即可。

![1240 14][]

解压WAR包

![1240 15][]

在解压WAR包后的CLASS下更改config.properties

![1240 16][]

好久不见，TOM猫

![1240 17][]

rocketmq管控台

> 这个管控台实际上还是比较简陋的，我们使用比较多的是mqadmin操作命令，后续会介绍。

OK，到这里，双Master的搭建已经完成了！

[1240]: /images/20220613/82dfa3ba2fa646d38acacfa1696de41a.png
[1240 1]: /images/20220613/a37700374d724a25bdf999f2549be6ee.png
[1240 2]: /images/20220613/e5f716e6c1704e38bae492724f418238.png
[1240 3]: /images/20220613/875d25cf5c53497185d826a1b0d241c4.png
[1240 4]: /images/20220613/13796d1a718a485e90bb513c33fb004f.png
[1240 5]: /images/20220613/1b0c8fcb081d4046b1260fc27d21ea85.png
[1240 6]: /images/20220613/a77a445277564e84b8f6605f7ca1e5f3.png
[1240 7]: /images/20220613/11faf80d3068453f876ad0391be0db26.png
[1240 8]: /images/20220613/05a65a492b7e4205a103a0d1703dd13d.png
[1240 9]: /images/20220613/e47725d7143642fca2667c6fc76e63fd.png
[1240 10]: /images/20220613/9412d0cf74e647eb99d2c779e3f180c0.png
[1240 11]: /images/20220613/c83772837aa646fc8391b68ae17d9971.png
[1240 12]: /images/20220613/6737739ff53e46c8b0078819a2e170c2.png
[1240 13]: /images/20220613/ac6a2d0f4c5a4f70960b0e1fea3b0fbe.png
[1240 14]: /images/20220613/38faf6a5a33b4e95bb6fc2e5e97422aa.png
[1240 15]: /images/20220613/52cead1023ac41b4ae60069762d870ab.png
[1240 16]: /images/20220613/56e31737cdda4d2ba44612ef6ba7d93c.png
[1240 17]: /images/20220613/2d249546aaa140329a31eb702cf62d94.png