检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
回响应,接着发送下一条消息的通讯方式。 使用异步发送需要客户端实现异步发送回调接口(SendCallback)。即消息发送方在发送了一条消息后,不需要等待服务端响应接着发送第二条消息。发送方通过回调接口接收服务端响应,并处理响应结果。 参考如下示例代码,或者通过AsyncProducer
rocketmq.client import Producer, Message topic = 'TopicTest' gid = 'test' name_srv = '192.168.0.1:8100' def create_message(): msg = Message(topic)
查询项目标签成功。 { "tags" : [ { "key" : "key1", "values" : [ "value-test", "value1" ] }, { "key" : "key2", "values" : [ "value2" ]
/groups 响应示例 状态码: 200 查询主题消费组列表成功。 { "groups" : [ "CID_JODIE_1", "test_consumer" ] } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6
s/{instance_id}/groups/{group} 响应示例 状态码: 200 查询消费组成功。 { "name" : "test", "enabled" : true, "broadcast" : true, "brokers" : [ "broker-0"
name}?offset=0&limit=10 响应示例 状态码: 200 查询用户详情成功。 { "access_key" : "test_01", "admin" : false, "default_group_perm" : "DENY", "default_topic_perm"
状态码: 200 查询主题的授权用户列表成功 { "policies" : [ ], "total" : 0, "name" : "test" } SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6 7 8 9 10
offset=0&limit=10 响应示例 状态码: 200 查询结果。 { "users" : [ { "access_key" : "test_01", "admin" : false, "default_group_perm" : "DENY", "default_topic_perm"
修改VPC/子网/可用区 实例创建后,不支持修改VPC/子网/可用区。 Request-Reply机制 不支持此机制。 修改配置参数 不支持调用开源接口修改配置参数。 Topic 表2 Topic约束与限制 限制项 约束与限制 创建Topic的数量 Topic的数量根据产品规格确定,不支持修改。
"instance_id" : "11c45539-xxxx-xxxx-xxxx-812c41f61f30", "topic" : "topic-test", "store_timestamp" : 1648888166319, "born_timestamp" : 1648888166275
offset=0&limit=10&is_detail=true 响应示例 状态码: 200 查询消费者订阅详情成功。 { "group_name" : "test", "online" : true, "subscription_consistency" : true, "total"
回响应,接着发送下一条消息的通讯方式。 使用异步发送需要客户端实现异步发送回调接口(SendCallback)。即消息发送方在发送了一条消息后,不需要等待服务端响应接着发送第二条消息。发送方通过回调接口接收服务端响应,并处理响应结果。 参考如下示例代码(以下加粗内容需要替换为实例自有信息,请根据实际情况替换)。
安全管控要求。例如:针对DMS for RocketMQ服务,管理员能够控制IAM用户仅能对实例进行指定的管理操作。多数细粒度策略以API接口为粒度进行权限拆分,DMS for RocketMQ支持的API授权项请参见细粒度策略支持的授权项。 如表1所示,包括了DMS for RocketMQ的所有系统权限。
读写外部缓存系统,例如对远程Redis读写。 下游系统调用,例如Dubbo的RPC远程调用,Spring Cloud对下游系统的HTTP接口调用。 提前梳理下游系统的调用逻辑,掌握每个调用操作的预期耗时,有助于判断业务逻辑中I/O操作的耗时是否合理。通常消息堆积都是由于下游系统
36 37 38 39 40 41 42 43 44 45 46 47 48 49 package com.huaweicloud.sdk.test; import com.huaweicloud.sdk.core.auth.ICredential; import com.huaweicloud
35 36 37 38 39 40 41 42 43 44 45 46 47 48 package com.huaweicloud.sdk.test; import com.huaweicloud.sdk.core.auth.ICredential; import com.huaweicloud
36 37 38 39 40 41 42 43 44 45 46 47 48 49 package com.huaweicloud.sdk.test; import com.huaweicloud.sdk.core.auth.ICredential; import com.huaweicloud
37 38 39 40 41 42 43 44 45 46 47 48 49 50 package com.huaweicloud.sdk.test; import com.huaweicloud.sdk.core.auth.ICredential; import com.huaweicloud
43 44 45 46 47 48 49 50 51 52 53 54 55 56 package com.huaweicloud.sdk.test; import com.huaweicloud.sdk.core.auth.ICredential; import com.huaweicloud
36 37 38 39 40 41 42 43 44 45 46 47 48 49 package com.huaweicloud.sdk.test; import com.huaweicloud.sdk.core.auth.ICredential; import com.huaweicloud