仪表盘
业务背景 云消息队列 RocketMQ 版 的消息收发流程中，队列的堆积情况、缓冲情况以及消息处理各关节的耗时等，会直接反映当前业务处理的性能和服务端运行的状态。因此，云消息队列 RocketMQ 版 的重点指标主要涉及以下业务场景。消息堆积...
产品功能
消息队列分布式事务 在多次调用消息系统的场景中，通过 GTS，应用可轻松具备消息事务的处理能力。混合的分布式事务 GTS 可将各个资源加入事务范畴，实现同时跨服务、数据库、跨消息系统的事务处理能力。多种事务模式 提供了标准事务模式、...
消费重试
例如，您预设消息处理耗时最多20 ms，但实际业务中20 ms内消息处理不完，您可以修改消息不可见时间，延长消息处理时间，避免消息触发重试机制。修改消息不可见时间需要满足以下条件：消息处理未超时 消息处理未提交消费状态 如下图所示，...
消息过滤
场景示例 以下图电商交易场景为例，从客户下单到收到商品这一过程会生产一系列消息，按照类型将消息分为订单消息和物流消息，其中给物流消息定义地域属性，按照地域分为杭州和上海：订单消息 物流消息 物流消息且地域为杭州 物流消息且地域...
通过ARMS告警大盘提高告警处理效率
背景信息 企业在处理系统告警时，经常会遇到以下痛点：如何查看过去一段时间系统发生了哪些告警，哪类告警占比较高。告警配置没有收敛，多人在多个系统配置了多个告警。如何只查看我关心的告警以及对应的处理情况。制定了值班机制，无法...
新零售电子价签解决方案（MQTT）
电子价签管控服务通过接收 云消息队列 RocketMQ 版 消息，处理分析当前系统中在线的价签节点的状态，并将数据记录到SLS。更新屏显 电子价签管控服务发送改价的 云消息队列 RocketMQ 版 消息，触发改价操作。MQTT服务端会路由该 云消息队列 ...
仪表盘
堆积消息量（已就绪消息+处理中消息）top20 GroupIDs 统计堆积的消息量最多的前20个Group。单位：条。处理中消息量 top20 GroupIDs 统计处理中的消息量最多的前20个Group。单位：条。消费处理耗时 top20 GroupIDs 统计消费处理耗时最长的前...
应用场景
事务消息处理 此时，需要利用 云消息队列 RocketMQ 版 所提供的事务消息来实现系统间的状态数据一致性。流程说明如下：注册系统向 云消息队列 RocketMQ 版 发送半事务消息。1.1 半事务消息发送成功，进入2。1.2 半事务消息发送失败，注册...
应用场景
前端的监控系统和大数据处理系统会利用 TSDB 的数据查询和计算分析能力进行业务监控和分析结果的实时展现。电力化工及工业制造监控分析 传统电力化工以及工业制造行业需要通过实时的监控系统进行设备状态检测，故障发现以及业务趋势分析。...
内容分割
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
内容映射
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
内容富化
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
动态路由
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
SOFAMQ 常见问题
作为一款分布式消息中间件，在网络抖动、应用处理超时等异常情况下，可以保证消息不丢失，但是无法保证消息不重复。控制台显示的消息堆积量是否包含了 Topic 下所有 Tag 的消息？是。消息生产者将所有类型的 Tag 都发送至同一个 Topic 中，...
OnsConsumerAccumulate-查询消息消费堆积情况
查询指定Group ID的消息消费堆积情况，包括当前消息堆积数量和消费延迟时间等。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 Open...
通过原始日志快速分析和定位问题
本文介绍基于 云消息队列 RabbitMQ 版 当前日志快速查询和分析问题的方法。当您遇到消息不符合预期、消费异常、消息堆积时，通过该方法可以帮助您高效识别出异常、保证业务正常运行。前提条件 推送 云消息队列 RabbitMQ 版 实例的消息操作...
开服地域
本文介绍 云消息队列 Kafka 版 的服务地域和各地域功能（Connector、数据处理和消息检索等）开通情况。下表中的 表示该功能已在该地域支持，表示暂不支持指定地域。公共云 地域名称 RegionId Connector（公测中）数据处理（公测中）消息...
Serverless实例计费说明
计费公式 消息收发费用＝消息收发次数累计值（次）×消息收发单价（元/次）消息收发次数计算规则 消息收发次数=接收消息次数+投递消息次数 接收消息次数：表示服务端收到生产者发送的消息条数，例如，某个Topic中收到5条消息，则计算为5次...
MQTT和RocketMQ进行数据互通（客户端上下线通知）
MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息，云消息队列 MQTT 版 支持将该条消息数据导出至其他阿里云产品，并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的 云消息队列 RocketMQ 版 数据互通...
通知点击处理
自定义消息处理 如需处理消息，可以重写 MPPushMsgServiceAdapter 的 onMessageReceive 和 onChannelMessageClick 方法：public class MyPushMsgService extends MPPushMsgServiceAdapter {/*自建通道收到消息的回调（非厂商通道）*@param ...
消息队列RocketMQ版是否能保证消息不重复？
绝大多数情况下，消息是不重复的。作为一款分布式消息中间件，在网络抖动、应用处理超时等异常情况下，无法保证消息不重复，但是能保证消息不丢失。
消费幂等
什么是消息幂等 当出现消费者对某条消息重复消费的情况时，重复消费的结果与消费一次的结果是相同的，并且多次消费并未对业务系统产生任何负面影响，那么这个消费者的处理过程就是幂等的。例如，在支付场景下，消费者消费扣款消息，对一笔...
基本概念
订阅关系（Subscription）订阅关系是 云消息队列 RocketMQ 版 系统中消费者获取消息、处理消息的规则和状态配置。订阅关系由消费者分组动态注册到服务端系统，并在后续的消息传输中按照订阅关系定义的过滤规则进行消息匹配和消费进度维护。...
使用函数计算实现消息数据清洗
消息数据清洗功能提供常见的消息处理模板，如消息分割、动态路由和消息富化等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。本文介绍 云消息队列 RocketMQ 版 消息数据清洗模板的类型和使用方式。背景信息 消息...
计费常见问题
本文汇总了 云消息队列 MQTT 版 计费相关的常见问题。我已经购买了包年包月微消息队列MQTT版实例，为什么发消息后，还会继续扣钱呢？包年包月（预付费）实例的费用只限于 云消息队列 MQTT 版 所支持的协议，即 云消息队列 MQTT 版 的消息...
SysOM内核层容器监控
SysOM（System Observer Monitoring）是一种在操作系统内核层进行容器监控的方法。基于SysOM操作系统层的容器监控功能，容器服务 Kubernetes 版 ACK（Container Service for Kubernetes）提供独特的操作系统内核层的容器监控可观测能力。该...
消费者分类
SimpleConsumer适用于以下场景：消息处理时长不可控：如果消息处理时长无法预估，经常有长时间耗时的消息处理情况。建议使用SimpleConsumer消费类型，可以在消费时自定义消息的预估处理时长，若实际业务中预估的消息处理时长不符合预期，也...
订阅关系（Subscription）
定义 订阅关系是 云消息队列 RocketMQ 版 系统中消费者获取消息、处理消息的规则和状态配置。订阅关系由消费者分组动态注册到服务端系统，并在后续的消息传输中按照订阅关系定义的过滤规则进行消息匹配和消费进度维护。通过配置订阅关系，...
消息幂等
什么是消息幂等 当出现消费者对某条消息重复消费的情况时，重复消费的结果与消费一次的结果是相同的，并且多次消费并未对业务系统产生任何负面影响，那么这整个过程就实现了消息幂等。例如，在支付场景下，消费者消费扣款消息，对一笔订单...
消息队列
任务A作为生产者循环向消息队列发送消息，任务B作为消费者循环从消息队列接收消息，一般情况下，消费者处理数据是要花费很长时间，所以会导致消息产生的速度大于消息处理的速度，使得消息队列溢出。所以可以通过调整任务B优先级大于任务A来...
消息处理时长自适应
本文介绍如何使消息处理时长自适应。背景信息 消息服务MNS 的规范中，每条消息都有个默认的VisibilityTimeout，Worker在接收到消息后，Timeout就开始计时了。如果Worker在Timeout时间内没能处理完消息，那么消息就有可能被其他Worker接收到...
附件二：众测漏洞定级标准（先知安全情报）
严重漏洞 严重漏洞是指，发生在核心系统业务系统（核心控制系统、域控、业务分发系统、堡垒机等可管理大量系统的管控系统），可造成大面积影响的，获取大量（依据实际情况酌情限定）业务系统控制权限，获取核心系统管理人员权限并且可控制...
削峰填谷
上图中，黄色区域代表超出消息处理能力的部分。将黄色部分的消息平均分布到之后的空闲时间去处理，既可以保证系统负载处在一个稳定的水位，又可以尽可能地处理更多消息。通过配置流控规则，可以达到消息匀速处理的效果。功能原理 限流降级...
使用云消息队列 Kafka 版时出现消息堆积
一般情况下，客户端消费流程大致如下：判断消息堆积是否属于正常情况 如果发现Group中出现消息堆积，请参见下列步骤，判断消息堆积是否属于正常情况：登录 云消息队列 Kafka 版控制台。在顶部菜单栏，选择地域。在左侧导航栏，单击 实例...
Exactly-Once投递语义
什么是Exactly-Once投递语义 Exactly-Once是指发送到消息系统的消息只能被消费端处理且仅处理一次，即使生产端重试消息发送导致某消息重复投递，该消息在消费端也只被消费一次。Exactly-Once语义是消息系统和流式计算系统中消息流转的最...
队列使用手册
并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。Console.WriteLine("DeleteMessage Failed!ErrorCode:"+me.ErrorCode);} catch(Exception ex){ Console.WriteLine("Delete message ...
削峰填谷
上图中，黄色的部分代表超出消息处理能力的部分。把黄色部分的消息平均到之后的空闲时间去处理，这样既可以保证系统负载处在一个稳定的水位，又可以尽可能地处理更多消息。通过配置流控规则，可以达到消息匀速处理的效果。功能原理 AHAS流...
常见问题
MNS提供哪些可用的操作 主题订阅的使用限制 MNS是否支持长轮询 MNS是否提供对消息的先入先出（FIFO）访问 MNS是否可以与其他阿里云产品协作使用 MNS相对于自主研发、商用或开源的消息队列系统有什么优势 计费相关 删除队列后，是否继续计费...
告警功能配置及使用
告警功能配置 以下为白屏化配置告警通道的操作：告警通道选择 进入 系统管理-消息通道 页面，目前提供钉钉机器人以及邮件两种告警方式进行配置。配置钉钉机器人/邮件告警 钉钉机器人告警 进入配置页面，您需要输入机器人名称、Webhook以及...
队列使用手册
并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。echo"DeleteMessage Failed:".$e;return;} 步骤五：删除队列 Sample里最后会删除这个测试队列。try {$this->client->deleteQueue($...
- 产品推荐
- 这些文档可能帮助您