欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

RocketMQ:入门篇

程序员文章站 2024-03-18 23:38:28
...

RocketMQ:入门篇

    一、简介

    RocketMQ是大名鼎鼎的阿里开发的开源消息中间件,由于其高性能和可靠性,常被使用于企业的分布式架构中。

    他有着如下优点:

  1. RocketMQ原生地支持分布式,不像ActiveMQ需要zookeeper才能完成主从的搭建;
  2. RocketMQ能够承载海量的消息,并且不会导致明显的写入延迟;
  3. RocketMQ提供丰富的API,支持消息失败重试机制;
  4. RocketMQ可以保证严格的消息顺序,ActiveMQ无法保证;

    以上,使得RocketMQ在被选择时,能立于不败之地。

    二、进一步介绍

    先看这么一张图

RocketMQ:入门篇

    在JMS中,没有明确的的Group的概念,而在RocketMQ中,每一个消费者和生产者,必须要绑定一个唯一的组,如此一来,天然的实现了RocketMQ生产与消费的负载均衡。(若有九条消息,同一个组的消费者会分摊地拿到三条消息)

    在RocketMQ中,只有发布和订阅模式。

    三、RocketMQ的架构模式

    RocketMQ有几种架构方法:

  1. 单Master:顾名思义,只有一台主节点,如果宕机,服务就崩盘了。
  2. 多Master:多Master模式,可以完成消息存储的负载均衡,但是,当一台Master宕机时,该台Mater上的消息就无法被消费了。
  3. 多Master多Slave异步写入:给Master模式配Slave结点,可以完成RocketMQ的高可用,异步的写入Slave结点,性能会有所提升,但是如果宕机了,会可能存在毫秒级别的消息丢失。
  4. 多Master多Slave同步双写:同样完成高可用,采用同步双写的机制,只有当消息写入到主从结点时,才意味着一次消息写入的成功,如此一来,能绝对的保证消息的不丢失。

    四、实现双Master的环境搭建

    RocketMQ自己提供了一个NameServer,用于分布式的协调,本文会将NameServer与Broker放于一台服务器。

    第一步,修改配置文件hosts,完成IP地址的映射:

RocketMQ:入门篇

    第二步,解压安装包:

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

    第三步,修改Broker的配置文件:

RocketMQ:入门篇

    其中,需要修改的有集群名字,NameServer的地址。

    最后,修改Broker和NameServer的运行脚本,设置其中的JVM参数:

vim runbroker.sh/rumserver.sh

    再最后,依次启动NameServer和Broker,集群搭建就完成了。

    五、围观生产者和消费者的代码

    先看生产者的代码,先定义一个producer,对应一个指定的组,然后设置其NameServer的地址:

    RocketMQ:入门篇

    再然后,可以定义一个Message,有Topic,Tag作为筛选条件,设置一个Byte类型的数组,最后使用生产者发送。

    再看看消费者的代码:

RocketMQ:入门篇

    消费者同样需要设置组的名字,以及取消息是从队列头部还是尾部,NameServer的名字。最后定义消费要订阅的消息的内容,代码中可以看到有两个筛选,分别是Topic和Tag。

    不同与JMS中void类型的注册方法,RocketMQ的注册方法中存在一个返回值,用于通知消息中间件消息是否发送成功,或者通知消息中间件稍后重新发送消息。

RocketMQ:入门篇

RocketMQ:入门篇

    运行结果如上图,可以看到,生产者有些发送到Broker-a,有些发送到Broker-b,可见完成了消息生产的负载均衡。

    六、尾巴

  1. 在ActiveMQ中,是可以设置非持久化的,但是在RocketMQ中,则必须持久化;
  2. 消息重试机制的代码如下,生产者可以设置消息重试的次数以及超时重试的时间:
    RocketMQ:入门篇
相关标签: JMS RocketMQ