消息重试
受消费者处理速度的影响，到第5 s时才开始拉取消息消费，6 s后消息处理异常客户端返回消费失败。此时还不能进行消费重试，需要等待重试间隔后才能开始再次消费。等到第21 s时消息再次变为已就绪状态。5 s后客户端才再次开始重新消费消息。...
消息优先级为1，就一定优先吗？
消息服务MNS 消费消息时尽量做到先进先出，因为分布式消息队列的一些特性，消息服务MNS 不能保证按照消息的发送顺序去消费消息，所以如果业务必须先进先出，建议在消息中加入序号信息以便消费消息后进行重新排序。如果您要求消息顺序必须...
消息幂等
如果消息重复消费会影响您的业务处理，请对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 在数学与计算机学中，幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同。在消息领域，幂等是...
监控数据相关问题
实例消息生产流量 Topic消息生产流量 Group未消费消息总数 其他指标项（如实例/Topic消息生产条数、实例/Topic消息生产发送次数、实例/Topic消息消费次数等）数据在流量比较小或客户端版本比较低时，会存在误差，在您业务流量正常的情况下...
如何处理消息堆积
问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警，登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象：在 Group 详情 页面，看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹，单击 创建查询任务，...
基本概念
订阅关系（Subscription）订阅关系是 云消息队列 RocketMQ 版 系统中消费者获取消息、处理消息的规则和状态配置。订阅关系由消费者分组动态注册到服务端系统，并在后续的消息传输中按照订阅关系定义的过滤规则进行消息匹配和消费进度维护。...
常见问题
控制台常见问题 消息队列RocketMQ版仪表盘的指标含义是什么？使用消费验证功能消费的消息，为什么查不到消息轨迹？为什么控制台查看不到实例、Topic和Group资源？为什么在控制台上查询不到延时消息的轨迹？如何查看某个资源的增删改查记录...
捷旅假期
本文以捷旅假期为例，介绍如何通过 函数计算、云消息队列 RocketMQ 版 及对象存储等云服务，处理瞬时并发消息等问题。客户介绍 深圳市捷旅国际旅行社有限公司（简称“深捷旅”），自2001年成立以来专注于酒店行业的客房分销业务以及酒店...
消息类型
普通消息 定时和延时消息 顺序消息 事务消息 普通消息 普通消息是指消息队列中无特性的消息，区别于有特性的定时/延时消息、顺序消息和事务消息。TCP Java SDK 收发普通消息的示例代码 发送普通消息（三种方式）发送消息（多线程）订阅消息...
捷旅假期
本文以捷旅假期为例，介绍如何通过 函数计算、云消息队列 RocketMQ 版 及对象存储等云服务，处理瞬时并发消息等问题。客户介绍 深圳市捷旅国际旅行社有限公司（简称“深捷旅”），自2001年成立以来专注于酒店行业的客房分销业务以及酒店...
计费常见问题
本文汇总了 云消息队列 RocketMQ 版 计费的常见问题。每天扣除2元，这是什么费用？我昨天删除了Topic，为什么今天会收到账单并被扣费？我没有使用 云消息队列 RocketMQ 版 服务，为什么会扣费？我在控制台上看到没有开通 云消息队列 ...
基本概念
该时间反映消费者完成消息处理的及时性。当前时间－最早一条未提交消息的就绪时间 消息过滤 Consumer可以根据消息标签（Tag）对消息进行过滤，确保Consumer最终只接收被过滤后的消息类型。消息过滤在 云消息队列 RocketMQ 版 的服务端完成...
接入方式
} 消息类型 Topic中会包含多种Event，如商品Topic中包含ProductCreated,SkuEdited等消息，您可以根据需要接受，如果业务上不需要，消息处理时可以直接跳过。其他语言 其他语言请根据接入点、topic、group等，参考阿里云kafka官方接入demo...
API&SDK常见问题
您在使用语音服务API或SDK时，如果遇到疑问后可以参考以下常见问题及处理建议。语音服务SDK是否支持Android终端？当前语音服务SDK不支持Android和iOS终端编译。语音服务VoiceReport接口返回后会再次推送吗？一个通话结束推送后，只要您有一...
产品简介
搭建Kafka集群复杂性的问题：使用阿里云商业版Confluent，您可以在几十分钟内完成机型选配、集群部署、消息事件处理。完全节省您自行部署集群大数据软件的成本。为什么使用流数据服务Confluent？相较于开源版Kafka，您可以享受企业版增值...
回执消息简介与配置流程
背景信息 如果出现网络异常、响应超时等情况，可能会导致回执消息推送重复、回执消息获取失败等问题。回执消息模式 接收回执消息的模式有MNS消息队列消费模式和HTTP批量推送模式两种，您可根据实际情况选择合适的模式接收回执消息。MNS消息...
应用场景
消息事务 GTS 与 MQ 打通，提供事务消息处理能力，可以保证业务链路完成时发送消息，任一阶段异常时回滚消息。开发简单，在客户端声明一个注解，用以界定事务边界，调用 MQ 的事务API发送消息。 高可靠：在宕机、网络故障等情况下，严格...
消息轨迹
如下图所示，设备上报数据后，查看消息轨迹，可发现在数据流转操作中：发布到另一个Topic（republish）、插入到表格存储（ots）和发布到AMQP服务端订阅消费组的消息处理成功。存储到实例内时间序列数据库（tsdb in vpc）因参数非法，及 ...
应用场景
事务型业务流程编排 复杂的业务场景如电商网站、酒店和机票预定等应用通常要访问多个远程服务，并且对操作事务性语义（即所有步骤全部成功或全部失败，不存在中间状态）有较高要求。在流量较小、数据存储集中的应用中，事务性可以通过关系...
可观测性体系概述
作为一款典型的分布式中间件产品，云消息队列 RocketMQ 版 被广泛应用于业务核心链路中，每条消息都关联着核心业务数据的变化，通过可观测能力及时发现问题、定位问题、解决问题对于业务运行是一项重要的保障能力。本文介绍 云消息队列 ...
使用异常
public class MessageListenerImpl implements MessageListener {@Override public Action consume(Message message,ConsumeContext context){/消息处理逻辑抛出异常，消息将重试 doConsumeMessage(message);如果在 doConsumeMessage()方法...
什么是消息服务MNS
更多信息，请参见：Endpoint签名认证 主题使用手册 对于因为网络或者其他原因不方便提供回调地址的情况，消息服务MNS 依然支持将消息推送到队列中，您仍然可以直接到队列中获取消息。原先使用队列模型的消费者，可以无缝消费主题中的消息。...
概述
消息集成为消息产品提供的低代码，全栈事件流（EventStreaming）服务平台，聚焦消息集成、数据连接、数据处理、服务集成等场景。提供可视化UI界面来便捷地创建集成任务，支持可视化设计与编排。提供跨地域、跨实例、跨应用的跨端连接能力。...
阿里云上稳定性保障服务（容量规划）
业务目标对齐 确认容量规划目标 确认业务范围 现有系统容量分析 阿里云提供现有系统的数据量、流量、消息量等分析和风险识别 容量规划的验证 根据业务需求和架构情况，进行容量的合理水位验证 方案实施日报 方案实施期间每日发生的问题、...
数据概览
网络业务和语音业务的差异 网络业务和语音业务最主要的区别在于一个是文本客服，一个是电话客服，其它具体差异可以参考下方表格：网络业务（在线）语音业务（热线）产品介绍 网络业务可以为企业提供一站式的在线服务能力，通过轻量便捷的...
概述
消息集成为消息产品提供的低代码，全栈事件流（EventStreaming）服务平台，聚焦消息集成、数据连接、数据处理、服务集成等场景。提供可视化UI界面来便捷地创建集成任务，支持可视化设计与编排。提供跨地域、跨实例、跨应用的跨端连接能力。...
概述
消息集成为消息产品提供的低代码，全栈事件流（EventStreaming）服务平台，聚焦消息集成、数据连接、数据处理、服务集成等场景。提供可视化UI界面来便捷地创建集成任务，支持可视化设计与编排。提供跨地域、跨实例、跨应用的跨端连接能力。...
集群消费和广播消费
广播模式下，消息队列保证每条消息至少被每台客户端消费一次，但是并不会重投消费失败的消息，因此业务方需要关注消费失败的情况。广播模式下，客户端每一次重启都会从最新消息消费。客户端在被停止期间发送至服务端的消息将会被自动跳过，...
消费者负载均衡
背景信息 了解消费者负载均衡策略，可以帮助您解决以下问题：消息消费处理的容灾策略：您可以根据消费者负载均衡策略，明确当局部节点出现故障时，消息如何进行消费重试和容灾切换。消息消费的顺序性机制：通过消费者负载均衡策略，您可以...
数据转发到消息服务（MNS）
当需要对设备数据进行复杂或精细化处理，且单个产品下所有设备或指定设备的消息量小于1,000 QPS时，可以使用云产品流转功能将物联网平台数据转发到消息服务（MNS）中，服务端再从消息服务主题中订阅消息，实现设备端与服务端之间高性能的...
查询消息轨迹
云消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数，例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等，并支持可视化查询。当消息收发结果不符合预期...
计费FAQ
本文汇总了 云消息队列 RabbitMQ 版 计费的常见问题。向10个Queue发送同一条消息，为什么收10次API调用费？将1条消息发送给10个Queue，实际上是10次API调用。为什么删除的Vhost、Exchange、Queue会被自动重建并重新开始计费？虽然删除了...
计费FAQ
本文汇总了 云消息队列 RabbitMQ 版 计费的常见问题。向10个Queue发送同一条消息，为什么收10次API调用费？将1条消息发送给10个Queue，实际上是10次API调用。为什么删除的Vhost、Exchange、Queue会被自动重建并重新开始计费？虽然删除了...
Token鉴权概述
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的Token相关的请求以及消息收发业务。使用流程 Token鉴权模式相比签名模式更加复杂，您需要按照下图所示的流程，部署您的应用服务器。而且在初始化时，...
注意要点
本文介绍使用开源的客户端SDK接入 云消息队列 RabbitMQ 版 服务端时的注意事项。要点 说明 com.rabbitmq.client.ConnectionFactory 接口 设置 com.rabbitmq.client.ConnectionFactory 接口时，必须开启连接自动恢复功能，保证服务端升级时...
消息存储和清理机制
因此，在实际使用中需要考虑以下问题，消息在服务端中的存储以什么维度为判定条件？消息存储以什么粒度进行管理？消息存储超过限制后如何处理？这些问题都是由消息存储和过期清理机制来定义的。了解消息存储和过期清理机制，可以从以下方面...
Token鉴权概述
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的Token相关的请求以及消息收发业务。使用流程 Token鉴权模式相比签名模式更加复杂，您需要按照下图所示的流程，部署您的应用服务器。而且在初始化时，...
消息堆积
常见的消息堆积相关问题如下：如何处理消息堆积？除了异步解耦功能，消息队列还有挡住前端数据洪峰的重要功能，以此保证后端系统的稳定性。这要求消息队列具有一定的消息堆积能力。消息队列能支持 10 亿级别的消息堆积，不会因为消息堆积...
使用云消息队列 Kafka 版时出现消息堆积
消息堆积的处理方式 经过上述判断，确认消息的确存在堆积情况时，建议打印消息的消费耗时，或者根据堆栈信息查看线程执行情况。根据以下方案适当调整以加快消息的消费速度，避免出现消息堆积。增加Consumer实例个数。可以在进程内直接增加...
计费概述
计费常见问题 计费常见问题 出账与欠费说明 标准版实例计费 标准版实例的计费方式为按量付费（后付费），适合消息量少或消息波峰波谷差异明显的业务场景，根据您实际使用的消息量和资源进行收费，可以有效避免资源浪费。消息收发费用 消息...
- 产品推荐
- 这些文档可能帮助您