活动

天翼云最新优惠活动,涵盖免费试用,产品折扣等,助您降本增效!
热门活动
  • 安全隔离版OpenClaw NEW OpenClaw云服务器专属“龙虾“套餐低至1.5折起
  • 青云志云端助力计划 NEW 一站式科研助手,海外资源安全访问平台,助力青年翼展宏图,平步青云
  • 出海产品促销专区 NEW 爆款云主机低至2折,高性价比,不限新老速来抢购!
  • 天翼云信创专区 NEW “一云多芯、一云多态”,国产化软件全面适配,国产操作系统及硬件芯片支持丰富
  • 中小企业服务商合作专区 国家云助力中小企业腾飞,高额上云补贴重磅上线
  • 云上钜惠 爆款云主机全场特惠,2核4G只要1.8折起!
  • 天翼云奖励推广计划 加入成为云推官,推荐新用户注册下单得现金奖励
免费活动
  • 免费试用中心 HOT 多款云产品免费试用,快来开启云上之旅
  • 天翼云用户体验官 NEW 您的洞察,重塑科技边界

息壤智算

领先开放的智算服务平台,提供算力、平台、数据、模型、应用“五位一体”智算服务体系,构建全流程的AI基础设施能力
AI Store
  • 算力市场
  • 模型市场
  • 应用市场
公共算力服务
  • 裸金属
  • 定制裸金属
训推服务
  • 模型开发
  • 训练任务
  • 服务部署
模型推理服务
  • 模型广场
  • 体验中心
  • 服务接入
应用托管
  • 应用实例
科研助手
  • 科研智能体
  • 科研服务
  • 开发机
  • 并行计算
大模型
  • DeepSeek-V3.1
  • DeepSeek-R1-0528
  • DeepSeek-V3-0324
  • Qwen3-235B-A22B
  • Qwen3-32B
智算一体机
  • 智算一体机
模型适配专家服务
  • 模型适配专家服务
算力服务商
  • 入驻算力服务商

应用商城

天翼云精选行业优秀合作伙伴及千余款商品,提供一站式云上应用服务
进入甄选商城进入云市场进入AI Store创新解决方案公有云生态专区智云上海应用生态专区
建站工具
  • 新域名服务
  • SSL证书
  • 翼建站
企业办公
  • 安全邮箱
  • WPS 365 天翼云版
  • 天翼企业云盘(标准服务版)
灾备迁移
  • 云管家2.0
  • 翼备份(SaaS版)

定价

协助您快速了解云产品计费模式、价格详情,轻松预估上云成本
价格计算器
  • 动态测算产品价格
定价策略
  • 快速了解计费模式

合作伙伴

天翼云携手合作伙伴,共创云上生态,合作共赢
天翼云生态合作中心
  • 天翼云生态合作中心
天翼云渠道合作伙伴
  • 天翼云代理渠道合作伙伴
天翼云服务合作伙伴
  • 天翼云集成商交付能力认证
天翼云应用合作伙伴
  • 天翼云云市场合作伙伴
  • 天翼云甄选商城合作伙伴
天翼云技术合作伙伴
  • 天翼云OpenAPI中心
天翼云培训认证
  • 天翼云学堂
  • 天翼云市场商学院
天翼云合作计划
  • 云汇计划
天翼信创云专区
  • 信创云专区
  • 适配互认证

开发者

开发者相关功能入口汇聚
技术社区
  • 专栏文章
  • 互动问答
  • 技术视频
资源与工具
  • OpenAPI中心
培训与认证
  • 天翼云学堂
  • 天翼云认证
开源社区
  • 魔乐社区
  • OpenTeleDB

支持与服务

为您提供全方位支持与服务,全流程技术保障,助您轻松上云,安全无忧
文档与工具
  • 文档中心
  • 新手上云
  • 自助服务
  • OpenAPI中心
定价
  • 价格计算器
  • 定价策略
