使用云消息队列 Kafka 版时客户端的报错及解决方案
报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权（sasl.mechanisms）失败 说明 该报错仅出现在 云消息队列 Kafka 版 的公网实例中。确保servers配置正确。通过 telnet 命令排除网络问题。如果网络...
使用云消息队列 Kafka 版时出现消息堆积
使用 云消息队列 Kafka 版 时，可能会发现Group中出现消息堆积。本文介绍如何判断消息堆积是否属于正常情况，以及处理方法。客户端消费流程 了解客户端消费流程，有助于理解消息是否堆积。一般情况下，客户端消费流程大致如下：判断消息...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的PHP SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格...
消息发送重试和流控机制
消息重复问题：因远程调用的不确定性，当 云消息队列 RocketMQ 版 客户端因请求超时触发消息发送重试流程，此时客户端无法感知服务端的处理结果，客户端进行的消息发送重试可能会产生消息重复问题，业务逻辑需要自行处理消息重复问题。...
示例代码
云消息队列 RocketMQ 版 5.x版本实例可兼容C++ 1.x/2.x SDK客户端接入，您可以使用1.x/2.x版本的SDK接入5.x实例进行消息收发。本文为您介绍1.x/2.x版本下的C++ SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK...
普通消息
普通消息为 云消息队列 RocketMQ 版 中最基础的消息，区别于有特性的顺序消息、定时/延时消息和事务消息。本文为您介绍普通消息的应用场景、功能原理、使用方法和使用建议。应用场景 普通消息一般应用于微服务解耦、事件驱动、数据集成等...
消费幂等
适用场景 在互联网应用中，尤其在网络不稳定的情况下，消息队列RocketMQ版 的消息有可能会出现重复。如果消息重复会影响您的业务处理，请对消息做幂等处理。消息重复的场景如下：发送时消息重复 当一条消息已被成功发送到服务端并完成持久...
ExchangeHasDiffFields
问题现象 使用 云消息队列 RabbitMQ 版 客户端连接 云消息队列 RabbitMQ 版 服务端时，报ExchangeHasDiffFields类型错误。例如ExchangeHasDiffFields[ODurable=true&NDurable=false;说明 报错中O开头的参数的属性值为要调用的Exchange的...
API概览
本产品（微消息队列 MQTT/2020-04-20）的OpenAPI采用 RPC 签名风格，签名细节参见 签名机制说明。我们已经为开发者封装了常见编程语言的SDK，开发者可通过 下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用需求...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 联合 阿里云云监控 提供了开箱即用且免费的监控报警服务，可帮助您解决如下问题：实例规格水位监控预警 若您实际使用的指标值超过实例的规格限制，云消息队列 RocketMQ 版 会进行强制限流。提前配置实例规格水位告...
基础术语
本文主要对 SOFAStack 消息队列涉及的专有名词及术语进行定义和解析，方便您更好地理解相关概念并使用消息队列。中文 英文 释义 消息主题 Topic 消息主题，一级消息类型，通过 Topic 对消息进行分类。详情请参见 Topic 与 Tag。消息 ...
QueueHasDiffField
问题现象 使用 云消息队列 RabbitMQ 版 客户端连接 云消息队列 RabbitMQ 版 服务端时，报QueueHasDiffField类型错误。例如QueueHasDiffField[OAutoDelete=false&NAutoDelete=true;说明 报错中O开头的参数的属性值为要调用的Queue的参数的已...
OnsDLQMessageResendById-重发指定的死信消息
您可通过同一 Message ID 的消息出现次数判断重发后依然消费失败的次数。由于死信消息是经过重试逻辑依然消费失败的消息，通常意味着消费逻辑可能存在问题，故请先查明多次消费失败的原因，再调用本接口重新发送。当前消息队列 RocketMQ 版...
定时/延时消息
若存储系统异常重启，可能会导致定时消息投递出现一定延迟。使用示例 和普通消息相比，定时消费发送时，必须设置定时触发的目标时间戳。以Java语言为例，使用定时消息示例参考如下：完整的消息收发示例代码请参见 RocketMQ 5.x系列SDK...
Exactly-Once投递语义
本文主要介绍 云消息队列 RocketMQ 版 的Exactly-Once投递语义的概念和典型使用场景，以便您理解如何使得消息只被消费端处理且仅处理一次。什么是Exactly-Once投递语义 Exactly-Once是指发送到消息系统的消息只能被消费端处理且仅处理一次...
环境准备（v2.x.x）
下载完成后选择对应操作系统内核的版本进行解压，会有如下目录结构，各目录的说明如下：demos/包含了普通消息发送、Oneway消息发送、顺序消息发送、普通消息消费、顺序消息消费等例子，还包含了 CMakeList.txt 用于 demos 的编译和管理。...
环境准备（v2.x.x）
下载完成后选择对应操作系统内核的版本进行解压，会有如下目录结构，各目录的说明如下：demos/包含了普通消息发送、Oneway消息发送、顺序消息发送、普通消息消费、顺序消息消费等例子，还包含了 CMakeList.txt 用于 demos 的编译和管理。...
通过原始日志快速分析和定位问题
本文介绍基于 云消息队列 RabbitMQ 版 当前日志快速查询和分析问题的方法。当您遇到消息不符合预期、消费异常、消息堆积时，通过该方法可以帮助您高效识别出异常、保证业务正常运行。前提条件 推送 云消息队列 RabbitMQ 版 实例的消息操作...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。不同消息类型所属的Topic不能混用，例如收发普通消息的Topic不能用来收发其他类型的消息。本文提供使用TCP协议下的C/C++ SDK收发...
迁移上云概述
该方案具备如下优势：服务不中断、消息收发影响小 迁移方案支持无感切换，在切流期间消息收发不中断，业务应用无感知，出现消息延迟和消息重复问题几率非常小。无需额外资源 业务方应用无需为迁移上云进行扩容或部署多套集群，迁移过程仅...
事务消息
事务消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 分布式事务的诉求 分布式系统调用的特点为一个核心业务逻辑的执行，同时需要调用多个下游业务...
仪表盘
借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力，云消息队列 RocketMQ 版 提供仪表盘功能。该功能可帮助您一站式、全方位、多维度地统计和观测指标，进而快速了解业务的运行状态。本文介绍仪表盘的应用场景、业务背景...
消息收发计算规格费用
包年包月或按量付费计费方式下，消息收发计算规格为 云消息队列 RocketMQ 版 的必选计费项，云消息队列 RocketMQ 版 根据消息收发TPS上限提供不同的计算规格，并按照规格大小和购买时长计算费用。计算规格说明 计算规格能力约束 消息收发...
消息幂等
适用场景 在互联网应用中，尤其在网络不稳定的情况下，云消息队列 RabbitMQ 版 的消息有可能会出现重复。如果消息重复消费会影响您的业务处理，请对消息做幂等处理。消息重复的可能原因如下：发送时消息重复 当一条消息已被成功发送到服务...
示例代码
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
查看实例风险
云消息队列 Kafka 版 实例的实时诊断功能能够定期对实例进行检测，支持查看诊断发现的问题、提供修复建议，并将异常的检查项上报告警给相关联系人。实现方案 报警通知说明 仅紧急且不健康的报警会发送报警通知。如果未添加报警联系人，则...
查看实例风险
云消息队列 Kafka 版 实例的实时诊断功能能够定期对实例进行检测，支持查看诊断发现的问题、提供修复建议，并将异常的检查项上报告警给相关联系人，帮助您及时处理异常。实现方案 检测项 说明 若检测出实例存在风险，请参考控制台上提示的...
示例代码
由于在oneway方式发送消息时没有请求应答处理，如果出现消息发送失败，则会因为没有重试而导致数据丢失。若数据不可丢，建议选用可靠同步或可靠异步发送方式。producer.sendOneway(msg);}/在应用退出前，销毁Producer对象。注意：销毁...
查询消息轨迹
云消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数，例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等，并支持可视化查询。当消息收发结果不符合预期...
消息查询
在使用Kafka的过程中遇到无法正确消费消息、消息丢失、消息延迟等消费问题时，您可通过消息查询功能查看指定消息的详细内容和相关属性，帮助您排查异常原因。若确定消息所在Topic的分区ID以及消息位点，可采用按位点查询消息；若不确定消息...
YARN调度器
yarn.scheduler.capacity.maximum-am-resource-percent 0.25 队列默认的AM可用比例，即队列内所有应用的AM占用资源量不得超过（该配置项值*队列Max-Capacity），默认值：0.1（若队列内小应用较多，AM Container占比较高，会导致可运行应用...
环境准备
64/ONSClient4CPP.lib ONSClient4CPP.dll ONSClient4CPP.pdb vc_redist.x64.exe demo/包含了普通消息发送、Oneway消息发送、顺序消息发送、普通消息消费、顺序消息消费等代码示例。interface/封装PINVOKE调用的代码，需要包含到您的项目...
环境准备
64/ONSClient4CPP.lib ONSClient4CPP.dll ONSClient4CPP.pdb vc_redist.x64.exe demo/包含了普通消息发送、Oneway消息发送、顺序消息发送、普通消息消费、顺序消息消费等代码示例。interface/封装PINVOKE调用的代码，需要包含到您的项目...
通过可观测性能力进行故障处理最佳实践
具体使用时可将这些指标大致分为以下三类：一级指标：建议将没有歧义的、可衡量业务正常运行的指标作为一级指标，这些指标出现异常则一定是业务链路出现问题，一般可用做监控报警项。例如，消息收发TPS超过规格限制可触发实例流控，您可以...
QueryMqttTraceMessageOfClient-查询消息轨迹
超过限制，API 调用会被限流，这可能会影响您的业务，请合理调用。更多信息，请参见 QPS 限制。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的PHP SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装PHP SDK。更多信息，请参见 准备环境...
OnsTopicCreate-创建Topic
仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险。本接口一般是在发布新应用或业务扩展等需要创建新的 Topic 资源时使用。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算...
客户端连接常见问题
本文介绍 云消息队列 MQTT 版 客户端连接服务端时的常见问题。使用安卓的Demo，返回连接失败报错。问题描述 资源填写正确，且网络可以连通。AK（AccessKey ID）、SK（AccessKey Secret）填写正确且已授权。可能原因 接入点格式不正确，正确...
企业铂金版生命周期管理
使用HTTP协议客户端接入时 云消息队列 RocketMQ 版 服务端时，可能会出现闪断或者拒绝连接情况，每次闪断或拒绝连接一般不会超过1分钟，请在客户端中做好重连逻辑处理。建议您使用云监控功能对重要业务进行监控，以便您在实例升降配期间...
QueryMqttTraceMessageSubscribe-查询消息消费轨迹
超过限制，API 调用会被限流，这可能会影响您的业务，请合理调用。更多信息，请参见 QPS 限制。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权...
- 产品推荐
- 这些文档可能帮助您