检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
时延会增加,进而导致生产消息请求时延增加,严重情况下可能造成生产消息失败。 对消费RocketMQ实例消息的影响 RocketMQ消息落盘使用的是顺序写,在新的消息生产到消息队列上时,会先将消息保存在内存中。如果消费者在启动消费时从最新的消息开始消费,则会直接从内存中获取消息进行消费。
整链路信息。通过消息轨迹,您能清晰定位消息从生产者发出,经由RocketMQ服务端,投递给消费者的完整链路,方便定位排查问题。 本章节介绍使用Java、Go和Spring开启消息轨迹,以及查看消息轨迹的方法。 前提条件 生产者Java客户端版本在4.9.0以上才支持事务消息的轨迹,如果版本不满足要求,请先升级。
集群 专业版(公测) 单机 集群 单机实例如果出现单点故障,无法保障服务SLA,可能造成服务不可用。由于单机实例具备成本优势,建议作为测试环境使用。 5.x版本的优势 与4.8.0版本相比,5.x版本具有如下优势: 架构更先进 5.x版本提供无状态的Proxy接入,解决无法通过代理访问的问题。5
建议在业务量少时重启节点。重启备节点,不会影响业务的使用。 怎么判断哪个是主节点? 一个Broker由一个主节点和两个备节点组成,当您购买的Broker数为1时,实际创建3个Broker节点。三个节点采用raft模式部署,使用Broker ID分别为1、2、3,当其中一台节点选为主节点后,Broker
收发顺序消息 收发事务消息 发送定时消息 使用ACL权限访问 消费端限流 Java(gRPC协议) 收发普通消息 收发顺序消息 收发事务消息 发送定时消息 Go(TCP协议) 收发普通消息 收发顺序消息 收发事务消息 发送定时消息 使用ACL权限访问 Go(gRPC协议) 收发普通消息
创建VPC和子网时,配置参数建议使用默认配置。 创建VPC和子网的操作指导请参考创建虚拟私有云和子网,若需要在已有VPC上创建和使用新的子网,请参考为虚拟私有云创建新的子网。 安全组 不同的RocketMQ实例可以重复使用相同的安全组,也可以使用不同的安全组,请根据实际需要进行配置。 使用Rocket
ame[:port]。端口缺省时使用默认的端口,https的默认端口为443。 否 使用AK/SK认证时该字段必选。 code.test.com or code.test.com:443 Content-Type 消息体的类型(格式)。推荐用户使用默认值application/j
正常范围 告警策略 是否接近性能上限 指标说明和告警处理建议 磁盘容量使用率 0~100 告警阈值:原始值>85 连续触发次数:3 告警级别:紧急 是 指标说明:该指标为从RocketMQ节点虚拟机层面采集的磁盘容量使用率。单位:%。 处理建议:出现该告警时,说明当前实例规格已不足以承
x版本收发普通消息前,需要确保Topic的消息类型为“普通”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为5.0.5。 使用Maven方式引入依赖。 <dependency> <groupId>org.apache.rocketmq</groupId>
运行状态和关键的业务指标,并能够及时收到异常的告警通知,实现生产环境的风险预警。 DMS for RocketMQ安全使用建议 本章节提供了RocketMQ使用过程中的安全最佳实践,旨在为提高整体安全能力提供可操作的规范性指导。
格名称,便于用户使用和理解。优化后的规格名称为:分布式消息服务RocketMQ专享规格。 原有RocketMQ实例的规格名称容易与其他云服务或者规格的名称混淆,从而产生误解。 本次仅优化展示的规格名称,实际的计费项和费用并没有发生改变,不会影响现有实例运行和使用。 商用
类型为“顺序”。 使用gRPC协议连接RocketMQ实例时,消费者是否顺序消费消息,取决于消费组中是否开启顺序消费,并非在消费代码中设置,顺序消费消息的代码与普通消费的代码相同。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为5.0
cluster*1。因为该RocketMQ实例打算长期使用下去,于2023/03/20 10:30:00将RocketMQ实例转为包年/包月计费,购买时长为1个月。那么在3~4月份,该RocketMQ实例总共产生多少费用呢? 计费构成分析 可以将RocketMQ实例的使用阶段按照计费模式分为两段:在2023/03/18
将在第7天被删除。 定时消息将占用普通消息约3倍的存储空间,大量使用定时消息时需要注意存储空间占用。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为5.0.5。 使用Maven方式引入依赖。 <dependency> <groupId>org
Topic是消息的一级分类,Tag是消息的二级分类,关系如下图。 应用场景 在实际业务中,通过合理使用Topic和Tag,可以使业务结构更清晰,提高效率。可以根据如下几方面判断Topic和Tag的具体使用场景: 根据消息类型判断:RocketMQ的消息可分为普通消息、顺序消息、定时/延迟消息
和各项云服务技术的安全功能和性能本身,也包括运维运营安全,以及更广义的安全合规遵从。 租户:负责云服务内部的安全,安全地使用云。华为云租户的安全责任在于对使用的IaaS、PaaS和SaaS类云服务内部的安全以及对租户定制配置进行安全有效的管理,包括但不限于虚拟网络、虚拟主机和访客
连接信息(分布式消息服务RocketMQ版5.x) 参数 说明 内网连接地址 未开启公网访问,并且使用TCP协议连接实例时,连接实例的地址。 grpc连接地址 未开启公网访问,并且使用gRPC协议连接实例时,连接实例的地址。 SSL 实例的SSL状态,支持根据实际情况修改。 公网访问
broker_disk_usage 磁盘容量使用率 该指标用于统计节点虚拟机的磁盘容量使用率 单位:% 0~100 RocketMQ实例节点 1分钟 broker_memory_usage 内存使用率 该指标用于统计节点虚拟机的内存使用率 单位:% 0~100 RocketMQ实例节点
将在第7天被删除。 定时消息将占用普通消息约3倍的存储空间,大量使用定时消息时需要注意存储空间占用。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为5.0.5。 使用Maven方式引入依赖。 <dependency> <groupId>org
x版本收发事务消息前,需要确保Topic的消息类型为“事务”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为5.0.5。 使用Maven方式引入依赖。 <dependency> <groupId>org.apache.rocketmq</groupId>