基础服务
  • 售前咨询
  • 在线支持
  • 在线支持
  • 工单服务
  • 服务保障
  • 会员中心
增值服务
  • 红心服务
  • 首保服务
  • 客户支持计划
  • 专家技术服务
  • 备案管家
我要反馈
  • 建议与反馈
  • 用户体验官
信息公告
  • 客户公告

了解天翼云

天翼云秉承央企使命,致力于成为数字经济主力军,投身科技强国伟大事业,为用户提供安全、普惠云服务
品牌介绍
  • 关于天翼云
  • 智算云
  • 天翼云4.0
  • 新闻资讯
  • 天翼云APP
基础设施
  • 全球基础设施
  • 信任中心
最佳实践
  • 精选案例
  • 超级探访
  • 云杂志
  • 分析师和白皮书
  • 天翼云·创新直播间
市场活动
  • 2026智能云生态大会
  • 2025智能云生态大会
  • 2024智算云生态大会
  • 2023云生态大会
  • 2022云生态大会
  • 天翼云中国行
天翼云
  • 活动
  • 息壤智算
  • 产品
  • 解决方案
  • 应用商城
  • 定价
  • 合作伙伴
  • 开发者
  • 支持与服务
  • 了解天翼云
      • 文档
      • 控制中心
      • 备案
      • 管理中心
      文档中心

      分布式消息服务RocketMQ

      分布式消息服务RocketMQ

      • 分布式消息服务RocketMQ

      无数据

        • 产品动态
        • 服务公告
        • 2025年
        • 【通知】产品订购、续订包周期2年和3年选项调整为白名单特性
        • 【重要】默认安全组策略优化调整
        • 2024年
        • 【优惠】正式开放2年7折,3年5折包年折扣
        • 【优惠】分布式消息服务RocketMQ增加包年优惠折扣和产品资费下调
        • 【通知】CTGMQ引擎调整为白名单特性
        • 【通知】通用型主机规格调整为白名单特性
        • 产品简介
        • 产品定义
        • 产品优势
        • 功能特性
        • 应用场景
        • 产品规格
        • 开源对比
        • 分布式消息产品选型
        • 使用限制
        • 安全方案
        • 名词解释
        • 产品架构
        • 与其他服务关系
        • 计费说明
        • 产品资费
        • 新资费
        • 旧资费
        • 计费项
        • 计费模式
        • 续费、到期与欠费
        • 退订
        • 卡券使用
        • 快速入门
        • 入门指引
        • 环境准备
        • 创建RocketMQ实例
        • 创建主题和订阅组
        • 创建应用用户和密码
        • 生产消费验证
        • 用户指南
        • 创建实例
        • 实例管理
        • 查看实例
        • 修改实例
        • 连接实例
        • 扩容
        • 按需转包周期
        • 续订和退订
        • 概览
        • 集群信息
        • 标签管理
        • 回收站管理
        • 用户管理
        • 创建用户
        • Topic管理
        • 查看Topic
        • 创建Topic
        • 修改Topic
        • 删除Topic
        • 拨测
        • 重置消费位置
        • Topic导入/导出
        • 消费组管理
        • 查看消费组
        • 创建消费组
        • 修改消费组
        • 删除消费组
        • 消费组导入/导出
        • 查看订阅关系
        • 用户权限管理
        • 权限管理
        • 主子账号
        • 管理消息
        • 消息查询
        • 消息轨迹
        • 消息重试
        • 死信消息
        • 生产者实例查询
        • 消费者实例查询
        • 监控与告警
        • 监控指标说明
        • 集群监控
        • 仪表盘
        • 配置告警
        • 云审计服务支持的关键操作
        • 云审计服务支持的RocketMQ操作列表
        • 最佳实践
        • 生产者
        • 消费者
        • topic、queue的规划
        • Java客户端Pull和Push的选择
        • 有序消费和无序消费的选择
        • 消费幂等
        • 业务消息设计:Topic与Tag
        • 同组Consumer订阅关系一致
        • 开发指南
        • 概述
        • 收集连接信息
        • Java
        • 收发普通消息
        • 收发顺序消息
        • 收发事务消息
        • 收发定时/延时消息
        • 消费限流
        • Python
        • 收发普通消息
        • 收发顺序消息
        • 收发事务消息
        • 收发定时/延时消息
        • 性能白皮书
        • RocketMQ性能白皮书
        • API参考
        • API使用说明
        • SDK参考
        • SDK概述
        • RocketMQ C++ SDK
        • RocketMQ .NET SDK
        • RocketMQ PHP SDK
        • 常见问题
        • 计费类
        • 购买类
        • 操作类
        • 管理类
        • 产品类
        • 文档下载
        • 相关协议
        • 服务等级协议
        • 服务条款
          无相关产品

          本页目录

          帮助中心分布式消息服务RocketMQ常见问题操作类
          操作类
          更新时间 2026-03-30 20:00:01
          • 新浪微博
          • 微信
            扫码分享
          • 复制链接
          最近更新时间: 2026-03-30 20:00:01
          分享文章
          • 新浪微博
          • 微信
            扫码分享
          • 复制链接

          如何开启ipv6访问?

          在开通实例时,您需要选择已开启ipv6的VPC与子网,并打开ipv6开关。开通完成后,将自动为实例分配ipv6地址。您可登录实例控制台获取ipv6连接地址,可通过IPv6地址段访问实例。

          应用客户端

          连接拒绝Connect faild

          11.png

          解决方案:当出现这类问题时,检查当前网络并无异常时,并排查下ulimit –a openfiles是否为1024,修改至65535。

          超时异常RemotingTimeoutException

          服务器端日志出现RemotingTimeoutException:wait response on the channel < 10.4.246.198:10911 > timeout, 3000ms。

          解决方案:这类情况一般由于客户端与服务端通信出现问题,可以ping Ip 以及telnet ip port 来排查这类,同时也要检查防火墙的问题。

          找不到路由No route info of this topic

          问题可能原因:

          • 没创建topic。
          • name server填错了。
          • 网络问题无法获取路由。

          解决方案:

          • 在管理台创建topic。
          • 检查客户端配置的namesrv的地址是否配错了。
          • 检查网络是否正常。

          备不可用SLAVE_NOT_AVAILABLE

          当生产者发送消息时,出现“status:SLAVE_NOT_AVAILABLE”,说明从节点发生状况。

          解决方案:

          • 从节点机器出现问题,重启从节点,并查看网络连接。
          • 在多网卡情况下,broker配置文件properties中,需增加配置项,例如:brokerIP1=10.4.246.130,brokerIP2=10.4.246.130
          • 防止网卡ip读取错误,取不到从节点信息。

          消息体大小越界

          客户端报此类异常Fail to send message, for: message body size over max message size, max: 524288。

          解决方案:

          • 检查服务端的最大消息体大小,即启动broker配置文件的maxMessageSize大小,如未配置,默认是512K。
          • 检查客户端设置的最大消息体(默认128k)是否小于当前发送的消息体大小。

          注意:ROCKETMQ建议消息体在50K或以下(压缩后)。

          组名已经创建

          当消息生产端/消费端运行时,报错The producer/consumer group has been created。

          问题原因:在同一个jvm里面只允许一个producerGroupName被加载一次 (consumerGroupName同理),否则就会报错。

          解决方案:

          • 如果使用同一个producerGroupName,部署多个实例(起多个进程)。
          • 在一个进程里,起多个线程,共用一个Producer对象实例。

          Subscription group not exist或者抛出%retry%的topic没有路由信息

          问题原因:没有建立消费关系或者没有创建相关订阅组。

          解决方案:在管理台或命令行创建对应订阅组。

          Messgae already acked,ackMessage failed

          88.png

          解决方案:这种异常表明该消息已被签收,直接跳过即可。

          重试签收调用次数

          ackMessageRetry重试签收是只需要调一次就够了,还是需要调多次。例如:签收失败后,调用重试签收,如果重试签收也失败,是否需要再次调用重试签收,还是会自动重试签收。

          现有版本接口不会自动帮你重试签收的, 重试签收失败后,需要自己再次调用重试签收接口。

          签收时出现不确定异常,如发生超时,或者网络异常时,是需要应用判断消息是否已经签收成功

          解决方案:

          • 通过管理台“即时查询”模块,查询这消息是否已经签收成功,看结果再做处理。
          • 重试签收,如果已经签收会抛已签收异常。主要还是看应用的自己处理。

          客户端注册失败

          客户端日志报No matched consumer for the PullRequest PullRequest。

          1111.png

          问题原因:客户端实例注册失败。

          解决方案:检查客户端代码,重启客户端进程。

          the consumer message buffer is full, so do flow control

          客户端日志出现the consumer message buffer is full, so do flow control

          问题原因:push客户端消费过慢,本地缓存队列已满,暂时停止向服务端拉取消息。消费慢的原因可能是网络原因、topic队列数过多、消费者过少,内存过小等。

          解决方案:

          (1)查看网络是否异常,缓慢。

          (2)增加消费者实例。

          (3)如果消息不重要,又不方便增加消费者实例,可以减少topic队列数量。

          system busy, start flow control for a while

          客户端日志出现 [REJECTREQUEST]system busy, start flow control for a while 或者 [PCBUSY_CLEAN_QUEUE]broker busy, start flow control for a while, period in queue。

          问题原因:

          • 在关闭生产者实例的同时用生产者实例发送消息,连接关闭了netty会拒绝请求。
          • 线程少,处理发送请求过慢。

          解决方案:

          • 应用优化使用流程,禁止在close生产者实例后使用生产者。
          • 如果Broker是同步主,那么改成异步主,或者将 sendMessageThreadPoolNums=32且waitTimeMillsInSendQueue=1000。

          消费者消费不到消息如何处理

          进入控制台查看订阅管理菜单,检查订阅组是否有消费实例在线,如果不在线检查消费客户端日志是否有连接异常。

          检查消费客户端逻辑,是否存在订阅关系不一致的情况。

          消费者机器宕机重启是否会造成消息丢失

          RocketMQ的消息数据以及订阅信息都是持久化保存的,当消费者下线重新上线后,会Broker持久化的下线前的消费偏移重新开始消费,所以不会发生消息丢失的情况。

          订阅消息时是否可以允许消息Tag为空

          订阅主题时如果Tag设置为空会导致消费者消费不到消息,如不希望通过Tag进行消息过滤,可以将Tag设置为*,示例如下:

          consumer.subscribe(topic, "*");

          客户端连接时出现“signature validate by dauth failed”错误

          这种错误的原因一般是由于ACL认证失败,较大的可能是客户端配置的AccessKey和SecretKey出现错误,可以检查下这两项配置是否输入有误。

          文档反馈

          建议您登录后反馈,可在建议与反馈里查看问题处理进度

          鼠标选中文档,精准反馈问题

          选中存在疑惑的内容,即可快速反馈问题,我们会跟进处理

          知道了

          上一篇 :  购买类
          下一篇 :  管理类
          搜索 关闭
          ©2026 天翼云科技有限公司版权所有 增值电信业务经营许可证A2.B1.B2-20090001
          公司地址:北京市东城区青龙胡同甲1号、3号2幢2层205-32室
          备案 京公网安备11010802043424号 京ICP备 2021034386号
          ©2026天翼云科技有限公司版权所有
          京ICP备 2021034386号
          备案 京公网安备11010802043424号
          增值电信业务经营许可证A2.B1.B2-20090001
          用户协议 隐私政策 法律声明