概述
RocketMQ 是一种队列模型的消息处理平台,具有分布式、低延迟、高吞吐、高可靠和可扩展性等特点。部署 RocketMQ Operator 后,可在数据服务视图中使用 RocketMQ 功能。
RocketMQ 架构
RocketMQ 架构主要由 NameServer、Broker、Producer、Consumer 四大模块组成。
-
NameServer:是 RocketMQ 的服务注册中心,实现 Broker 管理和路由信息管理。NameServer 可以部署多个节点,节点间资源空间相互独立,且不进行信息交换。
-
Broker:实现消息存储、消息传递、消息查询以及高可用等功能。Broker 分为主节点与从节点,主节点负责处理生产者和消费者的读写操作请求,从节点负责对主节点的消息进行复制。
-
Producer:消息生产者。支持分布式集群方式部署。
-
Consumer:消息消费者。支持 push(推)、pull(拉)两种消费模式;同时也支持集群模式和广播模式对消息进行消费。
RocketMQ Operator 核心功能
下面列举了一些 RocketMQ Operator 支持的功能:
-
水平扩展:安全无缝地扩展 RocketMQ 的每个组件。
-
滚动更新:正常执行滚动更新,无需停机。
-
多集群支持:您可以使用 RocketMQ Operator 在单个 Kubernetes 集群上部署和管理多个 RocketMQ 名称服务器集群和代理集群。
-
Topic 迁移:Operator 可以在不影响业务的情况下自动将特定 Topic 从源 Broker 集群迁移到目标集群。