默认配置映射关系
同构消息映射关系 当消息的流入方和流出方为同一服务类型时，配置详情，请参见下文：基于事件流实现RocketMQ消息路由 基于事件流实现Kafka消息路由 基于事件流实现RabbitMQ消息路由 基于事件流实现MNS消息路由 异构消息映射关系 当消息的...
默认配置映射关系
同构消息映射关系 当消息的流入方和流出方为同一服务类型时，配置详情，请参见下文：基于事件流实现RocketMQ消息路由 基于事件流实现Kafka消息路由 基于事件流实现RabbitMQ消息路由 基于事件流实现MNS消息路由 异构消息映射关系 当消息的...
默认配置映射关系
同构消息映射关系 当消息的流入方和流出方为同一服务类型时，配置详情，请参见下文：基于事件流实现RocketMQ消息路由 基于事件流实现Kafka消息路由 基于事件流实现RabbitMQ消息路由 基于事件流实现MNS消息路由 异构消息映射关系 当消息的...
默认配置映射关系
同构消息映射关系 当消息的流入方和流出方为同一服务类型时，配置详情，请参见下文：基于事件流实现RocketMQ消息路由 基于事件流实现Kafka消息路由 基于事件流实现RabbitMQ消息路由 基于事件流实现MNS消息路由 异构消息映射关系 当消息的...
实例事件通知
以 因系统维护实例重启（SystemMaintenance.Reboot）的事件为例，事件通知的JSON格式如下所示。首次发布运维事件，事件处于 已计划（Scheduled）状态。{"id":"2256A988-0B26-4E2B-820A-8A*E5","product":"ECS","resourceId":"acs:ecs:...
版本说明
本文介绍RocketMQ ONS 1.x系列Java SDK的版本信息，包含下载链接、发布时间、更新点等，以便您按需获取适用的Java SDK收发消息。重要 JDK 1.8适用于所有Java ons-client版本，JDK 1.6仅支持ons-client v1.8.4.Final及之前的版本使用。为...
版本说明
本文介绍Java SDK的版本信息，包含使用限制、下载链接、发布时间、更新点等，以便您按需获取适用的Java SDK收发消息。使用限制 JDK 1.8适用于所有Java ons-client版本，JDK 1.6仅支持ons-client v1.8.4.Final及之前的版本使用。为避免升级...
什么是Topic
业务服务器收到物联网平台的消息，确认消息已成功发送。MQTT协议的重要参数，更多参数请参见 MQTT协议规范。消息服务质量（QoS）：QoS=0 代表物联网平台只推送一次消息给订阅者，QoS=1 代表订阅者收到消息后必须返回 puback 给发布者，否则...
消息类型
普通消息 定时和延时消息 顺序消息 事务消息 普通消息 普通消息是指消息队列中无特性的消息，区别于有特性的定时/延时消息、顺序消息和事务消息。TCP Java SDK 收发普通消息的示例代码 发送普通消息（三种方式）发送消息（多线程）订阅消息...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
mPaaS 适配 targetSdkVersion 33
消息推送 如果您接入了消息推送，需要通过自建通道推送消息并在通知栏展示，您需要在 AndroidManifest.xml 中添加该权限：并在合适的时机动态申请该权限，如未申请或用户拒绝该权限，无论您是否 自定义处理消息，自建通道收到的消息都无法...
作为Input接入
云消息队列 Kafka 版 可以作为Input接入Filebeat。本文说明如何在VPC环境下通过Filebeat从 云消息队列 Kafka 版 消费消息。背景信息 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 VPC...
名词解释
如需实现消息幂等，即如果消息重试多次，消费端对该重复消息消费多次与消费一次的结果是相同的，并且多次消费没有对系统产生副作用，在为每条消息设置唯一Message ID的基础上，您还需要在 云消息队列 RabbitMQ 版 的Consumer客户端对消息...
作为Input接入
云消息队列 Kafka 版 可以作为Input接入Logstash。本文说明如何在VPC环境下通过Logstash从 云消息队列 Kafka 版 消费消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 VPC...
作为Input接入
云消息队列 Kafka 版 可以作为Input接入Filebeat。本文说明如何在公网环境下通过Filebeat从 云消息队列 Kafka 版 消费消息。背景信息 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 ...
新零售电子价签解决方案（MQTT）
新零售电子价签解决方案由阿里云 云消息队列 MQTT 版 推出，通过MQTT以实现商场超市、公共场所电子标签、多媒体屏幕的数据更新管理。本文将以电子价签为例详细描述该解决方案的系统架构、数据流设计以及注意事项，其他类似行业可参考该方案...
作为Input接入
云消息队列 Kafka 版 可以作为Input接入Logstash。本文说明如何在公网环境下通过Logstash从 云消息队列 Kafka 版 消费消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 ...
Exactly-Once投递语义
例如，当您的消费端完成一条消息的消费处理后出现异常宕机，而消费端重启后由于消费的位点没有同步到消息系统的服务端，该消息有可能被重复消费。业界对于Exactly-Once投递语义存在很大的争议，很多人会拿出“FLP不可能理论”或者其他一致...
获取MQTT客户端在线状态
业务应用一般部署在阿里云的服务器上，业务应用通过向后端存储消息队列订阅这条消息来获取所有客户端的上下线动作。该方式属于异步感知客户端的状态，且感知到的是上下线事件，而非在线状态，云端应用需要根据事件发生的时间序列分析出客户...
通用WebSocket接入指南
回执消息格式：业务消息协议：消息内容：6{"messageId":"msg_1659937198426_687"} 消息格式：Text类型的DataFrame（字符串，编码：UTF-8）回执消息会带上对应消息的messageId，发送方可以根据是否收到回执消息才判断接收方是否成功接收到...
MQTT客户端上下线事件数据流出
业务应用一般部署在阿里云的服务器上，业务应用通过向后端云产品订阅这条消息来获取所有客户端的上下线动作。该方式属于异步感知客户端的状态，且感知到的是上下线事件，而非在线状态，云端应用需要根据事件发生的时间序列分析出客户端的...
消息发送重试和流控机制
消息重复问题：因远程调用的不确定性，当 云消息队列 RocketMQ 版 客户端因请求超时触发消息发送重试流程，此时客户端无法感知服务端的处理结果，客户端进行的消息发送重试可能会产生消息重复问题，业务逻辑需要自行处理消息重复问题。消息...
订阅者最佳实践
本文主要介绍 云消息队列 Kafka 版 订阅者的最佳实践，帮助您减少消费消息出错的可能性。消费消息基本流程 云消息队列 Kafka 版 订阅者在订阅消息时的基本流程为：Poll数据→执行消费逻辑→再次Poll数据，详情参见下图。负载均衡 每个 ...
应用迁移概述
如果您的应用已经部署到生产环境并处于正常运行状态，为了保持业务不中断运行，并且不发生数据丢失，您可以采用平滑迁移的方式将应用迁移至SAE。迁移至SAE的价值 SAE为应用部署提供了灵活的启动参数配置、可视化的部署流程、优雅上下线服务...
降低实例配置
如果您的 云消息队列 Kafka 版 实例的公网流量消耗远小于购买的公网流量配置，或者分区的使用量远小于购买的分区数量，您可以降低公网流量和分区数量配置，从而节约成本。本文介绍如何在 云消息队列 Kafka 版 控制台降低实例的公网流量、...
配置自动调优
动态参数更新下业务中断时间较之作业整体重启缩小30%-98%，具体依赖于作业状态和逻辑，目前仅支持并发的修改。详情请参见 动态更新作业参数。如果您使用了DataStream作业或SQL自定义的连接器，请确认作业代码中未配置作业并发度，否则智能...
变更消息配置
您可以按照业务需求调整消息保留时长、最大消息大小、消费位点保留时间和SSL证书算法位数。前提条件 您已购买 云消息队列 Kafka 版 实例，且实例处于服务中状态。操作步骤 登录 云消息队列 Kafka 版 控制台，在 概览 页面的 资源分布 区域...
短信发送状态回执错误码
isv.DOMESTIC_NUMBER_NOT_SUPPORTED 国际/港澳台消息模板不支持发送境内号码 原因：国际/港澳台消息模板仅支持发送国际、中国港澳台地区的号码。解决方案：如果要发送中国内地短信，请申请国内消息短信模板。isv.DENY_IP_RANGE 源IP地址...
事务消息
事务消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 分布式事务的诉求 分布式系统调用的特点为一个核心业务逻辑的执行，同时需要调用多个下游业务...
回执消息简介与配置流程
云通信的所有业务消息都支持MNS消息服务向外发送。用户在 ChatApp消息服务控制台 启用MNS消息服务订阅指定的消息类型（MessageType）时，系统会自动生成该类型的独立消息队列及名称（QueueName）。您可使用此消息队列名称（QueueName）和...
ECS系统事件概述
系统事件由阿里云定义，用于记录和通知云资源的信息，例如运维任务执行情况、资源是否出现异常、资源状态变化等。说明 阿里云有众多产品支持系统...对于有重启计划的系统事件，设置响应系统事件，实例的重启时间，请参见 修改预约重启时间。
EMR Kafka磁盘故障运维
业务场景 Kafka将日志数据存储到磁盘中，当磁盘出现故障时，会导致磁盘IO能力下降、集群吞吐下降、消息读写延时或日志目录offline等问题。这些情况有可能影响到线上业务平稳运行、数据丢失、Kafka集群容错能力下降，单块盘故障甚至有可能...
网络异常自动恢复
由于服务端升级、服务端重启、网络抖动等原因，服务端和客户端的网络连接可能会断开。本文介绍如何在客户端设置Connection和Topology自动恢复，使Connection和Topology在网络连接断开后自动恢复，避免断连对您的业务造成影响。触发原因 ...
MQTT和RocketMQ进行数据互通（客户端上下线通知）
MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息，云消息队列 MQTT 版 支持将该条消息数据导出至其他阿里云产品，并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的 云消息队列 RocketMQ 版 数据互通...
使用前必读
旧版公共实例已不支持资源规格扩容，如果资源规格不足，物联网平台提供实例迁移功能，可帮助您将旧版公共实例下产品、设备和消息转发数据迁移到 同账号同地域 下的 标准型 企业版实例中使用，降低迁移影响和系统改造成本。本文介绍实例迁移...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的Java SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示。...
如何快速测试云消息队列 Kafka 版服务端是否正常？
在创建并部署 云消息队列 Kafka 版 实例后，您可以使用 云消息队列 Kafka 版 控制台直接发送消息，快速测试服务端是否正常。前提条件 您已创建并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。操作流程 快速测试 云消息队列 ...
阿里云Elasticsearch实例FAQ
本文列举了阿里云Elasticsearch（ES）相关的常见问题，包括购买、退订、配置、访问、查询、写入、插件、分词、日志、重启、负载或状态异常、备份与恢复、监控报警等相关问题。常见问题概览 购买或退订实例问题 购买ES实例时选错配置，如何...
回执消息配置
云通信的所有业务消息都支持MNS消息服务向外发送。用户在 短信服务控制台 启用MNS消息服务订阅指定的消息类型（MessageType）时，系统会自动生成该类型的独立消息队列及名称（QueueName）。您可使用此消息队列名称（QueueName）和消息类型...
设置可维护时间窗口
默认可维护时间窗口为 21:00~22:00(Asia/Shanghai UTC+8)，您可以根据业务规律，将可维护时间窗口设置在业务低峰期，以免维护过程中可能对业务造成的影响。只读从实例不支持单独设置可维护时间窗口和小版本自动升级策略，其可维护时间窗口...
- 产品推荐
- 这些文档可能帮助您