-
查询指定实例 - 分布式消息服务RocketMQ版
"0b01fbb53600d4671fa8c00673c71260", "user_name" : "", "maintain_begin" : "02:00:00", "maintain_end" : "06:00:00", "enable_log_collection" : false
-
按需计费 - 分布式消息服务RocketMQ版
0版本的实例费用包括代理规格和代理数量。 5.x基础版的实例费用包括TPS和部署类型。 存储空间费用 总存储空间(单个代理的存储空间*代理数量)的费用。 假设您计划购买一个4.8.0版本的RocketMQ实例,其存储空间为300GB。在购买RocketMQ实例页面底部,您将看到所需费用的明细,如图1所示。
-
收发事务消息 - 分布式消息服务RocketMQ版
(ClientException e) { log.error("Failed to begin transaction", e); //事务分支开启失败,直接退出。 return; }
-
收发事务消息 - 分布式消息服务RocketMQ版
Getenv("ROCKETMQ_AK") //用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险,建议在配置文件或者环境变量中密文存放,使用时解密。 SecretKey = os.Getenv("ROCKETMQ_SK") ) func main() { os.Setenv("mq.consoleAppender
-
实例规格变更 - 分布式消息服务RocketMQ版
该参数有效且必填,实例存储空间 = 代理数量 * 每个broker的存储空间。 当oper_type类型是storage时,代理数量不变,每个broker存储空间最少扩容100GB。 当oper_type类型是horizontal时,每个broker的存储空间不变。 new_product_id
-
查询实例的扩容规格列表 - 分布式消息服务RocketMQ版
ntity 参数 参数类型 描述 io_spec String 存储IO规格 available_zones Array of strings 有可用资源的可用区列表 type String IO类型 unavailable_zones Array of strings 资源售罄的可用区列表
-
收发普通消息 - 分布式消息服务RocketMQ版
Getenv("ROCKETMQ_AK") //用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险,建议在配置文件或者环境变量中密文存放,使用时解密。 SecretKey = os.Getenv("ROCKETMQ_SK") ) func main() { os.Setenv("mq.consoleAppender
-
查看RocketMQ审计日志 - 分布式消息服务RocketMQ版
reliability deleteDMSCreateFailureInstancesSuccess 删除创建失败的DMS实例失败 reliability deleteDMSCreateFailureInstancesFailure 提交批量删除DMS实例请求成功 reliability ba
-
变更RocketMQ实例规格 - 分布式消息服务RocketMQ版
在实例列表页面的“可用存储空间”中查看扩容后的存储空间大小。 扩容存储空间不会影响业务。 可用存储空间=实际存储空间-用于存储日志的存储空间-格式化磁盘的损耗。 例如,实际扩容存储空间到700GB,用于存储日志的存储空间为100GB,格式化磁盘损耗7GB,那么扩容后的可用存储空间为593GB。
-
包年/包月 - 分布式消息服务RocketMQ版
Q实例和RocketMQ的磁盘存储空间收费。以下计费项支持包年/包月。 表1 适用计费项 计费项 说明 实例费用 4.8.0版本的实例费用包括代理规格和代理数量。 5.x基础版的实例费用包括TPS和部署类型。 存储空间费用 总存储空间(单个代理的存储空间*代理数量)的费用。随包年
-
查看RocketMQ消息 - 分布式消息服务RocketMQ版
参数说明 生产者状态 生产者状态如下: 发送成功:消息发送成功,服务端已经成功存储消息。 提交成功:允许消费者消费此事务消息。 回滚:事务消息将被丢弃,不允许消费者消费此事务消息。 未知,待确认:事务消息状态暂时无法确定,等待固定时间后,服务端向生产者进行消息回查。 生产耗时 生产者发送消息的耗时。
-
使用ACL权限访问 - 分布式消息服务RocketMQ版
mitive" "github.com/apache/rocketmq-client-go/v2/producer" ) func main() { p, err := rocketmq.NewProducer( producer.WithNsResolver(primitive
-
查询消息 - 分布式消息服务RocketMQ版
Number 存储消息的时间。 born_timestamp Number 产生消息的时间。 reconsume_times Integer 重试次数。 body String 消息体。 body_crc Number 消息体校验和。 store_size Number 存储大小。 property_list
-
收发事务消息 - 分布式消息服务RocketMQ版
import java.io.UnsupportedEncodingException; public class Main { public static void main(String[] args) throws MQClientException, UnsupportedEncodingException
-
购买RocketMQ实例 - 分布式消息服务RocketMQ版
0”时,您需要根据实际情况选择RocketMQ实例支持的规格、代理个数和代理存储空间。 部署架构:仅支持“集群”,保持默认值即可。 CPU架构:仅支持“x86计算”,保持默认值即可。 代理规格:根据实际业务情况选择实例规格。 代理数量:RocketMQ实例的代理个数。 代理存储空间:选择RocketMQ实例的磁盘类型和单个代理的储存空间。
-
实例可靠性是怎么保障的? - 分布式消息服务RocketMQ版
实例可靠性是怎么保障的? 通过以下两方面保障实例的可靠性: RocketMQ实例采用一主两备的方式存储数据 RocketMQ实例支持跨AZ部署 父主题: 实例问题
-
收发事务消息 - 分布式消息服务RocketMQ版
o/v2 v2.1.1 ) 发送事务消息 参考如下示例代码(以下加粗内容需要替换为实例自有信息,请根据实际情况替换)。 package main import ( "context" "fmt" "os" "strconv" "sync" "sync/atomic"
-
收发普通消息 - 分布式消息服务RocketMQ版
设置长轮询接收消息请求(long-polling receive requests)的最大等待时间 .setAwaitDuration(awaitDuration) // 设置订阅关系 .setSubsc
-
使用ACL权限访问 - 分布式消息服务RocketMQ版
角色名称 "ROCKETMQ_SK", # 角色密钥 '' )#用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险,建议在配置文件或者环境变量中密文存放,使用时解密。 producer.start() msg = create_message()
-
查询消费列表或详情 - 分布式消息服务RocketMQ版
rocketmq.v2.model.*; public class ShowConsumerListOrDetailsSolution { public static void main(String[] args) { // The AK and SK used for