公版APP《软件许可及服务协议》国际版
许可软件由您自下载平台下载取得，您需要遵守下载平台、系统平台、终端厂商对您使用许可软件方式与限制的约定，如果上述第三方确认您违反该约定需要短趣处理的，短趣可能会因第三方要求终止对您的使用许可。在本使用许可终止时，您应停止对...
消息过滤
场景示例 以下图电商交易场景为例，从客户下单到收到商品这一过程会生产一系列消息，按照类型将消息分为订单消息和物流消息，其中给物流消息定义地域属性，按照地域分为杭州和上海：订单消息 物流消息 物流消息且地域为杭州 物流消息且地域...
基本概念
消息堆积 生产者已经将消息发送到 云消息队列 RocketMQ 版 的服务端，但由于消费者的消费能力有限，未能在短时间内将所有消息正确消费掉，此时在 云消息队列 RocketMQ 版 的服务端保存着未被消费的消息，该状态即消息堆积。事务消息 事务...
Android推送失败排查步骤
推送消息在客户端上的路由过程涉及到发送应用内广播，部分设备存在广播拦截，请确认您的设备是否存在该问题：下图是正常情况下的日志，第一条handleRemoteMessage日志说明消息已经到达客户端，第二条AgooMessageReceiver日志表明用户自定义...
使用示例
背景信息 广播消息功能的更多信息，请参见 概述。广播消息 功能基于MQTT接入，开发过程中涉及MQTT接入的代码说明，请参见 MQTT接入。配置流程 初始化。详细内容，请参见 MQTT接入的初始化。配置功能。详细内容，请参见 MQTT接入的配置功能...
概述
RRPC能力 广播通信 设备无需订阅广播Topic，即可收到服务器发送的广播消息。广播通信 设备管理 物模型 基于物模型对设备进行管理，无需关心设备与物联网平台之间的数据交互格式，降低开发成本。物模型开发 设备标签 为设备自定义标识，以便...
UpdateTopicConfig
调用该接口可设置自定义Topic的操作权限，及是否支持消息广播、是否开启代理订阅和是否开启压缩或解压缩。使用说明 一个自定义Topic广播消息时，最多可被1,000个设备订阅。若后续需要新增更多设备订阅该自定义Topic的广播消息，可使用MQTT ...
广播通信
物联网平台支持广播通信，即向指定产品下的全量设备（设备无需订阅广播Topic），或订阅了指定Topic的所有设备发送消息。设备在线，即可收到服务器发送的广播消息。本文以向全量在线设备广播消息为例，介绍广播通信的具体配置流程。背景信息...
概述
物联网平台支持广播通信，即向指定产品下的全量设备（设备无需订阅广播Topic），或订阅了指定Topic的所有设备发送消息。设备在线，即可收到服务器发送的广播消息。本文介绍通过配置C Link SDK，设备端实现广播通信功能。前提条件 已准备...
概述
RRPC 广播通信 设备无需订阅广播Topic，即可收到服务器发送的广播消息。广播通信 设备管理 物模型 基于物模型对设备进行管理，无需关心设备与物联网平台之间的数据交互格式，降低开发成本。物模型 设备标签 为设备自定义标识，以便灵活管理...
运行日志
广播通信功能的例程运行后，您可以在设备端 和物联网平台 查看日志信息。前提条件 已配置C Link SDK的广播通信功能的例程，详细信息，请参见 使用示例。设备端日志 您可以在设备端查看运行结果。连接日志：出现如下日志，表示设备与物联网...
PubBroadcast
调用该接口向指定产品下在线设备发布广播消息。在线设备可指定为所有在线设备或订阅了指定Topic的在线设备。使用说明 您可通过设置 请求参数 中 TopicFullName 值决定广播消息的对象：指定产品下所有在线设备或订阅了指定Topic的在线设备。...
应用场景
云消息队列 Kafka 版 忽略掉文件的细节，可以将多台主机或应用的日志数据抽象成一个个日志或事件的消息流，异步发送到 云消息队列 Kafka 版 集群，从而实现非常低的RT。云消息队列 Kafka 版 客户端可批量提交消息和压缩消息，对生产者而言...
Pub
调用该接口通过自定义Topic向设备发布消息，支持向指定产品下订阅了指定自定义Topic的在线设备发送广播消息。使用说明 发送广播消息时：相关Topic是在设备开发时编码定义的，无需控制台创建。一个Topic默认最多可被1,000个设备订阅。若后续...
Exchange
生产者向 云消息队列 RabbitMQ 版 发送消息时，不会直接将消息发送到Queue，而是先将消息发送到Exchange，由Exchange将消息路由到一个或多个Queue。Exchange根据Binding Key、Routing Key以及Headers属性路由消息。Direct Exchange 路由...
广播拉取消息模型
消息服务MNS 支持一对多拉取消息消费模型，以满足一对多订阅、主动拉取的场景。本文介绍如何高效利用该模型实现多消费者并行拉取与处理消息。说明 本文以Java SDK为例介绍广播拉取消息流程，其他语言SDK请参见 新版SDK参考（推荐）。前提...
基本概念
消息堆积 Producer已经将消息发送到 云消息队列 RocketMQ 版 的服务端，但由于Consumer消费能力有限，未能在短时间内将所有消息正确消费掉，此时在 云消息队列 RocketMQ 版 的服务端保存着未被消费的消息，该状态即消息堆积。消息堆积量=...
基础术语
消息堆积 Message accumulation Producer 已经将消息发送到消息队列的服务端，但由于 Consumer 消费能力有限，未能在短时间内将所有消息正确消费掉，此时在消息队列的服务端保存着未被消费的消息，该状态即消息堆积。消息过滤 Message ...
死信Exchange
云消息队列 RabbitMQ 版 的死信Exchange适用于处理被消费者否定应答或重试失败的消息。本文介绍死信Exchange的核心概念、路由流程、配置方式、注意事项和更多信息。核心概念 死信Exchange 用于路由死信消息的Exchange。死信Exchange会根据...
发布者最佳实践
默认情况下，云消息队列 Kafka 版 为了提升可用性，并不保证单个分区内绝对有序，在升级或者宕机时，会发生少量消息乱序（某个分区挂掉后把消息Failover到其它分区）。如果业务要求分区保证严格有序，请在创建Topic时选择使用Local存储。
消息处理时长自适应
背景信息 消息服务MNS 的规范中，每条消息都有个默认的VisibilityTimeout，Worker在接收到消息后，Timeout就开始计时了。如果Worker在Timeout时间内没能处理完消息，那么消息就有可能被其他Worker接收到并处理。Timeout计时的好处在于消息...
迁移上云操作
注意事项 云消息队列 RocketMQ 版 迁移工具按照最小范围粒度仅访问源自建集群如下信息：Topic元数据配置信息 Group元数据配置信息 Topic动态路由注册信息 消费者连接信息及消费堆积信息 不会访问源集群其他信息，也不会对源自建集群的配置...
MQTT和RocketMQ进行数据互通（客户端上下线通知）
MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息，云消息队列 MQTT 版 支持将该条消息数据导出至其他阿里云产品，并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的 云消息队列 RocketMQ 版 数据互通...
配置生命周期挂钩
生命周期挂钩可以暂停由弹性伸缩自动触发的伸缩活动，使ECS实例或ECI实例处于挂起中的状态（即等待的状态），为您保留一段自定义操作的时间以满足特定的部署需求和业务场景，例如预装软件等。直至生命周期挂钩超时结束后，弹性伸缩的伸缩...
配额与限制
云消息队列 RocketMQ 版 对实例的资源配额、实例规格和相关参数进行了约束和规范，您在使用 云消息队列 RocketMQ 版 时不要超过对应的限制值，避免应用出现异常。参数限制 以下参数中各资源的命名及备注等限制值不支持调整，请严格按照规范...
负载均衡
在短连接或者广播语句比较多的场景下，性能提升比较明显。如上图所示，假设 PolarDB 集群中只存在一个RW节点和三个RO节点，在不考虑一致性的前提下，三种场景下的请求路由和数据读取效率如下：非按需建联 用户的一个会话通过数据库代理会与...
开源对比
项目 云消息队列 Kafka 版 Apache Kafka 差异原因 Topic 创建方式 云消息队列 Kafka 版 控制台 云消息队列 Kafka 版 OpenAPI 服务端自动创建（默认不开启）Kafka CLI Kafka Manager 服务端自动创建 云消息队列 Kafka 版 默认通过阿里云控制...
集群消费和广播消费
集群消费和广播消费是 云消息队列 RocketMQ 版 的基本消费模式，您可以在消费者客户端将消费模式设置为集群消费或者广播消费，用于控制同一条消息只能被集群内一个消费者消费到，还是会被集群内每个消费者都消费到。背景信息 云消息队列 ...
消息发送重试和流控机制
本文为您介绍 云消息队列 RocketMQ 版 的消息发送重试机制和消息流控机制。背景信息 消息发送重试 云消息队列 RocketMQ 版 的消息发送重试机制主要为您解答如下问题：部分节点异常是否影响消息发送？请求重试是否会阻塞业务调用？请求重试...
步骤二：创建资源
一个新的应用接入 云消息队列 RabbitMQ 版 服务端，您需要提前创建 云消息队列 RabbitMQ 版 的相关资源，包括创建 云消息队列 RabbitMQ 版 实例、创建Vhost、创建Exchange、创建Queue、绑定Exchange和Queue、创建用户名密码以及获取实例接...
自动创建Topic
说明 您可以在 云消息队列 Kafka 版 控制台的 实例详情 页面的 基础信息 区域查看实例的运行状态和版本。注意事项 建议您仅在迁移场景或测试场景下使用该功能。在生产环境中，不建议开启自动创建Topic功能，如果开启，请务必不要在重大生产...
2.3 门禁设备与手机蓝牙对接协议
广播间隔：两次广播事件之间的最小的时间间隔，一般取值范围在 20ms~10.24s 之间，链路层会在每次广播时间期间产生一个随机广播延时时间加在广播时间里，这样来避免多设备之间的数据碰撞。1.3.2 蓝牙连接参数 连接参数如下：参数 说明 通道...
SDK 版本说明
本文介绍 SOFAStack 消息队列 Java SDK sofamq-client-all 的各个版本信息，包含 SDK 的发布时间、下载链接以及更新点等。3.1.7（2021-04-10）版本号 发布时间 下载链接 3.1.7 2021-04-10 sofamq-client-all 3.1.7 新特性 集成 Metrics/...
Java SDK
本文介绍SchedulerX产品的Java SDK发布的功能变更，包括新增...分布式任务，根任务失败，无法看到失败原因。并行任务子任务列表不能重试子任务。无 1.0.6-compatible，2019-07-02 变更类型 功能描述 相关文档 优化 兼容 schedulerx1.0(DTS)...
历史记录
高负载场景下，消息重复发送会造成秒级任务卡主或应用线程被Interrupt。问题修复 广播任务卡主问题。秒级任务卡主问题。at-least-once-delivery 可能会导致子任务状态无限重试。logcollector 初始化失败，异常抛出来，启动失败。DB清理工作...
什么是AUI Kits
通过超低延时直播、互动消息可以实现音视频与消息同频互动，有效解决音视频和IM延时不一致使买家产生等待，影响购物转化率的问题。支持实时互动能力，例如超低音视频直播、连麦、聊天弹幕等。提供基础的互动组件，例如点赞、分享、关注。...
2019年
前端任务管理列表重新设计，可以看到更多信息。修复分布式拉模型，全局子任务可能不起作用。修复隔离单元环境，如果没有配置Domain，可能还是会启动失败。无 1.0.9，2019-11-28 变更类型 功能描述 相关文档 新增 增加 BlockAppStart 配置。...
Spark常见报错
本文汇总了 AnalyticDB for MySQL Spark作业常见的错误码、报错信息、报错原因和解决办法。您可以参考本文解决报错。报错概览 现象 错误码 报错信息 Spark访问JDBC数据源失败。JDBC_SOURCE_TABLE_NAME_DUPLICATE Both '$jdbcTableName' and...
名词解释
本文主要对 云消息队列 RabbitMQ 版 涉及的专有名词及术语进行定义和解析，方便您更好地理解相关概念并使用 云消息队列 RabbitMQ 版。A Alternate Exchange 备份Exchange，简称AE，用于接收配置了备份Exchange的Exchange路由失败的消息。...
短轮询和长轮询
消息服务MNS 提供短轮询（Short Polling）和长轮询（Long Polling）两种方式来获取队列中的消息。短轮询 创建队列时，长轮询时间设置为0，且发起popMessage请求时 waitSeconds 设置为0。使用短轮询获取队列中的消息，popMessage请求会向...
- 产品推荐
- 这些文档可能帮助您