概述
SOFAStack 消息队列（SOFAStack MQ，简称 SOFAMQ）是基于 Apache RocketMQ 构建的分布式消息中间件，并与金融分布式架构 SOFAStack 深度集成，为分布式应用系统提供异步解耦和削峰填谷的能力，支持事务消息、顺序消息、定时消息等多种消息...
中兴通讯的Landing Zone：“一站式”云上管理及治理
中兴通讯向公有云转型 中兴通讯股份有限公司（以下简称“中兴通讯”）是全球领先的综合通信信息解决方案提供商，为全球电信运营商、政企客户和消费者提供创新的技术与产品解决方案。公司成立于1985年，在中国香港和深圳两地上市，业务覆盖...
什么是云消息队列 MQTT 版
在该模型中消息的生产者和消费者都是分布在终端设备，通过MQTT协议连接到 云消息队列 MQTT 版 产品。根据以上两种消息收发模型，可以将使用 云消息队列 MQTT 版 的开发人员分为终端和云端两大类。两类开发人员所需的二次开发内容请分别参见...
功能与特性概述
您可以将应用部署在阿里云ECS、企业自建云，或者嵌入到移动端、物联网设备中与 云消息队列 RocketMQ 版 建立连接进行消息收发；同时，本地开发者也可以通过公网接入 云消息队列 RocketMQ 版 服务进行消息收发。多协议接入 TCP协议：区别于...
查询消息轨迹
消息轨迹是指一条消息从生产者发送到消息队列服务端，再到消费者消费处理，整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息...查询出的消息轨迹图中，您也可以获取到生产者、Topic 与消费者所在的 Zone 信息，如下图所示。
查询消息轨迹
消息轨迹数据 云消息队列 RocketMQ 版 系统中，一条消息的完整链路包含生产者、服务端、消费者三个角色，每个角色处理消息的过程中都会在轨迹链路中增加相关的信息，将这些信息汇聚即可获取任意消息当前的状态。使用说明 所有类型的消息...
功能特性
NTP服务 为资源受限的嵌入式设备，解决无法实时地获取服务端时间的问题。网关与子设备 实现管理子设备、子设备与网关的拓扑关系，对子设备进行监控运维等。设备分发 实现跨地域、跨实例、跨账号分发设备，降低设备接入成本。数据服务 功能 ...
基本概念
当一个参与者被发起方调用，则被纳入到该发起方启动的分布式事务中，成为该分布式事务的一个分支事务。一个分布式事务可以有多个参与者。仓库 仓库（Repository），特指代码仓库。[回到顶部]D DataId 用于全局唯一标识一个属性的字符串，由...
附录：SOFAStack 产品目录
SOFAStack 源于自蚂蚁内部沉淀十多年的金融级分布式中间件技术体系，吸收了支付宝自创立以来在关键金融交易系统锤炼出来的架构实践。SOFAStack 所有的产品技术均经过蚂蚁集团自身严苛的金融场景验证，为金融交易技术保证风险安全的同时，...
ConsumerGroupHeartBeat
请求参数中的Shard实际分配的消费者，与请求参数中的消费者不一致。可能原因是和服务端心跳断开后，Shard已经分配给其他消费者，建议传入空Shard列表。404 ProjectNotExist Project does not exist.Project不存在。404 LogStoreNotExist ...
基本概念
Alibaba Cloud Toolkit 阿里云开发者插件（Alibaba Cloud Toolkit）是一个面向IntelliJ IDEA、Eclipse和Maven平台的免费插件，旨在帮助开发者在本地开发平台（IDE）中更便捷的使用阿里云，从而高效地开发、测试、诊断并部署应用。...
领域模型概述
生产者生产消息并发送至 云消息队列 RocketMQ 版 服务端，消息被存储在服务端的主题中，消费者通过订阅主题消费消息。消息生产 生产者（Producer）：云消息队列 RocketMQ 版 中用于产生消息的运行实体，一般集成于业务调用链路的上游。生产...
Spring集成
背景信息 云消息队列 RocketMQ 版 支持以下消息类型的生产者和消费者与Spring集成：普通消息的生产者和消费者 事务消息的生产者和消费者 顺序消息的生产者和消费者 说明 云消息队列 RocketMQ 版 暂不支持Spring框架下定时消息和延时消息的...
消息过滤
消费者订阅了某个主题后，云消息队列 RocketMQ 版 会将该主题中的所有消息投递给消费者。若消费者只需要关注部分消息，可通过设置过滤条件在 云消息队列 RocketMQ 版 服务端进行过滤，只获取到需要关注的消息子集，避免接收到大量无效的...
动态过滤器（Dynamic Filter）
JOIN是分布式系统中常见的操作，同时也是一个耗时、耗资源的操作，因为其涉及到的Shuffle操作尤其在海量数据场景下，会耗费较多的资源和时间。针对Shuffle操作，MaxCompute可以利用JOIN本身的等值连接属性进行优化。优化思路 一个典型的...
动态过滤器（Dynamic Filter）
JOIN是分布式系统中常见的操作，同时也是一个耗时、耗资源的操作，因为其涉及到的Shuffle操作尤其在海量数据场景下，会耗费较多的资源和时间。针对Shuffle操作，MaxCompute可以利用JOIN本身的等值连接属性进行优化。优化思路 一个典型的...
案例介绍
为了管理维护方便（计算与存储资源分配），本案例中规划了三对项目（每对项目包括开发项目和生产项目）：ODS层项目（dummy_retail_ods_dev和dummy_retail_ods），用于存放从各个业务系统每天同步过来的原始数据.CDM层项目（dummy_retail_...
MNS回调事件通知
MNS提供了队列模型，支持多个生产者和消费者并发访问同一个队列，并能确保某条消息在取出之后的特定时间段内，无法被其他消费者获得。消息被消费后一段时间内不可见，需要用户主动删除，否则该消息会被再次消费。视频点播服务VOD支持通过...
延时消息
如果您希望消息被投递后延迟一段时间被消费者消费，您可以使用 云消息队列 RabbitMQ 版 的延时消息。云消息队列 RabbitMQ 版 原生支持延时消息，使用方式比开源RabbitMQ更简单。什么是延时消息 延时消息是指在指定时间段之后才被消费者消费...
什么是消息服务MNS
寿司店中有多个寿司师傅（生产者）在制作精美的寿司，每一份寿司都是独特的，顾客（消费者）可以从传送带上拿取中意的寿司进行食用（消费）。队列模型消息流 如 图 1 所示，应用系统A（生产者）向队列发送消息，应用系统B（消费者）从队列...
消息过滤
本文描述 SOFAStack 消息队列的消费者如何根据 Tag 在消息队列服务端完成消息过滤，以确保消费者最终只消费到其关注的消息类型。Tag，即消息标签，用于对某个 Topic 下的消息进行分类。消息队列的生产者在发送消息时，已经指定消息的 Tag，...
开源RabbitMQ迁移上云
在使用开源RabbitMQ集群时，当您希望能够解决各种稳定性痛点（例如消息堆积、脑裂等问题）、实现高并发、分布式、灵活扩缩容时，您可以将开源RabbitMQ集群迁移至 云消息队列 RabbitMQ 版，本文介绍迁移上云的前提条件、操作步骤、注意事项...
事务消息
使用规则 生产消息规则 事务消息发送完成本地事务后，可在 execute 方法中返回以下三种状态：TransactionStatus.CommitTransaction：提交事务，允许消费者消费该消息。TransactionStatus.RollbackTransaction：回滚事务，消息将被丢弃不...
基本概念
本文介绍 事件总线EventBridge 使用过程中遇到的常用名词的基本概念和简要描述。CloudEvents 1.0 用标准方式描述事件数据的开源规范，旨在简化事件声明以及跨服务、跨平台的消息投递。以下是CloudEvents 1.0中涉及的术语。更多信息，请参见...
NFS协议
消费者ECS订阅消息队列，读到消息X（文件X生产完毕），此时，消费者ECS再去open这个文件，通过open返回的fd去读取这个文件，则一定能够读到文件X的所有内容。如果消费者ECS在生产者ECS生产完毕之前，就open了文件X，并且持有了fd，当收到...
logstash-input-sls插件使用说明
自动负载均衡：根据消费者数量自动分配shard，消费者增加或退出后会自动进行负载均衡。前提条件 您已完成以下操作：安装logstash-input-sls插件。具体操作步骤请参见 安装或卸载插件。创建日志服务项目和Logstore，并采集数据。具体操作...
基础术语
消息消费者 Consumer 消息消费者，也称为消息订阅者，负责接收并消费消息。Consumer 实例 Consumer instance Consumer 的一个对象实例，不同的 Consumer 实例可以运行在不同进程内或者不同机器上。一个 Consumer 实例内配置线程池消费消息...
消息过滤
消费者订阅了某个Topic后，云消息队列 RocketMQ 版 会将该Topic中的所有消息投递给消费端进行消费。若消费者只需要关注部分消息，可通过设置过滤条件在 云消息队列 RocketMQ 版 服务端完成消息过滤，只消费需要关注的消息。本文介绍消息...
开发HSF应用（SDK）
与生产者相同，消费者的服务属性配置分为Maven依赖配置与Spring的配置。配置服务属性。在 pom.xml 文件中添加Maven依赖。添加 servlet 的依赖-><dependency><groupId>javax.servlet</groupId><artifactId>servlet-api</artifactId>...
消息类型
适用场景 定时消息和延时消息适用于以下场景：消息生产和消费有时间窗口要求：比如在蚂蚁森林场景中，相关低碳行为触发时，会发送一条定时消息，在第二天 7 点定时投递给消费者，产生绿色能量；或者发送一条延时消息，24 小时后产生绿色...
基本概念
具体的指标含义和计算公式如下：分类 指标 定义 计算公式 消息数量指标 处理中的消息（inflight messages）在消费者客户端正在处理，但客户端还未返回消费结果的消息。最晚一条拉取消息的位点－最晚一条提交消息的位点 已就绪的消息（ready...
步骤五：到控制台验证
基于 开发单元化应用 中的转账与积分场景，在完成相应的转账或存款等操作后，您可以前往各个产品控制台验证单元化效果：分布式链路跟踪：查看单元间流量走向 分布式事务：查看事务执行情况 消息队列：查看消息轨迹 微服务：按单元推送动态...
发票常见问题
（2）若消费者未将「跨境电商电子邮件载具」归户手机条形码：电子发票整合服务平台会将「中奖通知信」寄送至境外电商营业人传输至平台存证之消费者电子信箱（即消费者与境外电商平台注册之电子信箱）。查验发票真伪的方法 您可到您所在的...
应用场景
通过集成的 可观测链路 OpenTelemetry 版，为分布式应用的开发者提供完整的调用链路还原、调用请求量统计、链路拓扑、应用依赖分析等工具，帮助开发者快速分析和诊断分布式应用架构下的性能瓶颈，提高开发诊断效率。微服务架构 通过ASM，...
队列服务订阅推送
消费者与消费者组的使用 您可以在Watch API调用中通过HTTP Header声明所使用的消费者与消费者组，或者在各个语言的SDK中，在client初始化时进行声明。相关HTTP Header的key也可以通过Attributes API进行查看。meta.header.group:X-EAS-...
设备接入引导
物联网平台提供了基于多种语言的Paho-MQTT的示例，包括Paho-MQTT的 Android、Java、C（嵌入式版）、C（非嵌入式版）、C#、Python、Rust、Go 等语言。可以根据 Alink协议，对接开发物联网平台的各项功能。模组接入 可以使用支持MQTT、HTTPS...
什么是Topic
时钟同步 NTP服务同步请求和响应的Topic，解决嵌入式设备资源受限，系统不包含NTP服务，端上没有精确时间戳的问题。设备影子 设备影子数据通过Topic进行流转，包括设备影子发布和设备接收影子变更。配置更新 设备主动请求配置信息和物联网...
什么是Quick BI
丰富的集成实践 支持嵌入式分析集成、覆盖单租户及多租户模式，拥有生意参谋及钉钉两个千万级用户平台的集成和服务实践。企业级安全管控 通过ISO安全和隐私体系认证，企业级的中心化和便于协同的安全管控体系。Quick BI都有哪些产品和能力...
MCU+支持MQTT的模组
应用场景：设备的硬件由一个MCU加上一个通信模组构成，设备的应用逻辑运行在MCU上，通信模组支持MQTT功能并提供AT指令给MCU使用，MCU控制模组连接云端服务以及收发数据。本示例中：示例app+SDK+模组对接代码一起的RAM消耗为6KB。对于这样的...
消费-通过消费组实现高可靠消费
过程中不重复（需要消费者配合）。观察到消费进度，以便合理调配计算资源。支持更多渠道日志接入（对银行而言开通网上银行、手机银行、支票等渠道，可以接入更多的用户请求）。您可以通过Logstore消费组解决日志实时处理中的这些经典问题，...
- 产品推荐
- 这些文档可能帮助您