产品功能
消息队列分布式事务 在多次调用消息系统的场景中，通过 GTS，应用可轻松具备消息事务的处理能力。混合的分布式事务 GTS 可将各个资源加入事务范畴，实现同时跨服务、数据库、跨消息系统的事务处理能力。多种事务模式 提供了标准事务模式、...
应用场景
这些活动都对分布性系统中的各项微服务应用的处理性能带来很大的挑战。消息队列作为分布式系统中的重要组件，可以很好的应对这些场景。下文以支付转账为场景说明消息队列如何实现以下功能：异步解耦 分布式事务的数据一致性 削峰填谷 异步...
消息超时和重试机制
本文介绍 云消息队列 RabbitMQ 版 服务端默认的消息重试机制，帮助您理解消费失败后的消息处理逻辑，并选择合适的消息处理策略。重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试...
消息处理时长自适应
本文介绍如何使消息处理时长自适应。背景信息 消息服务MNS 的规范中，每条消息都有个默认的VisibilityTimeout，Worker在接收到消息后，Timeout就开始计时了。如果Worker在Timeout时间内没能处理完消息，那么消息就有可能被其他Worker接收到...
消息轨迹
如下图所示，设备上报数据后，查看消息轨迹，可发现在数据流转操作中：发布到另一个Topic（republish）、插入到表格存储（ots）和发布到AMQP服务端订阅消费组的消息处理成功。存储到实例内时间序列数据库（tsdb in vpc）因参数非法，及 ...
仪表盘
20_ms le_50_ms le_200_ms le_500_ms le_overflow uid instance_id topic client_id invocation_status 消费者Metrics指标 Metrics类型 Metrics name 单位 指标说明 Label Histogram rocketmq_process_time ms PushConsumer的消息处理耗时...
队列使用手册
并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。Console.WriteLine("DeleteMessage Failed!ErrorCode:"+me.ErrorCode);} catch(Exception ex){ Console.WriteLine("Delete message ...
内容分割
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
仪表盘
堆积消息量（已就绪消息+处理中消息）top20 GroupIDs 统计堆积的消息量最多的前20个Group。单位：条。处理中消息量 top20 GroupIDs 统计处理中的消息量最多的前20个Group。单位：条。消费处理耗时 top20 GroupIDs 统计消费处理耗时最长的前...
内容映射
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
动态路由
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
消息数、活跃消息数、延迟消息数分别表示哪些消息？
本文介绍控制台上的消息数、活跃消息数、延迟消息数分别表示哪些类型的消息。各消息数的概念如下：消息数：成功发送的和没有发送的所有消息数。活跃消息数：未经处理的消息数。延迟消息数：设置了延迟时间的消息数。
主题使用手册
并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。Console.WriteLine("DeleteMessage Failed!ErrorCode:"+me.ErrorCode);} catch(Exception ex){ Console.WriteLine("Delete message ...
构建基于Serverless架构的弹性高可用音视频处理系统
在音视频系统中，音视频转码是比较消耗计算力的一个子系统，您可以通过 函数计算 和 Serverless 工作流 构建弹性高可用的Serverless音视频处理系统。本文会从工程效率、运维、性能和成本方面介绍Serverless音视频处理系统和传统方案的差异...
订阅消息
class ExampleMessageListener:public MessageListener { public:Action consume(Message&message,ConsumeContext&context){/此处为具体的消息处理过程，确认消息被处理成功请返回CommitMessage。如果有消费异常，或者期望重新消费，可以...
Exactly-Once投递语义
什么是Exactly-Once投递语义 Exactly-Once是指发送到消息系统的消息只能被消费端处理且仅处理一次，即使生产端重试消息发送导致某消息重复投递，该消息在消费端也只被消费一次。Exactly-Once语义是消息系统和流式计算系统中消息流转的最...
使用函数计算实现消息数据清洗
消息数据清洗功能提供常见的消息处理模板，如消息分割、动态路由和消息富化等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。本文介绍 云消息队列 RocketMQ 版 消息数据清洗模板的类型和使用方式。背景信息 消息...
使用函数计算实现消息数据清洗
消息数据清洗功能提供常见的消息处理模板，如消息分割、动态路由和消息富化等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。本文介绍 云消息队列 RocketMQ 版 消息数据清洗模板的类型和使用方式。背景信息 消息...
消息队列
任务A作为生产者循环向消息队列发送消息，任务B作为消费者循环从消息队列接收消息，一般情况下，消费者处理数据是要花费很长时间，所以会导致消息产生的速度大于消息处理的速度，使得消息队列溢出。所以可以通过调整任务B优先级大于任务A来...
日志字段详情
MessageId 消息的MessageId，标识本次操作处理的消息。QueueName 本次操作对应的队列名称。AccountId 本次操作对应队列的账号。RemoteAddress 发起该操作的客户端地址。NextVisibleTime 该操作执行完成后，这条消息的下次可见时间。...
欠费说明
消息服务MNS 处于欠费状态...当您的账户余额不足以支付账单金额，消息服务MNS 处于欠费状态超过7天，阿里云将停止 消息服务MNS 的服务，即您不能再访问API，未处理的消息数据将按队列设置的消息过期时间自动过期释放，被释放的数据不可恢复。
Dashboard
Consumer：查看消息在消费端的处理结果。说明 除了rabbitmq_instance_api_tps_max为秒级指标，其他指标都为分钟级指标。Overview Metrics Type Metrics Name 单位 指标说明 Label gauge rabbitmq_instance_api_tps_max count/s 每分钟实例...
接入 iOS
iOS 10 以下系统，通知栏消息处理方法-(void)application:(UIApplication*)application didReceiveRemoteNotification:(NSDictionary*)userInfo fetchCompletionHandler:(void(^)(UIBackgroundFetchResult result))completionHandler {/...
捷旅假期
本文以捷旅假期为例，介绍如何通过 函数计算、云消息队列 RocketMQ 版 及对象存储等云服务，处理瞬时并发消息等问题。客户介绍 深圳市捷旅国际旅行社有限公司（简称“深捷旅”），自2001年成立以来专注于酒店行业的客房分销业务以及酒店...
捷旅假期
本文以捷旅假期为例，介绍如何通过 函数计算、云消息队列 RocketMQ 版 及对象存储等云服务，处理瞬时并发消息等问题。客户介绍 深圳市捷旅国际旅行社有限公司（简称“深捷旅”），自2001年成立以来专注于酒店行业的客房分销业务以及酒店...
接口和参数说明
messageListener 消息订阅回调，在回调中处理订阅的消息。设备上下线事件接口 接口名称：subscribeStatus 类名称：com.alibaba.mqtt.server.ServerConsumer 表 3.设备上下线事件接口参数 参数 说明 mqttGroupId 您在 云消息队列 MQTT 版 ...
消息服务MNS中HttpEndpoint接口接收不到消息时的排查...
概述 本文主要介绍消息服务MNS中HttpEndpoint接口接收不到消息时的排查方法。排查步骤 请参考如下步骤进行排查。使用 主题HTTP Endpoint本地调试工具 进行调试，检查HttpEndpoint接口接收消息的逻辑是否存在问题。使用该工具可分别针对鉴权...
使用OpenAPI示例
说明 媒体处理的系统权限策略如下：AliyunMTSFullAccess：管理媒体转码服务（MTS）的权限。AliyunMTSPlayerAuth：使用媒体转码服务（MTS）播放器的权限。关于如何创建自定义权限，请参见 授权信息。单击 确定，完成授权操作。凭证 在创建...
Spring集成
spring.rabbitmq.listener.simple.transaction-size 事务处理的消息数量。spring.rabbitmq.listener.simple.default-requeue-rejected 被拒绝的消息是否重新进入队列，默认值为true。spring.rabbitmq.listener.simple.missing-queues-fatal...
重置消费位点
您也可以将消费位置移动至最新位点，暂时不处理堆积的消息。前提条件 已停止所有Consumer客户端（云消息队列 Kafka 版 不支持在线重置消费位点）。重要 在停止Consumer客户端后，需要经过 ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG 配置的...
什么是云消息队列 RocketMQ 版？
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台，面向互联网分布式应用场景提供微服务异步解耦、流式数据处理、事件驱动处理等核心能力。为什么选择云...
什么是云消息队列 Confluent 版？
云消息队列 Confluent 版 阿里云和Apache Kafka的原厂创始公司Confluent合作，在ApacheKafka能力基础上支持消息流式处理以及大数据系统的集成的一站式解决方案—— 云消息队列 Confluent 版。您可以购买适合您生产集群规模的企业版Kafka ...
定时/延时消息
因此，下文统一用定时消息描述。在分布式定时调度触发、任务超时处理等场景，需要实现精准、可靠的定时事件触发。使用 云消息队列 RocketMQ 版 的定时消息可以简化定时调度任务的开发逻辑，实现高性能、可扩展、高可靠的定时触发能力。典型...
应用场景
事务消息处理 此时，需要利用 云消息队列 RocketMQ 版 所提供的事务消息来实现系统间的状态数据一致性。流程说明如下：注册系统向 云消息队列 RocketMQ 版 发送半事务消息。1.1 半事务消息发送成功，进入2。1.2 半事务消息发送失败，注册...
异步任务完成通知
消费事件总线EventBridge中的消息，需要接入对应的消费服务，具体费用请参考相关服务的官方文档。接入viapi事件源 登录 事件总线EventBridge控制台。在左侧导航栏单击 事件总线。在顶部菜单栏选择地域为 华东2（上海）。在 事件总线 页面，...
应用场景
前端的监控系统和大数据处理系统会利用 TSDB 的数据查询和计算分析能力进行业务监控和分析结果的实时展现。电力化工及工业制造监控分析 传统电力化工以及工业制造行业需要通过实时的监控系统进行设备状态检测，故障发现以及业务趋势分析。...
消息 Mesh
作为蚂蚁集团向下一代云原生架构演进的核心基础设施，Service Mesh 在 2019 年得到了大规模的应用与落地。...赋予更多开箱即用的消息流量管控和治理能力，并进一步结合 Knative 探索消息精细化流量调度在 Serverless 下的应用场景。
常见问题
访问移动推送控制台时提示You are not anthorized to do this operation 设备收到的消息并不是按推送的顺序到达 标签绑定与解绑为什么不是立即生效 怎么测试标签和别名的推送 移动推送支持C++接入开发吗 推送时偶现 java.lang....
回执消息FAQ
本文为您介绍配置短信回执消息时常见问题及处理建议。如何设置消息回执的接收方式？使用短信服务API接口后，可以通过MNS消息队列消费模式或HTTP批量推送模式来接收短信的回执消息。更多详情请参见 回执消息配置。什么是上行短信？如何获取...
告警功能配置及使用
告警功能配置 以下为白屏化配置告警通道的操作：告警通道选择 进入 系统管理-消息通道 页面，目前提供钉钉机器人以及邮件两种告警方式进行配置。配置钉钉机器人/邮件告警 钉钉机器人告警 进入配置页面，您需要输入机器人名称、Webhook以及...
- 产品推荐
- 这些文档可能帮助您