RocketMQ是阿里巴巴在2012年开发的分布式消息中间件,专为万亿级超大规模的消息处理而设计,具有高吞吐量、低延迟、海量堆积、顺序收发等特点。
2015年,RocketMQ在消息传递方面迎来了一批重量级功能发布,包括事务消息、SQL过滤、轨迹追踪、定时消息、高可用多活等,以满足阿里巴巴日益丰富的业务场景。同年,RocketMQ被捐赠给Apache基金会,并入选孵化器项目,旨在未来为更多开发者服务。
2017年从Apache基金会毕业后,RocketMQ被指定为顶级项目(TLP)。
RocketMQ基于kafka的设计使用Java重写,其架构模型如下图:
NameServer通常会有多个实例部署,各实例间相互不进行信息通讯。Broker是向每一台NameServer注册自己的路由信息,所以每一个NameServer实例上面都保存一份完整的路由信息。当某个NameServer因某种原因下线了,客户端仍然可以向其它NameServer获取路由信息。
Broker主要负责消息的存储、投递和查询以及服务高可用保证。
在 Master-Slave 架构中,Master可以部署多个,一个Master可以对应多个Slave,但是一个Slave只能对应一个Master。Master 与 Slave 的对应关系通过指定相同的BrokerName,不同的BrokerId 来定义,BrokerId为0表示Master,非0表示Slave。
生产者用来构建并传输消息到服务端的运行实体。生产者通常被集成在业务系统中,将业务消息按照要求封装成消息并发送至服务端。投递的过程支持快速失败和重试,并且支持以下几个形式:
主题是消息传输和存储的顶层容器,用于标识同一类业务逻辑的消息。 主题的作用主要如下:
队列是消息存储和传输的实际容器,也是消息的最小存储单元。队列的主要作用如下:
消息是最小数据传输单元。具备如下特点:
消息标签是RocketMQ提供的细粒度消息分类属性,可以在主题层级之下做消息类型的细分。
消息是按到达RocketMQ服务端的先后顺序存储在指定主题的多个队列中,每条消息在队列中都有一个唯一的Long类型坐标,这个坐标被定义为消息位点。
消费者中用来接收并处理消息的运行实体。消费者通常被集成在业务系统中,从服务端获取消息,并将消息转化成业务可理解的信息,供业务逻辑处理。有以下几个功能:
一条消息被某个消费者消费完成后不会立即从队列中删除,RocketMQ会基于每个消费者分组记录消费过的最新一条消息的位点,即消费位点。可以通过重置消费位点来实现一些功能,比如,业务回溯,纠正处理。
消费者分组承载多个消费行为一致的消费者的负载均衡分组。和消费者不同,消费者分组并不是运行实体,而是一个逻辑资源,通过消费者分组初始化多个消费者实现消费性能的水平扩展以及高可用容灾。在消费者分组中,统一定义以下消费行为:
订阅关系是RocketMQ系统中消费者获取消息、处理消息的规则和状态配置。
由消费者分组动态注册到服务端系统,并在后续的消息传输中按照订阅关系定义的过滤规则进行消息匹配和消费进度维护。通过配置订阅关系,可控制如下传输行为:
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。