检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
应用场景下，同一个消费组中的多个消费者共同完成Topic所有Queue的消费。Queue的分配以消费组为单位，会均匀分配给消费组下的消费者，而不会在意该消费者是否订阅了当前Topic。一个消费者只会分配到Topic中的某几个Queue，而一个Queue只会分配给一个消费者。 正确的订阅关系
"0b01fbb53600d4671fa8c00673c71260", "user_name" : "", "maintain_begin" : "02:00:00", "maintain_end" : "06:00:00", "enable_log_collection" :
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
接收消息的对象，负责从服务端获取消息。 消费组（Consumer Group） 多个消费者组成同一个消费组，同一消费组内的消费者具有相同的消费属性。 代理（Broker） 一组节点构成的一个业务集群。 NameServer 存储元数据信息的轻量级注册中心。生产者/消费者在生产/消费消
产品优势 分布式消息服务RocketMQ版具有如下产品优势，旨在打造一个即开即用、全托管、低延迟、弹性高可靠、动态扩展、便捷管理和多样功能的消息队列。 即开即用：简单几步即可在云上构建自己专属的消息服务，RocketMQ实例创建完成后，使用实例提供的访问地址即可快速接入。兼容开源
static void main(String[] args) throws IOException { // The AK and SK used for authentication are hard-coded or stored in plaintext, which
产品架构 图1 产品架构示意图 示意图说明： Broker：负责接收和存储Producer发送的消息，或者转发消息到Consumer。一个Broker由一个主节点和两个备节点组成。 NameServer：负责接收和存储Broker中的元数据。 Producer：从NameServer获
rocketmq.v2.model.*; public class ShowConsumerListOrDetailsSolution { public static void main(String[] args) { // The AK and SK used for
主节点重启过程中，客户端的生产和消费请求会被拒绝，持续时间不超过30s，建议在业务量少时重启节点。重启备节点，不会影响业务的使用。 怎么判断哪个是主节点？ 一个Broker由一个主节点和两个备节点组成，当您购买的Broker数为1时，实际创建3个Broker节点。三个节点采用raft模式部署，使用Broker
请参见如何调用API。 URI GET /v2/available-zones 请求参数 无 响应参数 状态码： 200 表1 响应Body参数 参数 参数类型 描述 region_id String 区域ID。 available_zones Array of available_zones objects
修改接入方式的影响 服务端接入方式 影响 PLAINTEXT > SSL 存量实例会重启，业务会中断，需要在客户端修改实例接入方式。 新实例不会重启，但是业务会中断，需要在客户端修改实例接入方式。 SSL > PLAINTEXT PLAINTEXT > PERMISSIVE 实例不会重启，业务不会中断。
//IAM用户密码，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全 "domain": { "name": "domainname" //IAM用户所属账号名 }
如果您需要提高RocketMQ集群实例的可靠性，在创建实例时，建议选择3个或以上的可用区，不支持选择2个可用区。原因如下：使用2个可用区的实例，如果其中一个可用区故障，可能会导致实例不可用。 父主题： 实例问题
服务器无法处理客户端发送的不带Content-Length的请求信息。 412 Precondition Failed 未满足前提条件，服务器未满足请求者在请求中设置的其中一个前提条件。 413 Request Entity Too Large 由于请求的实体过大，服务器无法处理，
Cloud，以下简称VPC）、子网和安全组，并配置安全组策略。每个RocketMQ实例都部署在某个VPC中，并绑定具体的子网和安全组，通过这样的方式为RocketMQ提供一个隔离的、用户自主配置和管理的虚拟网络环境以及安全保护策略，提升实例的安全性。 RocketMQ实例所需资源的具体要求和创建指导如表1所示。
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
"domain_id": "accountid", "name": "username", "password": "**********", "email": "email", "description":
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
通过Topic和Tag实现消息分类 方案概述 Topic是消息关联的基础逻辑单元，消息的生产与消费围绕着Topic进行。每个Topic包含若干条消息，每条消息只能属于一个Topic。 Tag是消息的标签，用于在同一Topic下区分不同类型的消息。来自同一业务单元的消息，可以根据不同业务目的在同一Topic下
统一包年/包月资源的到期日 如果您持有多台到期日不同的RocketMQ实例，可以将到期日统一设置到一个日期，便于日常管理和续费。 图5展示了用户将两个不同时间到期的资源，同时续费一个月，并设置“统一到期日”后的效果对比。 图5 统一到期日 更多关于统一到期日的规则请参见如何设置统一到期日。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
