检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
和各项云服务技术的安全功能和性能本身,也包括运维运营安全,以及更广义的安全合规遵从。 租户:负责云服务内部的安全,安全地使用云。华为云租户的安全责任在于对使用的IaaS、PaaS和SaaS类云服务内部的安全以及对租户定制配置进行安全有效的管理,包括但不限于虚拟网络、虚拟主机和访客
x版本收发普通消息前,需要确保Topic的消息类型为“普通”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4.9.8。 通过以下任意一种方式引入依赖: 使用Maven方式引入依赖。 <dependency> <groupId>org.apache.rocketmq</groupId>
在“变更类型”中,选择“代理规格”,在“代理规格”中,选择扩容后的代理规格,单击“下一步”。确认扩容信息无误后,单击“提交”。 在实例列表页面的“规格”中查看扩容后的代理规格。 扩容代理规格会导致实例中断一分钟左右,如果扩容时生产TPS较高,可能扩容失败。建议优先使用扩容代理个数。
年/包月,可以让您享受一定程度的价格优惠。 将RocketMQ实例的计费模式从包年/包月转为按需计费,可以帮助您回收部分成本,并更加灵活地使用RocketMQ资源。 说明: 包年/包月计费模式到期后,按需计费模式才会生效。 按需转包年/包月 包年/包月转按需 存储空间 不支持单独
AccessKey = os.Getenv("ROCKETMQ_AK") //用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险,建议在配置文件或者环境变量中密文存放,使用时解密。 SecretKey = os.Getenv("ROCKETMQ_SK") ) func
"copyright", "credits" or "license" for more information. >>> 如果未安装Python,请使用以下命令安装: yum install python 安装librocketmq库和rocketmq-client-python,具体操作
x版本收发定时消息前,需要确保Topic的消息类型为“定时”。 适用场景 定时消息适用于以下场景: 消息对应的业务逻辑有时间窗口要求,如电商交易中超时未支付关闭订单的场景。在订单创建时发送一条定时消息,5分钟以后投递给消费者,消费者收到此消息后需要判断对应订单是否完成支付,如果未完成支付,则关闭订单。如果已完成,则忽略。
} } 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 192.168.0.1:8100:表示实例连接地址和端口。 topic1:表示Topic名称。 异步发送 异步发送是指消息发送方发出一条消息后,不等服务端返回响应,接着发送下一条消息的通讯方式。 使用异步发送需要客户
action 否 String 批量删除Topic时使用,不配置则为创建接口。删除操作:delete。 请求参数 表3 请求Body参数 参数 是否必选 参数类型 描述 name 否 String 主题名称,只能由英文字母、数字、百分号、竖线、中划线、下划线组成,长度3~64个字符。 brokers
描述 type String 实例类型。 product_id String 产品ID。 ecs_flavor_id String 该产品使用的ECS规格。 billing_code String 账单计费类型。 arch_types Array of strings 支持的CPU架构类型。
instance_id 是 String 实例ID。 表2 Query参数 参数 是否必选 参数类型 描述 action 否 String 批量删除消费组时使用,不配置则为创建接口。删除操作:delete。 请求参数 表3 请求Body参数 参数 是否必选 参数类型 描述 groups 否 Array