-
计费项 - 分布式消息服务RocketMQ版
计费示例 以包年/包月计费模式为例,假设您于2023/03/08 15:50:04在“华北-北京四”区域购买了一个包年/包月4.8.0版本的RocketMQ实例(规格:rocketmq.4u8g.cluster.small*1,总存储空间:超高I/O 300GB),计费资源包括实例费用
-
责任共担 - 分布式消息服务RocketMQ版
华为云的安全责任在于保障其所提供的 IaaS、PaaS 和 SaaS 类云服务自身的安全,涵盖华为云数据中心的物理环境设施和运行其上的基础服务、平台服务、应用服务等。这不仅包括华为云基础设施和各项云服务技术的安全功能和性能本身,也包括运维运营安全,以及更广义的安全合规遵从。
-
SDK概述 - 分布式消息服务RocketMQ版
在线生成SDK代码 API Explorer能根据需要动态生成SDK代码功能,降低您使用SDK的难度,推荐使用。 SDK列表 表1提供了分布式消息服务RocketMQ版支持的SDK列表,您可以在GitHub仓库查看SDK更新历史、获取安装包以及查看指导文档。
-
消费端限流 - 分布式消息服务RocketMQ版
(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET); RateLimiter rateLimiter = RateLimiter.create(200); consumer.registerMessageListener
-
使用ACL权限访问 - 分布式消息服务RocketMQ版
= nil { fmt.Println("init producer error: " + err.Error()) os.Exit(0) } err = p.Start() if err !
-
开启RocketMQ消息轨迹 - 分布式消息服务RocketMQ版
= nil { fmt.Println(err.Error()) } // Note: start after subscribe err = c.Start() if err !
-
收发事务消息 - 分布式消息服务RocketMQ版
public static void main(String[] args) throws ClientException, IOException { final ClientServiceProvider provider = ClientServiceProvider.loadService
-
收发普通消息 - 分布式消息服务RocketMQ版
consumer.subscribe("TopicTest", "*"); consumer.registerMessageListener(new MessageListenerConcurrently() { @Override
-
错误码 - 分布式消息服务RocketMQ版
at least two of the following character types:Lowercase lettersUppercase lettersDigitsSpecial characters `~!
-
查询主题列表 - 分布式消息服务RocketMQ版
total_read_queue_num Number 总读队列个数。 total_write_queue_num Number 总写队列个数。 permission String 权限。 brokers Array of brokers objects 关联的代理。
-
收发顺序消息 - 分布式消息服务RocketMQ版
return msg def send_orderly_with_sharding_key(): producer = Producer(gid, True) producer.set_name_server_address(name_srv) producer.start
-
收发事务消息 - 分布式消息服务RocketMQ版
err := p.Start() if err !
-
收发顺序消息 - 分布式消息服务RocketMQ版
), consumer.WithConsumeFromWhere(consumer.ConsumeFromFirstOffset), consumer.WithConsumerOrder(true), ) err := c.Subscribe("test", consumer.MessageSelector
-
创建实例 - 分布式消息服务RocketMQ版
EnablePublicip: &enablePublicipCreateInstanceByEngineReq, Ipv6Enable: &ipv6EnableCreateInstanceByEngineReq, EnterpriseProjectId: &enterpriseProjectIdCreateInstanceByEngineReq
-
批量创建Topic - 分布式消息服务RocketMQ版
FileReader fileReader = new FileReader(file); BufferedReader bufferedReader = new BufferedReader(fileReader); String str = null
-
发送定时消息 - 分布式消息服务RocketMQ版
MQBrokerException, RemotingException { DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName"); // 填入连接地址
-
收发普通消息 - 分布式消息服务RocketMQ版
= nil { log.Fatal(err) } err = producer.Start() if err !
-
收发顺序消息 - 分布式消息服务RocketMQ版
org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyContext; import org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyStatus
-
收发普通消息 - 分布式消息服务RocketMQ版
= nil { fmt.Println(err.Error()) } // Note: start after subscribe err = c.Start() if err !
-
查询消费列表或详情 - 分布式消息服务RocketMQ版
brokers Array of Brokers objects Topic关联代理(当查询Topic消费“详情”才显示此参数)。 表4 Brokers 参数 参数类型 描述 broker_name String Topic关联代理名称。