检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
附录 状态码 错误码 实例状态说明 获取项目ID 获取账号名和账号ID
管理消息 查看RocketMQ消息 修改RocketMQ消息保留时间 开启和查询RocketMQ消息轨迹 验证RocketMQ消息消费 管理RocketMQ死信消息
“Topic管理”页面。 在待生产消息的Topic所在行,单击“生产消息”,弹出“生产消息”对话框。 输入消息内容、消息Key和消息Tag,消息Key和消息Tag为可选,单击“确定”。 消息内容:生产消息的内容。输入长度不能超过2000个字符。 (可选)消息Key:消息键。输入长
管理实例 查看和修改RocketMQ实例基本信息 查看RocketMQ实例后台任务 配置RocketMQ实例标签 导出RocketMQ实例列表 诊断RocketMQ实例 重启RocketMQ实例的Broker节点 删除RocketMQ实例 配置RocketMQ实例回收站策略 修改RocketMQ实例的SSL配置
、FILTERSRV_CONSUMER等。这些都是RocketMQ内置的,RocketMQ服务端需要使用这些内置的消费组实现一些特定的功能和机制。 父主题: 消费组问题
表1 支持变更计费模式的RocketMQ实例计费项 计费项 变更说明 相关文档 实例规格 变更RocketMQ实例的计费模式会同时变更实例规格和存储空间的计费模式。 将RocketMQ实例的计费模式从按需计费转为包年/包月,可以让您享受一定程度的价格优惠。 将RocketMQ实例的计
是否顺序消费 RocketMQ实例的版本为5.x时,需要设置此参数。 开启顺序消费后,消费者将按顺序消费消息。 按顺序消费可以保证消息的消费顺序和发送的顺序一致,即先发送的先消费,后发送的后消费。 描述 消费组的描述信息。 修改完成后,单击“确定”。 父主题: 管理消费组
= "192.168.xx.xx:8080" AccessKey = os.Getenv("ROCKETMQ_AK") //用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险,建议在配置文件或者环境变量中密文存放,使用时解密。 SecretKey = os
information. >>> 如果未安装Python,请使用以下命令安装: yum install python 安装librocketmq库和rocketmq-client-python,具体操作请参考rocketmq-client-python。 建议下载rocketmq-client-cpp-2
= "192.168.xx.xx:8080" AccessKey = os.Getenv("ROCKETMQ_AK") //用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险,建议在配置文件或者环境变量中密文存放,使用时解密。 SecretKey = os
源状态变为“已冻结”。 超过宽限期仍未续费将进入保留期,如果保留期内仍未续费,资源将被自动删除。 华为云根据客户等级定义了不同客户的宽限期和保留期时长。 在RocketMQ实例到期前均可开通自动续费,到期前7日凌晨3:00首次尝试自动续费,如果扣款失败,每天凌晨3:00尝试一次,
单击“查看报告”,进入“实例诊断”页面,查看诊断结果。 您可以查看到消费组状态是否在线、消费者数量、订阅关系是否一致和消息堆积量,并根据结果分析处理生产和消费消息时所遇到的问题。 图1 诊断结果 消费组不在线时,可以诊断成功,但是会显示1项异常。 删除诊断记录 登录管理控制台。 在管理控制台左上角单击,选择区域。
的“更多 > 转包周期”,跳转到“按需转包年/包月”页面。 选择RocketMQ实例的购买时长,判断是否勾选“自动续费”,确认预计到期时间和配置费用后单击“去支付”。 图1 按需转包年/包月 进入支付页面,选择支付方式,确认付款,支付订单后即可完成按需转包年/包月。 父主题: 变更计费模式
后即可完成续费。 统一包年/包月资源的到期日 如果您持有多台到期日不同的RocketMQ实例,可以将到期日统一设置到一个日期,便于日常管理和续费。 图5展示了用户将两个不同时间到期的资源,同时续费一个月,并设置“统一到期日”后的效果对比。 图5 统一到期日 更多关于统一到期日的规则请参见如何设置统一到期日。
SendResult sendResult = producer.send(msg); // 打印发送结果和预计投递时间 System.out.printf("%s %s%n", sendResult, UtilAll.timeMi
值。 topic:表示Topic名称。 gid:表示生产者组名称,请根据业务实际情况输入生产者组名称。 name_srv:表示实例连接地址和端口。 事务消息生产者需要实现两个回调函数,其中local_execute回调函数在发送完半事务消息后被调用,即上图中的第3阶段,check
err.Error()) } } 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 192.168.0.1:8100:表示实例连接地址和端口。 test:表示Topic名称。 父主题: Go(TCP协议)
err.Error()) } } 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 192.168.0.1:8100:表示实例连接地址和端口。 topic1:表示Topic名称。 事务消息生产者需要实现两个回调函数,其中ExecuteLocalTransaction回调函数在