What is RocketMQ?
RocketMQ作为一款分布式的消息中间件(阿里的说法是不遵循任何规范的,所以不能完全用JMS的那一套东西来看它),经历了Metaq1.x、Metaq2.x的发展和淘宝双十一的洗礼,在功能和性能上远超ActiveMQ。
ActiveMQ中并没有Group这个概念,而在RocketMQ中理解Group的机制很重要。
Group机制
想过没有,通过Group机制,让RocketMQ天然的支持消息负载均衡!
比如某个Topic有9条消息,其中一个Consumer Group有3个实例(3个进程 OR 3台机器),那么每个实例将均摊3条消息!(注意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模式)
双Master模式架构
在192.168.99.121/122机器上各一个NameServer、Master进程。
以192.168.99.121为例:
hosts配置
确保相互之间可以ping通
tar -xvf alibaba-rocketmq-3.2.6.tar.gz
mkdir -p alibaba-rocketmq/store/{commitlog,consumequeue,index}
broker-x.properties
上面已经将实际中常用的配置项给出来了!
配置项
注意到logback.*.xml配置文件中:
需要替换${user.name}
可以使用sed进行替换:
sed -i 's#${user.home}#/software/alibaba-rocketmq#g' *.xml
vim runbroker.sh/rumserver.sh
注意,在这里我将JVM的堆的初始化和最大大小统一设置为1G,并将新生代大小设置为512M。主要是考虑到我的虚拟机内存,实际上在线上是可以走默认的4G堆内存的。
nohup sh mqnamesrv &
NameServer
nameserver启动日志
启动broker
注意观察日志:
broker.log
进程与端口
把rocketmq-console.war部署到Tomcat下即可。
解压WAR包
在解压WAR包后的CLASS下更改config.properties
这个管控台实际上还是比较简陋的,我们使用比较多的是mqadmin操作命令,后续会介绍。
OK,到这里,双Master的搭建已经完成了!
(未完待续)