检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
会导致消息重复消费。 前提条件 仅在实例的“状态”为“运行中”时，才可以进行消费验证。 确保待进行消费验证的客户端处于在线状态，且消费者已订阅待重新发送的消息所属的Topic。 验证RocketMQ消息消费 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。
查看RocketMQ消费者连接地址 消费者连接地址即消费消息的客户端地址，当客户端连接RocketMQ消费消息时，可通过控制台查看客户端的连接地址。 约束与限制 消费者处于连接RocketMQ实例时，才可以查看消费者连接地址。 前提条件 已创建消费组，且消费组中已存在消费者。 已创建Topic。
费。 TransactionResolution.UNKNOW：无法判断状态，期待服务端向生产者再次回查该消息的状态。 订阅事务消息 订阅事务消息的代码与订阅普通消息相同。 父主题： Go（gRPC协议）
费。 LocalTransactionState.UNKNOW：无法判断状态，期待服务端向生产者再次回查该消息的状态。 订阅事务消息 订阅事务消息的代码与订阅普通消息的代码相同。 父主题： Java（TCP协议）
费。 TransactionResolution.UNKNOW：无法判断状态，期待服务端向生产者再次回查该消息的状态。 订阅事务消息 订阅事务消息的代码与订阅普通消息相同。 父主题： Java（gRPC协议）
而Tag可以理解为是二级分类。本章节介绍如何搭配使用Topic和Tag来实现消息过滤。 实现订阅关系一致 订阅关系不一致，可能导致消息消费逻辑混乱，消息被重复消费或遗漏。本章节介绍订阅关系一致的概念、原理以及实施方法。 消息堆积处理建议 本章节介绍出现消息堆积的主要原因和实施方法。
0版本存在此参数）、最大重试次数、描述、顺序消费（仅RocketMQ实例5.x版本存在此参数）和广播消费的配置。 在详情页下方可以查看到消费组信息，及消费组订阅的所有Topic、授权信息以及订阅关系。 父主题： 管理消费组
被丢弃不允许消费。 primitive.UnknowState：无法判断状态，期待服务端向生产者再次回查该消息的状态。 订阅事务消息 订阅事务消息的代码与订阅普通消息的代码相同。 父主题： Go（TCP协议）
例如Topic A下有Tag A和Tag B，消费者A订阅了Tag A的消息，消费者B订阅了Tag B的消息。 如果消费者A和消费者B设置了相同的消费组，当生产者发送Tag A的消息时，Tag A的消息会均匀发送给消费者A和消费者B。由于消费者B没有订阅Tag A的消息，会把Tag A消息过滤掉，从而导致部分Tag
表1 Topic参数说明 参数 说明 权限 RocketMQ实例的版本为4.8.0时，才会显示此参数。 Topic的权限，包括发布+订阅、发布和订阅。 关联代理 RocketMQ实例的版本为4.8.0时，才会显示此参数。 修改读队列个数或写队列个数。 读队列个数：Topic读数据可用的总队列数。
Failed 未满足前提条件，服务器未满足请求者在请求中设置的其中一个前提条件。 413 Request Entity Too Large 由于请求的实体过大，服务器无法处理，因此拒绝请求。为防止客户端的连续请求，服务器可能会关闭连接。如果只是服务器暂时无法处理，则会包含一个Retry-After的响应信息。
支持多少个消费组个数？ 更多 远程登录 应用容器化改造介绍 应用容器化改造流程 步骤1：对应用进行分析 步骤2：准备应用运行环境 更多 云服务器卡顿 应用容器化改造介绍 应用容器化改造流程 步骤1：对应用进行分析 步骤2：准备应用运行环境 更多 操作系统相关 应用容器化改造介绍 应用容器化改造流程
次请求的结果，供您查询、审计和回溯使用。 弹性云服务器（Elastic Cloud Server） 弹性云服务器是由CPU、内存、操作系统、云硬盘组成的基础的计算组件。RocketMQ实例运行在弹性云服务器上，一个代理对应三台弹性云服务器。 云硬盘（Elastic Volume Service）
分布式消息服务RocketMQ版4.8.0规格 分布式消息服务RocketMQ版4.8.0产品规格由以下七个维度定义： 资源规格：定义使用的弹性云服务器的规格类型。 代理个数：定义实例的规模。 磁盘类型：定义存储空间的磁盘类型，包含高I/O、超高I/O、通用型SSD和极速型SSD。 存
mqadmin sendMessage -n "${连接地址}" -t ${Topic名称} -p "hello rocketmq" 参数说明如下： 连接地址：表示RocketMQ实例的“连接地址”（内网访问）/“公网连接地址”（公网访问）。 Topic名称：RocketMQ实例下创建的Topic名称。
是否允许以广播模式消费 是否顺序消费 group-01 16 否 否 购买1台ECS服务器（区域、可用区、虚拟私有云、子网、安全组与RocketMQ实例保持一致，Linux系统），具体步骤请参考购买弹性云服务器。 在ECS中安装Java JDK，并配置JAVA_HOME与PATH环境变量。
topic：表示Topic名称。 gid：表示生产者组名称，请根据业务实际情况输入生产者组名称。 name_srv：表示实例连接地址和端口。 订阅普通消息 参考如下示例代码（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。 import time from rocketmq
显示，例如Topic名称为“test%01”，在云监控中Topic名称显示为“test_01”。 权限 Topic的权限，包括发布+订阅、发布和订阅。 关联代理 选择在某个代理上创建Topic，并设置Topic的队列个数。 如果实例部署在多个代理上，单击“添加关联代理”，可以在其
mqadmin sendMessage -n "${连接地址}" -t ${Topic名称} -p "hello rocketmq" 参数说明如下： 连接地址：表示RocketMQ实例的“连接地址”（内网访问）/“公网连接地址”（公网访问）。 Topic名称：RocketMQ实例下创建的Topic名称。
弹性云服务器”，创建一个ECS实例。 具体创建操作，请参考购买弹性云服务器。如果您已有可用的ECS，可重复使用，不需要再次创建。 使用root用户登录ECS。 安装JDK，并配置JAVA_HOME与PATH环境变量。 下载JDK。 ECS虚拟机默认自带的JDK可能不符合要求，例如OpenJDK，需要配
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
