检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
group-01 broker-0 16 否 购买1台ECS服务器(区域、可用区、虚拟私有云、子网、安全组与RocketMQ实例保持一致,Linux系统),具体步骤请参考购买弹性云服务器。 在ECS中安装Java JDK,并配置JAVA_HOME与PATH环境变量。 export JAVA_HOME=/root/jdk1
生产/消费成功。 分布式消息服务RocketMQ版提供三种消息查询的方法:按Topic查询、按Message ID查询和按Message Key查询。 按Topic查询:查询某时间段内指定Topic下所有的消息。此方法属于范围查询,查询到的消息可能比较多。 按Message ID
消息堆积处理建议 方案概述 在RocketMQ的实际业务中,消息堆积是比较常见的问题。在消息处理过程中,如果客户端的消费速度跟不上服务端的发送速度,未处理的消息会越来越多,这部分消息就被称为堆积消息。消息没有被及时消费而产生消息堆积,从而会造成消息消费延迟。对于消息消费实时性要求
投递。 定时消息的定时时间是服务端开始向消费端投递的时间。如果消费者当前有消息堆积,那么定时消息会排在堆积消息后面,将不能严格按照配置的时间进行投递。 由于客户端和服务端可能存在时间差,消息的实际投递时间与客户端设置的投递时间之间可能存在偏差,以服务端时间为准。 设置定时消息的投
RocketMQ支持的监控指标 功能说明 本章节定义了分布式消息服务RocketMQ版上报云监控服务的监控指标的命名空间,监控指标列表和维度定义,您可以通过分布式消息服务RocketMQ版控制台来检索分布式消息服务RocketMQ版产生的监控指标和告警信息。 命名空间 SYS.DMS
限。Token可通过调用获取用户Token接口获取。 云服务存在两种部署方式:项目级服务和全局级服务。其中: 项目级服务需要获取项目级别的Token,此时请求body中auth.scope的取值为project。 全局级服务需要获取全局级别的Token,此时请求body中auth
什么是分布式消息服务RocketMQ版 分布式消息服务RocketMQ版是一个低延迟、弹性高可靠、高吞吐、动态扩展、便捷多样的消息中间件服务。 分布式消息服务RocketMQ版具有如下特点: 兼容开源RocketMQ客户端。 提供顺序、延迟、定时、重投、死信、事务消息等功能,更好的适配电商、金融等多样的业务场景。
更多 远程登录 应用容器化改造介绍 应用容器化改造流程 步骤1:对应用进行分析 步骤2:准备应用运行环境 更多 云服务器卡顿 应用容器化改造介绍 应用容器化改造流程 步骤1:对应用进行分析 步骤2:准备应用运行环境 更多 操作系统相关 应用容器化改造介绍 应用容器化改造流程 步骤1:对应用进行分析
FullAccess 分布式消息服务管理员权限,拥有该权限的用户可以操作所有分布式消息服务的功能。 系统策略 无 DMS UserAccess 分布式消息服务普通用户权限(没有实例创建、修改、删除、扩容)。 系统策略 无 DMS ReadOnlyAccess 分布式消息服务的只读权
Trace Service,CTS)服务,您可以记录与分布式消息服务RocketMQ版相关的操作事件,便于日后的查询、审计和回溯。 前提条件 已开通CTS。 CTS支持的DMS for RocketMQ操作 表1 云审计服务支持的分布式消息服务RocketMQ版操作列表 操作名称
授权,则该自定义策略不生效。关于IAM项目与企业项目的区别,详情请参见:IAM与企业管理的区别。 DMS for RocketMQ的支持自定义策略授权项如下表所示。用户调用如下API时,需要获取对应的权限。权限获取请参考统一身份认证服务(IAM)的帮助指导。 表1 DMS for
规格:rocketmq.4u8g.cluster*1 总存储空间:高I/O,300GB 用了一段时间后,用户发现RocketMQ实例当前规格无法满足业务需要,于2023/03/20 9:00:00升配为rocketmq.8u16g.cluster*1。因为该RocketMQ实例打算长期使用下去,于2023/03/20
group-01 16 否 否 购买1台ECS服务器(区域、可用区、虚拟私有云、子网、安全组与RocketMQ实例保持一致,Linux系统),具体步骤请参考购买弹性云服务器。 在ECS中安装Java JDK,并配置JAVA_HOME与PATH环境变量。 export JAVA_HOME=/root/jdk1
投递。 定时消息的定时时间是服务端开始向消费端投递的时间。如果消费者当前有消息堆积,那么定时消息会排在堆积消息后面,将不能严格按照配置的时间进行投递。 由于客户端和服务端可能存在时间差,消息的实际投递时间与客户端设置的投递时间之间可能存在偏差,以服务端时间为准。 设置定时消息的投
计费项 计费说明 分布式消息服务RocketMQ版的计费项由实例费用和存储空间费用组成。具体内容如表1所示。 表1 分布式消息服务RocketMQ版计费项 计费项 计费项说明 适用的计费模式 计费公式 实例费用 4.8.0版本计费因子:代理规格和代理数量 5.x基础版和专业版计费因子:TPS和部署类型
身份认证与访问控制 身份认证 无论用户通过控制台还是API访问DMS for RocketMQ,都会要求访问请求方出示身份凭证,并进行身份合法性校验,同时提供登录保护和登录验证策略加固身份认证安全。 DMS for RocketMQ基于统一身份认证服务(Identity and Access
ACL_ACCESS_KEY", "ACL_SECRET_KEY")); TransactionMQProducer producer = new TransactionMQProducer("ProducerGroupName", rpcHook); ACL_ACCESS_KE
消息发送方式分为同步发送和异步发送。 同步发送:消息发送方发出一条消息到服务端,服务端接收并处理消息,然后返回响应给发送方,发送方收到响应后才会发送下一条消息。 异步发送:消息发送方发出一条消息后,不等服务端返回响应,接着发送下一条消息。 收发消息前,请参考收集连接信息收集RocketMQ所需的连接信息。
rocketmq.4u8g.cluster.small 1 ~ 10 300 ~ 30000 15000 2000 2000 rocketmq.4u8g.cluster 1 ~ 10 300 ~ 60000 20000 4000 4000 rocketmq.8u16g.cluster 1 ~ 10
rocketmq.4u8g.cluster 1 ~ 10 300 ~ 60000 20000 4000 4000 rocketmq.8u16g.cluster 1 ~ 10 300 ~ 90000 25000 8000 8000 rocketmq.12u24g.cluster 1 ~ 10 300