-
成本管理 - 分布式消息服务RocketMQ版
企业可以使用成本中心的“成本单元”来拆分公共成本。公共成本是指多个部门共享的计算、网络、存储或资源包产生的云成本,或无法直接通过企业项目、成本标签分配的云成本。这些成本不能直接归属于单一所有者,因此不能直接归属到某一类别。使用拆分规则,可以在各团队或业务部门之间公平地分配这些成本。详细介绍请参见使用成本单元查看成本分配。
-
新建元数据迁移任务 - 分布式消息服务RocketMQ版
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
-
构造请求 - 分布式消息服务RocketMQ版
"domain_id": "accountid", "name": "username", "password": "**********", "email": "email", "description":
-
收发顺序消息 - 分布式消息服务RocketMQ版
' msgId: ' + ret.msg_id) producer.shutdown() if __name__ == '__main__': send_orderly_with_sharding_key() 示例代码中的参数说明如下,请参考收集连接信息获取参数值。
-
收发普通消息 - 分布式消息服务RocketMQ版
' msgId: ' + ret.msg_id) producer.shutdown() if __name__ == '__main__': send_message_sync() 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 topic:表示Topic名称。
-
通过消息幂等实现消息去重 - 分布式消息服务RocketMQ版
消费者消费消息时,服务端将消息投递至消费者并完成业务处理。如果此时发生网络闪断,导致消费者提交offset失败,服务端的offset未及时更新,此时服务端会认为消息投递失败。为了保证消息至少被消费一次,服务端会尝试投递之前已被处理过的消息,最终消费者就会收到与之前处理过的Message
-
支持多少个消费组个数? - 分布式消息服务RocketMQ版
x基础版单机) 资源规格 存储容量(GB) 实例TPS 实例Topic数上限 实例消费组数上限 rocketmq.b1.large.1 100 ~ 30000 500 50 500 表3 实例规格说明(分布式消息服务RocketMQ版5.x基础版集群) 资源规格 存储容量(GB) 实例TPS
-
支持多少个Topic? - 分布式消息服务RocketMQ版
x基础版单机) 资源规格 存储容量(GB) 实例TPS 实例Topic数上限 实例消费组数上限 rocketmq.b1.large.1 100 ~ 30000 500 50 500 表3 实例规格说明(分布式消息服务RocketMQ版5.x基础版集群) 资源规格 存储容量(GB) 实例TPS
-
批量创建Topic - 分布式消息服务RocketMQ版
static void main(String[] args) throws IOException { // The AK and SK used for authentication are hard-coded or stored in plaintext, which
-
消费端限流 - 分布式消息服务RocketMQ版
message.MessageExt; public class PushConsumer { public static void main(String[] args) throws InterruptedException, MQClientException {
-
收发顺序消息 - 分布式消息服务RocketMQ版
RemotingException; public class Producer { public static void main(String[] args) { try { DefaultMQProducer producer
-
消息问题 - 分布式消息服务RocketMQ版
消息问题 RocketMQ的消息保留时间是多少?可以修改吗? RocketMQ支持的最大消息大小是多少?可以修改吗? RocketMQ副本存储形式是怎样的?可以修改吗? 消息创建时间在哪设置?
-
通过Topic和Tag实现消息分类 - 分布式消息服务RocketMQ版
根据消息类型判断:RocketMQ的消息可分为普通消息、顺序消息、定时/延迟消息、事务消息,不同类型的消息需要用不同的Topic来区分,无法通过Tag区分。 根据消息优先级判断:在业务中紧急程度高和紧急程度一般的消息用不同的Topic来区分,方便后续业务处理。 根据业务关联性判
-
计费模式概述 - 分布式消息服务RocketMQ版
后付费 按照RocketMQ实例实际使用时长计费。 计费周期 按订单的购买周期计费。 秒级计费,按小时结算。 适用计费项 实例费用、存储空间费用 实例费用、存储空间费用 变更计费模式 支持变更为按需计费模式。 但包年/包月资费模式到期后,按需的资费模式才会生效。 支持变更为包年/包月计费模式。
-
变更RocketMQ实例计费模式为包周期 - 分布式消息服务RocketMQ版
转包周期”。RocketMQ实例5.x版本:单击RocketMQ实例名称,进入实例详情页面。单击右上角的“转包周期”。 选择续费时长,单击“去支付”,根据界面提示信息,支付费用,完成实例转包周期操作。 父主题: 变更实例
-
RocketMQ业务使用流程 - 分布式消息服务RocketMQ版
购买RocketMQ实例 RocketMQ实例采用物理隔离的方式部署,租户独占RocketMQ实例。 创建RocketMQ Topic 创建用于存储消息的Topic,供生产者生产消息以及消费者订阅消息。 连接实例 客户端使用内网/公网通过命令行连接RocketMQ实例,并生产消费消息。
-
基本概念 - 分布式消息服务RocketMQ版
风火水电,AZ内逻辑上再将计算、网络、存储等资源划分成多个集群。一个Region中的多个AZ间通过高速光纤相连,以满足用户跨AZ构建高可用性系统的需求。 项目 区域默认对应一个项目,这个项目由系统预置,用来隔离物理区域间的资源(计算资源、存储资源和网络资源),以默认项目为单位进行
-
什么是分布式消息服务RocketMQ版 - 分布式消息服务RocketMQ版
产品架构 图1 产品架构示意图 示意图说明: Broker:负责接收和存储Producer发送的消息,或者转发消息到Consumer。一个Broker由一个主节点和两个备节点组成。 NameServer:负责接收和存储Broker中的元数据。 Producer:从NameServer
-
RocketMQ相关概念 - 分布式消息服务RocketMQ版
多个消费者组成同一个消费组,同一消费组内的消费者具有相同的消费属性。 代理(Broker) 一组节点构成的一个业务集群。 NameServer 存储元数据信息的轻量级注册中心。生产者/消费者在生产/消费消息前,需要先从NameServer获取元数据。
-
快速连接RocketMQ并生产消费消息 - 分布式消息服务RocketMQ版
选择“x86计算”。 代理规格 选择“rocketmq.4u8g.cluster”。 代理数量 选择“1”。 代理存储空间 选择“超高I/O 300GB”。 实例总存储空间 = 单个代理的存储空间 * 代理数量 设置实例网络环境信息,配置详情请参考表3。 表3 设置实例网络环境信息 参数 配置说明