检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
务的开发。 低延迟:基于华为云网络部署,在内网访问可达微秒级时延。 弹性高可靠:基于Raft协议实现集群内部节点的管理,及时发现故障节点并进行流量迁移,保证业务的连续性可靠。 动态扩展:提供业务集群动态扩容的能力,根据业务需要动态扩容集群规模。 便捷管理:提供监控告警、消息追踪和
Authentication Required 请求要求代理的身份认证,与401类似,但请求者应当使用代理进行授权。 408 Request Time-out 服务器等候请求时发生超时。 客户端可以随时再次提交该请求而无需进行任何更改。 409 Conflict 服务器在完成请求时发生冲突。 返回该状态码
租户:负责云服务内部的安全,安全地使用云。华为云租户的安全责任在于对使用的IaaS、PaaS和SaaS类云服务内部的安全以及对租户定制配置进行安全有效的管理,包括但不限于虚拟网络、虚拟主机和访客虚拟机的操作系统,虚拟防火墙、API网关和高级安全服务,各项云服务,租户数据,以及身份账号和密钥管理等方面的安全配置。
有的包年/包月RocketMQ实例仍可正常使用。然而,对于涉及费用的操作,如新购RocketMQ实例、扩容实例规格、续费等,用户将无法正常进行。 按需计费 当您的账号因按需RocketMQ实例自动扣费导致欠费后,账号将变成欠费状态。欠费后,按需资源不会立即停止服务,资源进入宽限期
onException(Throwable throwable) { // 消息发送失败,需要进行重试处理,可重新发送这条消息或持久化这条数据进行补偿处理。 System.out.println("send message
期前自动续费,避免因忘记手动续费而导致资源被自动删除。 在一个包年/包月RocketMQ实例生命周期的不同阶段,您可以根据需要选择一种方式进行续费,具体如图1所示。 图1 RocketMQ实例生命周期 RocketMQ实例从购买到到期前,处于正常运行阶段,资源状态为“运行中”。 到期后,资源状态变为“已过期”。
支持客户端主动拉取和服务端推送两种模式。 广播消费 支持 支持 支持 消息回溯 支持 支持。Kafka支持按照offset和timestamp两种维度进行消息回溯。 3.8.35版本:不支持。RabbitMQ中消息一旦被确认消费就会被标记删除。 AMQP-0-9-1版本:支持。 消息堆积 支持
云硬盘单价请参见分布式消息服务RocketMQ版价格详情中的“存储价格”。 弹性TPS费用 5.x专业版时,如果开启弹性TPS功能,则会按照超过实例基础规格TPS上限的增量部分进行计费。 取值为计费周期即1小时内,增量部分TPS的最大值。 按量付费(先使用后付费) 与实例本身为按需或包年/包月无关。 每小时弹性TPS费用
执行以下命令解压“rocketmq-tutorial”。 unzip rocketmq-tutorial.zip 步骤二:创建RocketMQ实例 使用RocketMQ进行消息生产和消费时,必须先创建RocketMQ实例。实例中的虚拟机资源会存储Topic信息。 进入购买RocketMQ实例页面。 在“快速购
长度为4~64个字符。 只能由英文字符、数字、中划线、下划线组成,且开头须为英文字母。 是否同名覆盖 如果开启同名覆盖,会对已有的同名元数据的配置进行修改。 例如:原实例Topic01的读队列个数为3,云上实例Topic01的读队列个数为2,开启同名覆盖后,云上实例Topic01的读队列个数变为3。
单击“创建/编辑标签”,弹出“创建/编辑标签”对话框。在待删除的标签后,单击,然后单击“确定”,完成标签的删除。 当标签达到20个时,不支持使用该方法进行删除。 如需批量删除标签,勾选待删除的标签,单击列表左上角“删除”,弹出“删除标签”对话框。单击“确定”,完成标签的删除。 父主题: 管理实例
0版本时,总存储空间的费用为单个代理的存储空间*代理数量。 弹性TPS费用 5.x专业版时,如果开启弹性TPS功能,则会按照超过实例基础规格TPS上限的增量部分进行计费。 取值为计费周期即1小时内,增量部分TPS的最大值。 说明: 专业版目前还处于公测阶段。 假设您计划购买一个4.8.0版本的Rock
长度为4~64个字符。 只能由英文字符、数字、中划线、下划线组成,且开头须为英文字母。 是否同名覆盖 如果开启同名覆盖,会对已有的同名元数据的配置进行修改。 例如:原实例Topic01的读队列个数为3,云上实例Topic01的读队列个数为2,开启同名覆盖后,云上实例Topic01的读队列个数变为3。
查看和管理该告警规则。 标签:标签用于标识云资源,当您拥有相同类型的许多云资源时,可以使用标签按各种维度(例如用途、所有者或环境)对云资源进行分类。 单击“立即创建”,完成告警规则的设置。 告警规则创建完成后,在云监控服务的“告警 > 告警规则”界面,查看新创建的告警规则。
在告警规则页面,设置告警信息。 创建告警规则操作,请查看创建告警规则。 设置告警名称和告警的描述。 设置告警策略和告警级别。 如下图所示,在进行指标监控时,如果连续3次周期,磁盘容量使用率原始值超过85%,则产生告警,如果未及时处理,则产生告警通知。 图1 设置告警策略和告警级别
通过Topic和Tag实现消息分类 在RocketMQ中,Topic与Tag都是业务上用来归类的标识,区分在于Topic是一级分类,而Tag可以理解为是二级分类。本章节介绍如何搭配使用Topic和Tag来实现消息过滤。 实现订阅关系一致 订阅关系不一致,可能导致消息消费逻辑混乱,消息被重复消费或遗漏。本章节介绍订阅关系一致的概念、原理以及实施方法。
订阅关系一致性保证了同一个消费组中消费消息的正常运行,避免消息逻辑混乱和消息丢失。在实际使用中,生产者端要做好消息的分类,便于消费者可以使用Tag进行消息的准确订阅。而在消费者端,则要保证订阅关系的一致性。 错误的订阅关系 同一消费组下的消费者订阅了不同的Topic 例如,消费组Grou
导出Topic或者消费组列表:单击“导出 > 导出全部数据到XLSX”/“导出 > 导出已选中数据到XLSX”。 删除Topic或者消费组:选择以下任意一种方法进行删除。 在待删除的Topic或者消费组所在行,单击“删除”。 勾选需要删除的Topic或者消费组,单击左上角的“批量删除”。 通过用户访问服务端
提交成功:允许消费者消费此事务消息。 回滚:事务消息将被丢弃,不允许消费者消费此事务消息。 未知,待确认:事务消息状态暂时无法确定,等待固定时间后,服务端向生产者进行消息回查。 生产耗时 生产者发送消息的耗时。 单位:毫秒 生产地址 生产者的IP地址。 消费者状态 消费者状态如下: 消费成功 消费超时 消费异常
死信消息默认保留时间为48小时,超时后,会被自动删除。如果想要修改死信消息保留时间,请参考修改RocketMQ消息保留时间。 本章节主要介绍如何查询、导出和重新投递死信消息。 分布式消息服务RocketMQ版提供三种死信消息查询的方法:按Group查询、按Message ID查询和按Message