检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
执行如下命令下载依赖。 go mod tidy 发送事务消息 参考如下示例代码（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。 package main import ( "context" "fmt" "os" "strconv" "sync" "sync/atomic"
RemotingException; public class Producer { public static void main(String[] args) { try { DefaultMQProducer producer
' msgId: ' + ret.msg_id) producer.shutdown() if __name__ == '__main__': send_message_sync() 示例代码中的参数说明如下，请参考收集连接信息获取参数值。 topic：表示Topic名称。
RocketMQ实例规格。 c6.4u8g.cluster.small：单个代理最大Topic数2000，单个代理最大消费组数2000 c6.4u8g.cluster：单个代理最大Topic数4000，单个代理最大消费组数4000 c6.8u16g.cluster：单个代理最大Topic数8000，单个代理最大消费组数8000
mod tidy 发送定时消息 发送定时消息的示例代码如下（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。 package main import ( "context" "fmt" "github.com/apache/rocketmq-client-go/v2"
support_features Object 支持的特性。 properties Object 产品特性。 available_zones Array of strings 可用分区。 unavailable_zones Array of strings 不可用分区。 qingtian_incompatible
support_features Object 支持的特性。 properties Object 产品特性。 available_zones Array of strings 可用分区。 unavailable_zones Array of strings 不可用分区。 qingtian_incompatible
响应Body参数 参数 参数类型 描述 core_nume Integer 核数 请求示例 GET https://{endpoint}/v2/rocketmq/products/cores 响应示例 状态码： 200 查询成功。 { "core_nume" : 100 } 状态码
"security_group_id": "d39c8xxxxxxaa8510a498", "available_zones": [ "effdcxxxxxx2f56533" ], "product_id": "c6.4u8g.cluster", "storage_spec_code": "dms.physical
broker_disk_read_await 磁盘平均读操作耗时 磁盘平均读操作耗时 单位：ms 说明： 2022年5月16号及以后购买的实例，支持此监控项。 >=0 RocketMQ实例节点 1分钟 broker_disk_write_await 磁盘平均写操作耗时 磁盘平均写操作耗时
"name" : "broker-1" }, { "name" : "broker-2" } ], "result" : "success" } 状态码 状态码 描述 200 操作成功。 错误码 请参见错误码。 父主题： 实例管理
type String 支持rabbitmqInstance、kafkaInstance、rocketmqInstance、tags四种。 rabbitmqInstance表示RabbitMQ实例配额。 kafkaInstance表示Kafka实例配额。 rocketmqInstance表示RocketMQ实例配额。
需要鉴权。 切换到解压后的软件包目录下，在“conf/tools.yml”文件中，增加如下内容。 accessKey:******* secretKey:******* accessKey和secretKey表示在控制台“用户管理”页面，创建的用户名和密钥，具体可参见创建用户。
需要鉴权。 切换到解压后的软件包目录下，在“conf/tools.yml”文件中，增加如下内容。 accessKey:******* secretKey:******* accessKey和secretKey表示在控制台“用户管理”页面，创建的用户名和密钥，具体可参见创建用户。
"projects": [ { "domain_id": "65382450e8f64ac0870cd180d14e684b", "is_domain": false, "parent_id": "
groups Array of ConsumerGroup objects 消费组列表。 max Integer 最大可创建消费组数量。 remaining Integer 剩余可创建消费组数量。 next_offset Integer 下个分页的offset。 previous_offset
实例正在进行重启操作。 STARTING 实例从已冻结到运行中的中间状态。 EXTENDING 实例正在进行规格变更操作。 EXTENDEDFAILED 实例处于规格变更操作失败的状态。 FROZEN 实例处于已冻结状态，用户可以在“我的订单”中续费开启冻结的实例。 FREEZING
import java.io.UnsupportedEncodingException; public class Main { public static void main(String[] args) throws MQClientException, UnsupportedEncodingException
final String TOPIC_NAME = "ScheduledTopic"; public static void main(String[] args) throws MQClientException, InterruptedException, MQBrokerException
done') while True: time.sleep(3600) if __name__ == '__main__': send_transaction_message(10) 示例代码中的参数说明如下，请参考收集连接信息获取参数值。 topic：表示Topic名称。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
