检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
参考如下示例代码,或者通过AsyncProducerExample.java获取更多示例代码。
步骤一:获取RabbitMQ的元数据 在浏览器中输入“http://您的RabbitMQ IP地址:15672/”,进入开源RabbitMQ控制台。 在登录页面输入用户名和密码,单击“Login”。 默认的用户名和密码即购买RabbitMQ实例时配置的用户名和密码。
关于企业项目ID的获取及企业项目特性的详细信息,请参见《企业管理服务用户指南》。
发送事务消息 参考如下示例代码,或者通过TransactionProducer.java获取更多示例代码。
通过账单查找云服务资源并停止计费 为了确保所有计费资源都能够被找到并删除,您可以在费用账单中获取计费资源的ID,通过这些ID信息找到具体的资源,然后将其一一删除。具体操作如下: 进入“费用中心 > 流水和明细账单”页面。
message done') while True: time.sleep(3600) if __name__ == '__main__': send_transaction_message(10) 示例代码中的参数说明如下,请参考收集连接信息获取参数值
i < len(resp); i++ { fmt.Printf("%#v\n", resp[i]) } time.Sleep(time.Second * 1) } } 示例代码中的参数说明如下,请参考收集连接信息获取参数值
查询可用区信息 功能介绍 在创建实例时,需要配置实例所在的可用区ID,可通过该接口查询可用区的ID。 调用方法 请参见如何调用API。 URI GET /v2/available-zones 请求参数 无 响应参数 状态码: 200 表1 响应Body参数 参数 参数类型 描述 region_id
= nil { log.Fatal(err) } time.Sleep(time.Second * 1) } } 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 Topic:输入Topic名称。
<artifactId>rocketmq-client-java</artifactId> <version>5.0.5</version> </dependency> 发送顺序消息 参考如下示例代码,或者通过ProducerFifoMessageExample.java获取更多示例代码
= nil { fmt.Printf("shutdown producer error: %s", err.Error()) } } 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 192.168.0.1:8100:表示实例连接地址和端口。
i < len(resp); i++ { fmt.Printf("%#v\n", resp[i]) } time.Sleep(time.Second * 1) } } 示例代码中的参数说明如下,请参考收集连接信息获取参数值
= nil { fmt.Printf("shutdown producer error: %s", err.Error()) } } 示例代码中的参数说明如下,请参考收集连接信息获取参数值。 192.168.0.1:8100:表示实例连接地址和端口。
方法一:通过mqadmin命令导出源实例的元数据,然后在华为云上RocketMQ实例中创建迁移任务 获取其他厂商、自建RocketMQ或华为云上另一个RocketMQ实例的元数据 登录已准备的Linux系统主机,下载RocketMQ软件包。
artifactId>rocketmq-client-java</artifactId> <version>5.0.5</version> </dependency> 发送定时消息 发送定时消息的示例代码如下,或者通过ProducerDelayMessageExample.java获取更多示例代码
artifactId>rocketmq-client-java</artifactId> <version>5.0.5</version> </dependency> 发送事务消息 参考如下示例代码,或者通过ProducerTransactionMessageExample.java获取更多示例代码
cancelMsg.putUserProperty("__STARTDELIVERTIME", String.valueOf(deliverTimestamp)); // 设置要取消消息的ID,为发送消息的唯一ID(UNIQUE_KEY),可以从发送消息的结果中获取
消息管理 查询消息 查询消息轨迹 导出死信消息 重发死信消息 消费验证 父主题: API V2(推荐)
管理消息 查看RocketMQ消息 修改RocketMQ消息保留时间 开启和查询RocketMQ消息轨迹 验证RocketMQ消息消费 管理RocketMQ死信消息
API概览 表1 实例管理类接口 API 说明 生命周期管理 包括创建实例、修改实例信息、查询实例、删除实例、查询代理列表。 消费组管理 包括查询消费组、创建消费组、删除消费组、修改消费组、查询消费列表或详情、重置消费进度。 Topic管理 包括创建主题、删除主题、查询主题、修改主题