检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
将在第7天被删除。 定时消息将占用普通消息约3倍的存储空间,大量使用定时消息时需要注意存储空间占用。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为5.0.5。 使用Maven方式引入依赖。 <dependency> <groupId>org
cluster*1。因为该RocketMQ实例打算长期使用下去,于2023/03/20 10:30:00将RocketMQ实例转为包年/包月计费,购买时长为1个月。那么在3~4月份,该RocketMQ实例总共产生多少费用呢? 计费构成分析 可以将RocketMQ实例的使用阶段按照计费模式分为两段:在2023/03/18
不能创建超过10个标签。 请检查标签数量 400 DMS.10240045 The tag key has been used. 标签的键已经被使用过。 请检查标签是否已使用 400 DMS.10540001 The message body contains invalid fields. 消息体的字段非法。
阅权限。 IP白名单可以配置为具体的IP地址,也可以配置为网段。 多个IP时使用英文逗号隔开,如:192.168.1.2,192.168.2.3。 IP网段值如192.*.*.*。 在“华东二”区域使用IPv6方式连接RocketMQ实例时,IP白名单功能不可用。 管理员 开启管
broker_disk_usage 磁盘容量使用率 该指标用于统计节点虚拟机的磁盘容量使用率 单位:% 0~100 RocketMQ实例节点 1分钟 broker_memory_usage 内存使用率 该指标用于统计节点虚拟机的内存使用率 单位:% 0~100 RocketMQ实例节点
和各项云服务技术的安全功能和性能本身,也包括运维运营安全,以及更广义的安全合规遵从。 租户:负责云服务内部的安全,安全地使用云。华为云租户的安全责任在于对使用的IaaS、PaaS和SaaS类云服务内部的安全以及对租户定制配置进行安全有效的管理,包括但不限于虚拟网络、虚拟主机和访客
将在第7天被删除。 定时消息将占用普通消息约3倍的存储空间,大量使用定时消息时需要注意存储空间占用。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为5.0.5。 使用Maven方式引入依赖。 <dependency> <groupId>org
未开启公网访问,并且使用TCP协议连接实例时,连接实例的地址。 grpc连接地址 未开启公网访问,并且使用gRPC协议连接实例时,连接实例的地址。 公网访问 公网访问状态。单击“公网访问”后的,开启/关闭公网访问。 公网连接地址 仅开启公网访问后可见。 开启公网访问,并且使用TCP协议连接实例时,连接实例的地址。
x版本收发事务消息前,需要确保Topic的消息类型为“事务”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为5.0.5。 使用Maven方式引入依赖。 <dependency> <groupId>org.apache.rocketmq</groupId>
例如在支付场景下,用户购买商品后进行支付,由于网络不稳定导致用户收到多次扣款请求,导致重复扣款。但实际上扣款业务只应进行一次,商家也只应产生一条订单流水。这时候使用消息幂等就可以避免这个问题。 在实际应用中,导致消息重复的原因有网络闪断、客户端故障等,且可能发生在消息生产阶段,也可能发生在消息消费阶段
支持如下两种消费模式: CLUSTERING:表示集群消费模式。当使用集群消费模式时,RocketMQ认为任意一条消息只需要被消费组内的任意一个消费者处理即可。 BROADCASTING:表示广播消费模式。当使用广播消费模式时,RocketMQ会将每条消息推送给消费组所有的消费者,保证消息至少被每个消费者消费一次。
还提供登录保护及登录验证策略。 访问控制 对企业中的员工设置不同的DMS for RocketMQ访问权限,以达到不同员工之间的权限隔离,使用IAM进行精细的权限管理。该服务提供用户身份认证、权限分配、访问控制等功能,可以帮助您安全的控制华为云资源的访问。DMS for RocketMQ的访问权限请参见:权限管理。
x版本收发普通消息前,需要确保Topic的消息类型为“普通”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4.9.8。 通过以下任意一种方式引入依赖: 使用Maven方式引入依赖。 <dependency> <groupId>org.apache.rocketmq</groupId>
年/包月,可以让您享受一定程度的价格优惠。 将RocketMQ实例的计费模式从包年/包月转为按需计费,可以帮助您回收部分成本,并更加灵活地使用RocketMQ资源。 说明: 包年/包月计费模式到期后,按需计费模式才会生效。 按需转包年/包月 包年/包月转按需 存储空间 不支持单独
x版本支持gRPC协议,4.8.0版本不支持。 客户端连接RocketMQ实例5.x版本收发顺序消息前,需要确保Topic的消息类型为“顺序”。 使用gRPC协议连接RocketMQ实例时,消费者是否顺序消费消息,取决于消费组中是否开启顺序消费,并非在消费代码中设置,顺序消费消息的代码与普通消费的代码相同。
每天凌晨4点会清理过期的文件,部分老实例由于未设置时区,清理时间为每天中午12点。 当磁盘使用率达到70%(针对4.8.0版本)或75%(针对5.x版本)时,会立刻清理过期的文件。 当磁盘使用率达到85%时,会从最早创建的文件开始清理,不管文件是否已过期,直到磁盘空间充足。 前提条件
Getenv("ROCKETMQ_AK") //用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险,建议在配置文件或者环境变量中密文存放,使用时解密。 SecretKey = os.Getenv("ROCKETMQ_SK") ) func main() { os
x版本收发事务消息前,需要确保Topic的消息类型为“事务”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4.9.8。 通过以下任意一种方式引入依赖: 使用Maven方式引入依赖。 <dependency> <groupId>org.apache.rocketmq</groupId>
定时消息将占用普通消息约3倍的存储空间,大量使用定时消息时需要注意存储空间占用。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4.9.8。 通过以下任意一种方式引入依赖: 使用Maven方式引入依赖。 <dependency>
x版本收发顺序消息前,需要确保Topic的消息类型为“顺序”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4.9.8。 通过以下任意一种方式引入依赖: 使用Maven方式引入依赖。 <dependency> <groupId>org.apache.rocketmq</groupId>