函数计算
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已开通函数计算服务，具体...
基于MQTT Topic通信
接收与处理来自云端的消息 通过 on_topic_message()回调告知用户：lk.on_topic_message=on_topic_message def on_topic_message(topic,payload,qos,userdata):print("on_topic_message:"+topic+"payload:"+str(payload)+"qos:"+str(qos))...
消息超时和重试机制
本文介绍 云消息队列 RabbitMQ 版 服务端默认的消息重试机制，帮助您理解消费失败后的消息处理逻辑，并选择合适的消息处理策略。重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试...
收发定时消息
本文提供使用TCP协议下的.NET SDK收发定时消息的示例代码。目前支持的地域包括公网、华东1（杭州）、华北2（北京）、华东2（上海）、华南1（深圳）。...} } } 订阅定时消息 定时消息的订阅与普通消息订阅一致，更多信息，请参见 订阅消息。
队列使用手册
并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。echo"DeleteMessage Failed:".$e;return;} 步骤五：删除队列 Sample里最后会删除这个测试队列。try {$this->client->deleteQueue($...
技术支持
实时计算控制台功能主要包括：工作空间购买流程 工作空间创建流程 工作空间扩缩容流程 创建与管理项目空间流程 负责实时计算Flink版产品功能使用咨询服务、产品缺陷问题处理、集群稳定性问题处理。协助排查实时计算Flink版产品依赖的其他...
创建FC Sink Connector
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为函数计算的消息流出任务。前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买和部署实例。您已开通函数计算服务，...
通过Knative事件驱动实现消息发送
步骤一：部署消息处理 消息处理用于接收事件驱动发送的弹幕请求，并根据请求数进行自动扩缩容，待弹幕消息处理完成之后将结果发送到表格存储。部署之前，需要先确认当前无工作负载，以便观察部署之后的结果。在 容器服务管理控制台 确认...
订阅消息
本文介绍如何通过 云消息队列 RocketMQ 版 的C/C++ SDK订阅消息。订阅方式 云消息队列 RocketMQ 版 支持以下两种订阅方式：集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息，一个Group ID有3个...
监控报警
监控项说明 说明 消息堆积量、消息处理延迟时间、已就绪消息量、已就绪消息排队时间等消息堆积场景相关的指标的详细说明，请参见 堆积场景指标说明。指标分类 监控指标 MetricName 统计方法 单位 Instance 实例API调用TPS InstanceApi...
应用场景
与传统架构不同，云消息队列 Kafka 版 以及Storm、Samza、Spark等数据处理引擎的出现，就是为了更好地解决这类数据在处理过程中遇到的问题，数据处理模型能实现在数据流动的过程中对数据进行实时地捕捉和处理，并根据业务需求进行计算分析...
收发定时消息
本文提供使用TCP协议下的C/C++ SDK收发定时消息的示例代码供您参考。定时消息可以做到在指定时间戳之后才可被消费者消费，适用于对消息生产和消费有时间窗口...} 订阅定时消息 定时消息的订阅与普通消息订阅一致，更多信息，请参见 订阅消息。
订阅关系（Subscription）
定义 订阅关系是 云消息队列 RocketMQ 版 系统中消费者获取消息、处理消息的规则和状态配置。订阅关系由消费者分组动态注册到服务端系统，并在后续的消息传输中按照订阅关系定义的过滤规则进行消息匹配和消费进度维护。通过配置订阅关系，...
常见错误码参考
错误码 SQLSTATE 错误消息格式 处理建议 1005 HY000 Can't create table '%s' 无法创建表，请根据错误消息检查建表语句的用法是否正确。1006 HY000 Can't create database '%s'(errno:%d-%s)无法创建Database,请根据错误消息，检查输入的...
什么是云消息队列 Confluent 版？
业务监控与告警：每个Consumer Group都可以针对消息的堆积量情况设置监控与告警，帮助您及时发现问题。OpenAPI：提供了一整套完备的管控类OpenAPI，用于实现一系列的资源管理和运维功能。开箱即用：提供的是完全托管的Confluent Platform...
版本说明
事务消息：优化事务消息异常场景处理逻辑。广播消费：支持定制消费者启动时的消费位点。Push消费：支持消费速度限流；消费线程数异常场景逻辑优化。日志配置：日志默认路径变更；增加日志级别；增加对环境变量的支持。客户端创建：异常场景...
应用场景
本文为您介绍 云消息队列 RabbitMQ 版 的应用场景，以便您更好地判断如何在业务中使用 云消息队列 RabbitMQ 版。异步解耦 云消息队列 RabbitMQ 版 可用于单体应用被拆解为微服务后不同微服务间的通信。应用解耦的好处是不同应用的迭代不再...
接入方式
2.顺序消费 Linkedmall消息在发送时保证按分区有序，如您需要按序消费消息，请务必参考示例代码中的消费部分，对每个分区内的消息串行处理/拉取消息 ConsumerRecords,String>records=consumer.poll(Duration.of(1,ChronoUnit.SECONDS));...
产品简介
平台提供通讯录管理、即时通讯、音视频、消息触达、应用接入能力，支持专有云部署。助力解决三融五跨组织数字化协同、沟通和统一工作门户的问题。客户群体 金融行业：助力监管机构、银行、证券、保险行业企业构建专有的移动数字化协同体系...
连接云端应用程序
以下步骤描述云端应用程序接收到设备消息后，在处理设备消息上存在错误时，复制设备的消息并发送到方案商的调试程序进行问题定位的方法。设备商使用阿里云账号和密码登录 物联网平台控制台。在 实例概览 页面，找到对应的实例，单击实例...
内容分割
本文介绍如何使用数据清洗功能中的内容分割模板处理消息数据。背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息...
主题使用手册
消息已经处理完成，从队列里删除这条消息。queue->deleteMessage($receiptHandle);echo"DeleteMessage Succeed!break;} catch(MessageNotExistException$e){ echo"No New Message;} catch(MnsException$e){ echo"Process Failed:".$e;} ...
内容映射
本文介绍如何使用数据清洗功能中的内容映射模板处理消息数据。背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息...
内容富化
本文介绍如何使用数据清洗功能中的内容富化模板处理消息数据。背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息...
消息队列
任务A作为生产者循环向消息队列发送消息，任务B作为消费者循环从消息队列接收消息，一般情况下，消费者处理数据是要花费很长时间，所以会导致消息产生的速度大于消息处理的速度，使得消息队列溢出。所以可以通过调整任务B优先级大于任务A来...
队列使用手册
本文介绍如何使用C#SDK创建队列、发送消息、接收和删除消息、以及删除队列。步骤一：准备工作 下载最新版C#SDK，解压后将工程导入到VisualStudio。找到工程里四个项目中SDK所在的项目 AliyunSDK_MNS，单击鼠标右键，选择重新生成，在 bin ...
消息重试
云消息队列 RocketMQ 版 支持消息重试功能，即Consumer消费某条消息失败或消费超时，云消息队列 RocketMQ 版 会根据消息重试机制重新投递消息。本文介绍 云消息队列 RocketMQ 版 分别在HTTP协议和TCP协议下的消息重试策略。注意事项 一条...
iOS端推送消息失败的排查步骤
推送系统只负责消息的送达，需要用户自行处理消息数据并根据需求做展示。可参考下 官网 Demo 对消息处理的方式。消息接收监听，需在通知中心注册事件名为 CCPDidReceiveMessageNotification 的广播监听，具体参考：iOS API 介绍。iOS 消息...
动态路由
本文介绍如何使用数据清洗功能中的动态路由模板处理消息数据。背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息...
监控报警
Byte InstanceStorageSize userId、instanceId Sum 已就绪消息排队时间（Group）millisecond ReadyMessageQueueTime userId、instanceId、groupId Maximum 已就绪消息排队时间（Group&Topic）millisecond ReadyMessageQueueTimePerGidTopic...
常见问题
计费相关 删除队列后，是否继续计费 删除主题后，是否继续计费 消息问题 消息服务MNS的订阅成功后收不到消息 删除消息时报“message not exist”的错误 HttpEndpoint接口接收不到消息 使用消息服务MNS的HTTPEndpoint接口时签名认证失败 ...
主题使用手册
本文介绍如何使用C#SDK中的sample代码，完成创建主题、创建队列、创建订阅和发布消息等操作。步骤一：准备工作 下载最新版C#SDK，解压后将工程导入到VisualStudio。找到工程里四个项目中SDK所在的项目 AliyunSDK_MNS，右击项目名，选择重新...
下行消息
消息下发操作步骤 进入CMNS-下行消息页面 点击“消息发送”按钮 在“应用”下拉框选择您需要发送消息的客户端应用 在“类型”单选框选择您需要发送消息的类型 透传消息是消息直接发送至客户端应用，由客户端应用决定消息处理 通知消息是指...
RocketMQ全链路追踪解决方案
在分布式应用系统中，多个服务间的交互涉及复杂的网络通信和数据传输，往往一次请求需要多个内部服务间的相互调用才能完成，任何一个环节出现问题都可能导致外部服务任务执行失败或延时，且很难快速定位问题根源。链路追踪功能可在多个服务...
Kafka触发器
常见问题 为什么Kafka触发器触发函数的次数与消息的条数不一致？事件总线EventBridge会根据您的攒批配置将消息推送给函数处理，不能通过函数调用次数判断消息是否全部被消费。您可以在函数中打印日志来确认消费的消息情况。更多关于攒批...
使用云消息队列 Kafka 版时出现消息堆积
使用 云消息队列 Kafka 版 时，可能会发现Group中出现消息堆积。本文介绍如何判断消息堆积是否属于正常情况，以及处理方法。客户端消费流程 了解客户端消费流程，有助于理解消息是否堆积。一般情况下，客户端消费流程大致如下：判断消息...
数据转发到AMQP服务端订阅消费组
直接使用AMQP服务端订阅实时获取设备数据，只能从产品维度获取所有设备的数据，使用消息转发的云产品流转功能，可以将全部设备或指定设备发送到物联网平台的消息，先经过SQL表达式处理和过滤，再转发到AMQP服务端订阅消费组，通过AMQP客户...
查询MNS日志
阿里云消息服务（MNS）日志推送到日志服务后，可进行实时查询，本文介绍实时查询的常用场景及操作步骤，您也可以通过多个关键字组合方式实现更加复杂的查询。前提条件 已采集到MNS日志。具体操作，请参见 MNS日志。已配置索引。具体操作，...
常见问题
推送消息的时候设备离线怎么处理 Android端辅助通道收到推送通知后单击通知无法打开相应Activity Android端推送通知打开指定Activity时如何获取推送通知参数 移动推送在线收不到通知 Android端辅助通道和弹窗问题的排查步骤 厂商消息分类...
基本概念
消息堆积量=处理中消息量+已就绪消息量，具体的指标含义，可参考以下说明：上图表示指定主题的某一队列中各消息的状态，云消息队列 RocketMQ 版 将处于不同处理阶段的消息数量和耗时进行统计，这些指标可直接反映队列中消息的处理速率和...
- 产品推荐
- 这些文档可能帮助您