检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
MigrationRabbitVhostMetadata 参数 是否必选 参数类型 描述 name 否 String vhost名称。 表7 MigrationRabbitQueueMetadata 参数 是否必选 参数类型 描述 vhost 否 String vhost名称。 name 否
store_size 存储大小。 property_list 消息属性列表。 name:属性名称。 value:属性值。 born_host 产生消息的主机IP。 store_host 存储消息的主机IP。 queue_id 队列ID。 queue_offset 在队列中的偏移量。 重新投递死信消息
变更规格操作,变更时系统将按照如下规则为您计算变更费用: 资源升配:新配置价格高于老配置价格,此时您需要支付新老配置的差价。 资源降配:新配置价格低于老配置价格,此时华为云会将新老配置的差价退给您。 这里以资源升配且无任何优惠的场景为例,假设您于2023/04/08在“华北-北京
MQ消息存储在CommitLog文件中,CommitLog文件大小为1GB,当一个CommitLog文件写满后,会生成一个新的CommitLog文件。RocketMQ删除消息是删除CommitLog文件,而不是删除一条消息。CommitLog文件为顺序写入,当最后写入的一条消息过
使用TCP协议,通过公网访问实例的端口。 4.8.0 5.x 入方向 TCP 10100-10199 使用TCP协议,访问业务节点的端口。 5.x 入方向 TCP 8080 使用gRPC协议,通过内网访问实例的端口。 5.x 入方向 TCP 8081 使用gRPC协议,通过公网访问实例的端口。 建议将访问DMS
是否售罄。 id String 可用区ID。 code String 可用区编码。 name String 可用区名称。 port String 可用区端口号。 resource_availability String 分区上是否还有可用资源。 default_az Boolean
使用TCP协议,通过内网访问实例的端口。 入方向 TCP 8200 使用TCP协议,通过公网访问实例的端口。 入方向 TCP 8080 使用gRPC协议,通过内网访问实例的端口。 入方向 TCP 8081 使用gRPC协议,通过公网访问实例的端口。 入方向 TCP 10100 使
当前页大小。 name 否 String 查询vhost列表时,该字段可为空。 查询exchange列表时,该字段为exchange所属vhost名称。 查询queue列表时,该字段为queue所属vhost-所属exchange,例vhost1-exchange1。 请求参数 无 响应参数
offset消息ID。 tags String 消息的标签。 keys String 消息的keys。 store_host String 存储消息的主机IP。 client_host String 产生消息的主机IP。 retry_times Integer 重试次数。 body_length
ey() 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 topic:表示Topic名称。 name_srv:表示实例连接地址和端口。 set_keys:设置消息索引键,可根据关键字精确查找某条消息。 set_tags:设置消息Tag,用于消费端根据指定Tag过滤消息。
property_list Array of property_list objects 消息属性列表。 born_host String 产生消息的主机IP。 store_host String 存储消息的主机IP。 queue_id Integer 队列ID。 queue_offset
Error()) } } 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 192.168.0.1:8100:表示实例连接地址和端口。 topic1:表示Topic名称。 异步发送 异步发送是指消息发送方发出一条消息后,不等服务端返回响应,接着发送下一条消息的通讯方式。
send_message_sync() 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 topic:表示Topic名称。 name_srv:表示实例连接地址和端口。 set_keys:设置消息索引键,可根据关键字精确查找某条消息。 set_tags:设置消息Tag,用于消费端根据指定Tag过滤消息。
property_list Array of property_list objects 消息属性列表。 born_host String 产生消息的主机IP。 store_host String 存储消息的主机IP。 queue_id Integer 队列ID。 queue_offset
Error()) } } 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 192.168.0.1:8100:表示实例连接地址和端口。 test:表示Topic名称。 上述代码中,相同orderId的消息需要保证顺序,不同orderId的消息不需要保证顺序,所以将orderId作为选择队列的sharding
在实例列表页面的“规格”中查看扩容后的代理个数。 扩容代理个数前,需确认安全组已放通的网段和实例对外提供的端口信息,否则可能造成客户端无法连接新扩容的业务节点,从而导致消息生产失败。其中,放通的网段为实例所在子网网段,放通的端口范围为10100~(10100+3n-1)(n表示代理数量)。 已开启公网访问,
(10) 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 topic:表示Topic名称。 name_srv:表示实例连接地址和端口。 set_keys:设置消息索引键,可根据关键字精确查找某条消息。 set_tags:设置消息Tag,用于消费端根据指定Tag过滤消息。
_Secret_Key为用户的密钥。创建用户的步骤,请参见创建用户。用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险,建议在配置文件或者环境变量中密文存放,使用时解密。 func main() { os.Setenv("mq.consoleAppender.enabled"
是否售罄。 id String 可用区ID。 code String 可用区编码。 name String 可用区名称。 port String 可用区端口号。 resource_availability String 分区上是否还有可用资源。 default_az Boolean
_Secret_Key为用户的密钥。创建用户的步骤,请参见创建用户。用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险,建议在配置文件或者环境变量中密文存放,使用时解密。 SessionCredentialsProvider sessionCredentialsProvider