检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
是否允许以广播模式消费 group-01 broker-0 16 否 购买1台ECS服务器（区域、可用区、虚拟私有云、子网、安全组与RocketMQ实例保持一致，Linux系统），具体步骤请参考购买弹性云服务器。 在ECS中安装Java JDK，并配置JAVA_HOME与PATH环境变量。
35版本实例。 步骤一：获取RabbitMQ的元数据 在浏览器中输入“http://您的RabbitMQ IP地址:15672/”，进入开源RabbitMQ控制台。 在登录页面输入用户名和密码，单击“Login”。 默认的用户名和密码即购买RabbitMQ实例时配置的用户名和密码。 在
RocketMQ-Spring的使用 本文介绍如何使用RocketMQ-Spring连接华为云RocketMQ实例进行消息的生产和消费。相关代码您可以从rocketmq-springboot-demo中获取。 下文所有RocketMQ的配置信息，如实例连接地址、Topic名称、用户信息等，请参考收集连接信息获取。
收发普通消息前，请参考收集连接信息收集RocketMQ所需的连接信息。 客户端连接RocketMQ实例5.x版本收发普通消息前，需要确保Topic的消息类型为“普通”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为4.9.8。 通过以下任意一种方式引入依赖： 使用Maven方式引入依赖。
最后一条消息的时间。 请求示例 查询指定主题的消息数。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics/{topic}/status 响应示例 状态码： 200 查询成功 查询主题的消息数成功。
资源规格：定义使用的弹性云服务器的规格类型。 存储容量：定义实例可以保存的存储容量。 实例TPS：定义实例的TPS性能。 实例Topic数上限：定义实例可以创建的Topic数量。 实例消费组数上限：定义实例可以创建的消费组数量。 分布式消息服务RocketMQ版5.x基础版支持的产品规格如
Q所需的连接信息。 RocketMQ实例5.x版本支持gRPC协议，4.8.0版本不支持。 客户端连接RocketMQ实例5.x版本收发普通消息前，需要确保Topic的消息类型为“普通”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为5
定时消息的定时时间是服务端开始向消费端投递的时间。如果消费者当前有消息堆积，那么定时消息会排在堆积消息后面，将不能严格按照配置的时间进行投递。 由于客户端和服务端可能存在时间差，消息的实际投递时间与客户端设置的投递时间之间可能存在偏差，以服务端时间为准。 设置定时消息的投递时间后
对回滚的消息不可见。 收发事务消息前，请参考收集连接信息收集RocketMQ所需的连接信息。 客户端连接RocketMQ实例5.x版本收发事务消息前，需要确保Topic的消息类型为“事务”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为4
MQ所需的连接信息。 客户端连接RocketMQ实例5.x版本收发顺序消息前，需要确保Topic的消息类型为“顺序”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为4.9.8。 通过以下任意一种方式引入依赖： 使用Maven方式引入依赖。
SecretKey：创建实例时，如果开启了ACL，需要输入用户密钥。 SetKeys：输入消息的Key。 SetTag：输入消息的Tag。 异步发送 异步发送是指消息发送方发出一条消息后，不等服务端返回响应，接着发送下一条消息的通讯方式。 使用异步发送需要客户端实现异步发送回调接口（SendCallback）。即消息
收发事务消息 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证，通过两阶段的方式提供对事务消息的支持，事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息，然后执行本地事务。如果执行成功，则发送事务提交，否则发送事务
消息引擎的类型。支持的类型为rocketmq。 project_id 是 String 项目ID，获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 表2 Query参数 参数 是否必选 参数类型 描述 type 否 String 产品的类型。 advanced：专享版。
fmt.Println(err) } } 更多编程语言的SDK代码示例，请参见API Explorer的代码示例页签，可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 查询主题的授权用户列表成功 错误码 请参见错误码。 父主题： 用户管理
fmt.Println(err) } } 更多编程语言的SDK代码示例，请参见API Explorer的代码示例页签，可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 消费组的授权用户列表成功。 错误码 请参见错误码。 父主题： 用户管理
定时消息的定时时间是服务端开始向消费端投递的时间。如果消费者当前有消息堆积，那么定时消息会排在堆积消息后面，将不能严格按照配置的时间进行投递。 由于客户端和服务端可能存在时间差，消息的实际投递时间与客户端设置的投递时间之间可能存在偏差，以服务端时间为准。 设置定时消息的投递时间后
定时消息的定时时间是服务端开始向消费端投递的时间。如果消费者当前有消息堆积，那么定时消息会排在堆积消息后面，将不能严格按照配置的时间进行投递。 由于客户端和服务端可能存在时间差，消息的实际投递时间与客户端设置的投递时间之间可能存在偏差，以服务端时间为准。 设置定时消息的投递时间后
实例可靠性是怎么保障的？ 通过以下两方面保障实例的可靠性： RocketMQ实例采用一主两备的方式存储数据 RocketMQ实例支持跨AZ部署 父主题： 实例问题
本文介绍了分布式消息服务RocketMQ版提供的SDK语言版本，列举了最新版本SDK的获取地址。 在线生成SDK代码 API Explorer能根据需要动态生成SDK代码功能，降低您使用SDK的难度，推荐使用。 SDK列表 表1提供了分布式消息服务RocketMQ版支持的SDK列表，您可以在GitH
在实例列表页面的“可用存储空间”中查看扩容后的总存储空间大小（即扩容后的单个代理的存储空间*代理个数）。 扩容存储空间不会影响业务。 可用存储空间=实际存储空间-用于存储日志的存储空间-格式化磁盘的损耗。 例如，实际扩容存储空间到700GB，用于存储日志的存储空间为100GB，格式化磁盘损耗7GB，那么扩容后的可用存储空间为593GB。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
