API概览
在消息收发模型中，生产者将消息发送至主题，消费者通过订阅指定的主题来消费其中的消息。UpdateTopic 更新主题 更新主题的备注信息。DeleteTopic 删除主题 删除指定主题。ListTopics 查询主题列表 查询指定实例下的主题列表信息。GetTopic...
物联网连接管理技术服务条款
阿里提供服务的SIM卡，您（并应要求其用户）不允许订购公众通信服务（即运营商对消费者提供的套餐、业务包等）。如果发现某些号卡订购了公众通信服务，阿里将有权终止该号卡的所有服务，由此导致的责任和后果由您承担，且阿里有权追究您的...
JMS概述
JMS使分布式应用能够以松耦合、可靠、异步的方式进行通信。云消息队列 RabbitMQ 版 JMS库支持 JMS 1.1。云消息队列 RabbitMQ 版JMS库 云消息队列 RabbitMQ 版 JMS库是 云消息队列 RabbitMQ 版 提供的JMS接口。JMS应用只需变更少量代码，...
全场景解决方案
平滑迁移异构治理 方案架构 双模微服务平台通过 SOFA 微服务和 Service Mesh 微服务，提供了既支持 SOFA 框架又支持 Service Mesh 架构的微服务管理和治理能力,解决用户在技术转型期间与未改造的遗留系统相互之间的打通和过渡问题，帮助...
名词解释
Connection TCP连接，生产者或消费者与 云消息队列 RabbitMQ 版 间的物理TCP连接。具体信息，请参见 Connection和Channel。E Exchange 生产者将消息发送到Exchange，由Exchange将消息路由到一个或多个Queue中。Exchange根据消息的属性或...
消费者（Consumer）
本文介绍 云消息队列 RocketMQ 版 中消费者（Consumer）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 消费者是 云消息队列 RocketMQ 版 中用来接收并处理消息的运行实体。消费者通常被集成在业务系统中，从 云消息...
关键技术竞争力
传统应用现代化：不止于异构应用治理 在传统单体式架构向微服务架构迁移的过程中，随着应用微服务数量的增加，微服务间的通信、监控以及安全性 管理成为新的挑战。服务网格作为应用与基础设施的桥梁，突破传统的 SDK 接入方式，以对应用...
产品优势
Quick BI是一款全场景消费式的BI产品，服务于有数据化转型和提升智能决策和分析能力诉求的企业。相对于业内其他BI产品，本文介绍并汇总了核心产品优势。获得国际ABI领域顶级机构的认可 国内唯一一家 连续四年入选Gartner机构ABI魔力象限的...
配置消息灰度
因为消费者过滤的方式会在每个环境都处理全量的消息，对消息的生产者和消费者压力都比较大，不推荐在生产中使用此模式。开启消息灰度 登录 MSE治理中心控制台，并在顶部菜单栏选择地域。在左侧导航栏，选择 治理中心>应用治理。在 应用列表...
基本概念
Apache Kafka 一款开源的分布式数据流处理平台，可以实时发布、订阅、存储和处理数据流。更多信息，请参见 Apache Kafka。云消息队列 Kafka 版 一款由阿里云提供的Apache Kafka全托管服务，具备免部署、免运维、低成本、高弹性、高可靠、高...
消息队列 RocketMQ 客户端流控设计
限流方式有两种：针对消息订阅者的并发流控 针对消息订阅者的消费延时流控 针对消息订阅者的消费延时流控的基本原理是，每次消费时在客户端增加一个延时来控制消费速度，此时理论上消费并发最快速度为：MaxRate=1/ConsumInterval*...
普通消息
功能原理 什么是普通消息 定义：普通消息是 云消息队列 RocketMQ 版 基本消息功能，支持生产者和消费者的异步解耦通信。普通消息生命周期 初始化 消息被生产者构建并完成初始化，待发送到服务端的状态。待消费 消息被发送到服务端，对消费...
配置消费者鉴权
云原生网关支持为路由配置认证，并对指定的消费者进行鉴权，以允许对应消费者访问路由。本文介绍如何配置消费者鉴权。背景信息 相比全局认证鉴权适用于统一登录认证等ToC场景，路由认证和消费者鉴权模式适用于授权API给合作伙伴等ToB场景。...
消费组监控与告警
背景信息 一个消费组包含多个消费者，每个消费者消费Logstore中的一部分Shard。同一个消费组下面的消费者共同消费一个Logstore中的日志数据，消费者之间不会重复消费数据。Shard数据模型可以简单理解为一个队列，新写入的数据被加到队尾，...
Shape
InlineShapes ActiveDocument.InlineShapes 获取文档中的所有嵌入式图形对象。重要 JS-SDK V1.1.10及以上版本支持此功能。语法 表达式.ActiveDocument.InlineShapes 表达式：文档类型应用对象 示例 async function example(){ await ...
产品简介
内容中台依托支付宝 App 长期沉淀的内容获取、内容质检、内容理解、内容分发、内容消费和数据分析的能力，支持在内容中挂载关联度高的商品，实现内容带货，借助图文、视频、直播等媒介进行商品推广。为客户构建自有内容生态提供全链路辅助...
订阅关系（Subscription）
订阅关系判断原则 云消息队列 RocketMQ 版 的订阅关系按照消费者分组和主题粒度设计，因此，一个订阅关系指的是指定某个消费者分组对于某个主题的订阅，判断原则如下：不同消费者分组对于同一个主题的订阅相互独立 如下图所示，消费者分组...
消费者分组（ConsumerGroup）
本文介绍 云消息队列 RocketMQ 版 中消费者分组（ConsumerGroup）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 消费者分组是 云消息队列 RocketMQ 版 系统中承载多个消费行为一致的消费者的负载均衡分组。和消费者...
什么是物联网平台
阿里云物联网平台是一个集成了设备接入、设备管理、数据安全通信、消息订阅、消息转发和数据服务（存储、分析、过滤、解析、集成等）等能力的一体化平台。向下支持连接海量设备，采集设备数据上云；向上提供云端API，服务端可通过云端SDK...
基础术语
service provider 提供 RPC 服务的应用 服务消费方 service consumer 使用 RPC 服务的应用 服务注册中心 Service Registry 一个独立的应用集群，用来存储和维护所有在线的 RPC 应用地址列表 服务参数 service parameters 服务提供者可被...
基本概念
消息轨迹 在一条消息从生产者发出到消费者接收并处理过程中，由各个相关节点的时间、地点等数据汇聚而成的完整链路信息。通过消息轨迹，您能清晰定位消息从生产者发出，经由 云消息队列 RocketMQ 版 服务端，投递给消费者的完整链路，方便...
消息负载均衡策略
云消息队列 RocketMQ 版 的消息负载均衡策略针对生产者和消费者有所差异。对消费者而言，消息负载均衡策略在一定程度上影响消息堆积。背景信息 随着SDK版本的升级，云消息队列 RocketMQ 版 的负载均衡策略也有所优化，根据SDK版本，负载...
图形
} 嵌入式图形 获取 嵌入式图形对象 获取所选内容中的所有嵌入式图形对象。语法 表达式.ActiveDocument.InlineShapes 表达式：文档类型应用对象 示例 async function example(){ await instance.ready();const app=instance.Application;...
如何处理消息堆积
导航栏中选择 消息轨迹，单击 创建查询任务，选择 按 Message ID 查询，输入对应的信息，发现部分消息已发送至Broker节点，但未投递给下游消费者。可能原因 云消息队列 RocketMQ 版 的消息发送至Broker节点后，配置了Group ID的客户端根据...
产品架构
消费者：与Name Server集群中的其中一个节点（随机）建立长连接，定期从Name Server拉取Topic路由信息，并向提供Topic服务的Master Broker、Slave Broker建立长连接，且定时向Master Broker、Slave Broker发送心跳。Consumer既可以从Master...
产品架构
消费者 Consumer：与 Name Server 集群中的其中一个节点（随机）建立长连接，定期从 Name Server 拉取 Topic 路由信息，并向提供 Topic 服务的 Master Broker、Slave Broker 建立长连接，且定时向 Master Broker、Slave Broker 发送心跳。...
消息轨迹
在分布式应用中，云消息队列 RocketMQ 版 作为全链路中异步解耦的关键服务，提供的消息轨迹数据可有效将业务上下游信息串联起来，帮助您更好地排查异常信息，定位问题。本文介绍消息轨迹的使用场景、云消息队列 RocketMQ 版 定义的轨迹参数...
SOFAMQ 常见问题
上述方式可以查询到消息的具体内容以及消费情况，如果需要追踪一条消息从生产者发出到被消费者消费的整个链路中各个相关节点的时间地点，可以使用消息队列最新的消息轨迹查询功能，具体使用方式请参考 查询消息轨迹。消息队列是否能保证...
查看消费者状态
消息延迟时间：该 Group ID 下消费者群组最早的一条未消费消息的生产时间与当前时间的差值。单元化说明 在 LDC 单元化架构环境下，可以自由切换单元查看消费者状态，如下图所示。查看 Group ID 下单个消费者信息 如该 Group ID 的在线状态...
通过消费组消费数据
通过消费组（ConsumerGroup）消费数据有显著优点，您无需关注日志服务的实现细节及消费者之间的负载均衡、故障转移（Failover）等，只需要专注于业务逻辑。前提条件 已创建RAM用户并完成授权。具体操作，请参见 创建RAM用户并完成授权。已...
通过消费组消费数据
通过消费组（ConsumerGroup）消费数据有显著优点，您无需关注日志服务的实现细节及消费者之间的负载均衡、故障转移（Failover）等，只需要专注于业务逻辑。前提条件 已创建RAM用户并完成授权。具体操作，请参见 创建RAM用户及授权。已...
SDK同步与异步通信模式
同步通信模式 大多数嵌入式平台移植C Link SDK使用同步底层通信模型，能够支持C Link SDK以轮询方式主动收取网络报文。例如嵌入式Linux、Windows系统，以及大部分配备LwIP协议栈通信的RTOS（FreeRTOS系统）等，都支持上层应用主动收取网络...
消费幂等
什么是消息幂等 当出现消费者对某条消息重复消费的情况时，重复消费的结果与消费一次的结果是相同的，并且多次消费并未对业务系统产生任何负面影响，那么这个消费者的处理过程就是幂等的。例如，在支付场景下，消费者消费扣款消息，对一笔...
功能特性
查询消息轨迹：通过消息轨迹，能清晰定位消息从生产者发出，经由消息队列服务端，投递给消息消费者的完整链路，方便定位排查问题。集群消费和广播消费：当使用集群消费模式时，消息队列认为任意一条消息只需要被消费者集群内的任意一个消费...
消息幂等
什么是消息幂等 当出现消费者对某条消息重复消费的情况时，重复消费的结果与消费一次的结果是相同的，并且多次消费并未对业务系统产生任何负面影响，那么这整个过程就实现了消息幂等。例如，在支付场景下，消费者消费扣款消息，对一笔订单...
用户洞察概述
随着互联网技术的发展，企业通过各种途径积累了消费者资产，Quick Audience用户洞察模块旨在通过丰富的用户洞察模型和便捷的策略配置，帮助企业完成消费者多维洞察分析，为后续的消费者运营和触达奠定人群基础。功能简介 用户洞察模块提供...
创建和管理 Topic
Topic 是 SOFAStack 消息队列里对消息的一级归类，消息生产者将消息发送到 Topic，而消息消费者则通过订阅该 Topic 来获取和消费消息。创建 Topic 登录 SOFAStack 控制台。在左侧导航栏，选择 中间件>消息队列>Topic 管理。单击 创建 Topic...
用户洞察概述
随着互联网技术的发展，企业通过各种途径积累了消费者资产，Quick Audience用户洞察模块旨在通过丰富的用户洞察模型和便捷的策略配置，帮助企业完成消费者多维洞察分析，为后续的消费者运营和触达奠定人群基础。功能简介 用户洞察模块提供...
使用设备端SDK接入
创建产品 创建设备 添加物模型 管理消息通信Topic 选择设备端SDK 设备端Link SDK 云云对接（原泛化协议）SDK 基于Alink协议开发的SDK 基于设备端Link SDK开发 您可以在设备中集成物联网平台提供的Link SDK，实现设备接入物联网平台。...
顺序消息
} 获取顺序消息消费重试日志 PushConsumer顺序消费的重试是在消费者客户端进行，服务端无法获取消费重试的详细日志，若消息轨迹中顺序消息的投递结果为失败时，您需要在消费者客户端日志中查看消息重试的最大次数、消费者客户端等信息。...
- 产品推荐
- 这些文档可能帮助您