-
基本概念 - 分布式消息服务RocketMQ版
火水电,AZ内逻辑上再将计算、网络、存储等资源划分成多个集群。一个Region中的多个AZ间通过高速光纤相连,以满足用户跨AZ构建高可用性系统的需求。 项目 区域默认对应一个项目,这个项目由系统预置,用来隔离物理区域间的资源(计算资源、存储资源和网络资源),以默认项目为单位进行授
-
数据保护技术 - 分布式消息服务RocketMQ版
Q实例,或跨可用区(同城灾备)部署。 在单可用区或多可用区中部署实例 副本冗余 使用一主两备架构,备节点通过数据同步的方式保持数据一致。当网络发生异常或节点故障时,通过Raft协议自动切换主备关系,保持数据一致性。 - 数据持久化 业务系统日常运行中可能出现一些小概率的异常事件。
-
快速连接RocketMQ并生产消费消息 - 分布式消息服务RocketMQ版
选择“1”。 代理存储空间 选择“超高I/O 300GB”。 实例总存储空间 = 单个代理的存储空间 * 代理数量 设置实例网络环境信息,配置详情请参考表3。 表3 设置实例网络环境信息 参数 配置说明 虚拟私有云 选择已经创建好的虚拟私有云和子网。 虚拟私有云和子网在RocketMQ实例创建完成后,不支持修改。
-
购买RocketMQ实例 - 分布式消息服务RocketMQ版
和代理存储空间,您根据实际情况选择。 图3 规格测算 设置实例网络环境信息。 在“虚拟私有云”下拉列表,选择已经创建好的虚拟私有云和子网。 虚拟私有云可以为您的RocketMQ实例构建隔离的、能自主配置和管理的虚拟网络环境。 虚拟私有云和子网在RocketMQ实例创建完成后,不支持修改。
-
快速入门 - 分布式消息服务RocketMQ版
vpc_id:RocketMQ实例所在的VPC(虚拟私有云)的ID。您可以在虚拟私有云控制台查询,也可以通过查询VPC列表API查询。 subnet_id:VPC内子网的网络ID。您可以在虚拟私有云控制台查询,也可以通过查询子网列表API查询。 security_group_id:安全组ID。您可以在虚拟私有云
-
与Kafka、RabbitMQ的差异 - 分布式消息服务RocketMQ版
表1 功能差异 功能项 RocketMQ Kafka RabbitMQ 优先级队列 不支持 不支持 支持。建议优先级大小设置在0-10之间。 延迟队列 支持 不支持 不支持 死信队列 支持 不支持 支持 消息重试 支持 不支持 不支持 消费模式 支持客户端主动拉取和服务端推送两种方式
-
RocketMQ支持的监控指标 - 分布式消息服务RocketMQ版
broker_total_bytes_in_rate 网络入流量 节点每秒网络访问流入流量 单位:Byte/s >0 RocketMQ实例节点 1分钟 broker_total_bytes_out_rate 网络出流量 节点每秒网络访问流出流量 单位:Byte/s >0 RocketMQ实例节点
-
典型应用场景 - 分布式消息服务RocketMQ版
分布式消息服务RocketMQ版可以解除多个业务系统之间的耦合度,提升各系统的处理能力和响应速度。 分布式消息服务RocketMQ版提供的定时、延迟等能力,满足需要订阅通知的电商场景。 金融场景 相较于传统金融场景,互联网金融需要能及时响应互联网的快速变化。传统金融场景中共性的部分需要
-
RocketMQ业务迁移 - 分布式消息服务RocketMQ版
导入到云上RocketMQ实例中(适用于不支持通过mqadmin命令导出元数据的场景) 前提条件 配置网络环境 分布式消息服务RocketMQ版实例分内网地址以及公网地址两种网络连接方式。如果使用公网地址,则消息生产与消费客户端需要有公网访问权限,并配置如下安全组。 表1 安全组规则
-
通过Topic和Tag实现消息分类 - 分布式消息服务RocketMQ版
高效率。可以根据如下几方面判断Topic和Tag的具体使用场景: 根据消息类型判断:RocketMQ的消息可分为普通消息、顺序消息、定时/延迟消息、事务消息,不同类型的消息需要用不同的Topic来区分,无法通过Tag区分。 根据消息优先级判断:在业务中紧急程度高和紧急程度一般的消
-
成本管理 - 分布式消息服务RocketMQ版
详细介绍请参见通过成本标签维度查看成本分配。 使用成本单元进行成本分配 企业可以使用成本中心的“成本单元”来拆分公共成本。公共成本是指多个部门共享的计算、网络、存储或资源包产生的云成本,或无法直接通过企业项目、成本标签分配的云成本。这些成本不能直接归属于单一所有者,因此不能直接归属到某一类别。使
-
分布式消息服务RocketMQ版 - 分布式消息服务RocketMQ版
最大推迟时间可达到1年。同时也支持定时消息的取消。 定时消息即生产者生产消息到分布式消息服务RocketMQ版后,消息不会立即被消费,而是延迟到设定的时间点后才会发送给消费者进行消费。 支持区域: 华北-北京一 华北-北京四 华东-上海一 华东-上海二 华南-广州 西南-贵阳一 亚太-新加坡
-
创建实例 - 分布式消息服务RocketMQ版
subnet_id 是 String 子网信息。 获取方法如下:登录虚拟私有云服务的控制台界面,单击VPC下的子网,进入子网详情页面,查找网络ID。 security_group_id 是 String 指定实例所属的安全组。 获取方法如下:登录虚拟私有云服务的控制台界面,在安全组的详情页面查找安全组ID。