映射关系 MQTT资源 其他阿里云产品 其他阿里云产品资源 数据包定义 MQTT Topic 云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 的Topic MQTT与RocketMQ的消息结构映射 更多信息 如需了解控制台上的操作，请参见 数据流入规则管理。
对于传统企业的服务化转型来说，使用分布式框架不是银弹，在解决了传统的单块架构系统随着业务需求的快速变化而面临的挑战后，分布式架构也为研发和运维增加了更大的复杂度和管理成本，基于分布式框架来进行架构改造的应用和业务通常会面临...
本文以单直播间、一名老师、两名学生的场景为例，说明如何使用 云消息队列 MQTT 版 实现直播互动消息、禁言、成员上下线通知以及系统消息通知，其中，老师和学生的客户端以HTML网页为例，后端应用以Java为例。背景信息 在直播互动的场景下...
消息收发为 云消息队列 MQTT 版 最基本的功能，云消息队列 MQTT 版 支持终端和云端服务接入 云消息队列 MQTT 版 服务器，实现终端和终端、终端和云端的消息通信。本文介绍消息收发功能的基本场景和示例代码。背景信息 云消息队列 MQTT 版 ...
本文介绍 SOFAStack 消息队列的系统部署架构，方便您更好地理解消息队列的高可用性。消息队列在任何一个环境都是可扩展的，生产者必须是一个集群，消息服务器必须是一个集群，消费者也同样。集群级别的高可用，是消息队列跟其他的消息...
使用限制 目前仅支持以下操作系统间的迁移：Linux CentOS 7/8 操作系统架构 源操作系统 目标操作系统 X86 CentOS 7.x AnolisOS 7 AnolisOS 8 Alibaba Cloud Linux 2 Alibaba Cloud Linux 3 说明 更多有关Alibaba Cloud Linux信息，请参见 ...
消息发送返回值 同步消息 SendResult 结构体参数名 参数说明 messageId 消息 ID，可以在控制台根据消息 ID 查询到消息的具体轨迹信息，如果发送失败则不会返回消息 ID。topic 消息主题。异步消息 SendResult 结构体参数名 参数说明 ...
同时满足异地容灾、低成本快速扩容的需求，能够解决传统集中式架构转型的困难，并通过打造大规模高可用分布式系统架构，来支撑金融业务创新。同时，SOFAStack 体系内的各个组件已经开始逐步向社区开源：https://github.com/alipay。希望能...
在加入同步功能后，系统架构如下图所示：元数据 处理系统基本的存储和推送功能外，还需要对元数据进行处理，元数据包括用户信息和用户关系等。下面以用户关系进行介绍。用户账号之间的关注关系具有如下特点：变长链表，长度可达亿级别。...
分布式系统将计算任务和数据分布在多个节点上以实现更高的性能、可靠性和可扩展性，当一个节点发生故障或错误时，其他节点可以继续工作，相比于单机系统，架构本身就有较高的节点容错性。但随着服务拆分，更多组件的引入，分布式系统的复杂...
（最终支付中心与下游系统数据一致）下游系统接收消息队列的支付成功的消息。下游系统处理相关业务逻辑。（最终支付中心与下游系统数据一致）分布式事务消息的更多详细内容请参见 消息类型。削峰填谷 流量削峰也是消息队列的常用场景，一般...
在当今的互联网业内，很多大型互联网系统，比如淘宝、支付宝、网商银行等，都已经实现了单元化架构，并从中获益匪浅，更多企业正加入其中。为什么要做单元化，单元化架构能给系统带来什么样的能力。本文结合蚂蚁集团支付宝系统的单元化架构...
3 整体架构设计完成《领域模型地图》《微服务地图》《系统架构设计》《集成方案设计》《微服务接口设计规范》《微服务开发指南》《代码规范》《DevOps规范》《测试规范》乙方完成交付物的提交且交付物满足合同中双方约定的需求范围和内容 7...
您在使用 轻量消息队列（原 MNS）产品时，如果收到系统提示的错误信息，可查阅 错误码 匹配错误信息。对于其他问题，您可根据下列分类匹配问题场景和解决方案。产品介绍 什么是轻量消息队列（原 MNS）如何使用轻量消息队列（原 MNS）轻量...
本项目乙方服务不包括以下内容：应用程序改造、应用程序设计、数据库逻辑结构设计 迁移未明确认定为“范围内”的应用系统 迁移未明确认定为“范围内”的数据 云平台基础架构设施及环境的设计与搭建 实施所需的通信基础架构和组件 安装或...
Message ID Message ID 消息的全局唯一标识，由消息队列系统自动生成，唯一标识某条消息。Message Key Message Key 消息的业务标识，由消息生产者（Producer）设置，唯一标识某个业务逻辑。消息标签 Tag 消息标签，二级消息类型，用来...
奔跑 由于应用程序数量众多、架构高度专业化、用云情况复杂、架构模型多样化，因此需要进行频繁和结构化的系统审查。根据成本、重要性、特定的浪费模式等对系统进行优先级排序。由于需要评估的系统数量众多或结构复杂，需要建立正式的系统...
消息队列 基于 Apache RocketMQ 构建的金融级分布式消息中间件，为分布式应用系统提供异步解耦和削峰填谷的能力，支持多种消息类型与消费模式，并具备高可靠、高吞吐、低延时等金融级特性。任务调度 提供分布式任务调度框架，实现任务的...
半事务消息因系统重启或异常情况导致没有提交，生产者客户端会按照事务异常检查间隔时间进行回查，若超过半事务消息超时时长后没有返回结果，半事务消息将会被强制回滚。您可以通过监控该指标避免异常事务。定时消息最大间隔 包年包月、...
蚂蚁分布式中间件的产品发展路径，一直秉承着引领和拥抱业界先进标准和实践的理念，同时亦能满足传统金融架构的平滑迁移和融合适配，以稳妥应对业务升级变更，并积极应对金融交易系统所面临的服务和数据扩展性、事务一致性、秒级容灾、弹性...
本文介绍 云消息队列 RocketMQ 版 的系统部署架构，方便您更好地理解 云消息队列 RocketMQ 版 的高可用性。云消息队列 RocketMQ 版 在任何一个环境都是可扩展的，生产者必须是一个集群，消息服务器必须是一个集群，消费者也同样。集群级别...
流控行为 当系统触发消息发送流控时，客户端会收到系统限流错误和异常，错误码信息如下：gRPC协议：reply-code：530 reply-text关键词：TOO_MANY_REQUESTS 客户端收到系统流控错误码后，会根据指数退避策略进行 消息发送重试。Remoting协议...
消息路由：在分布式系统中，可以根据用户属性的不同值来决定消息的路由，增强系统对消息的灵活处理能力。安全和审计：在敏感数据传输中，用户属性可以携带审计信息，例如会话ID、用户标识等，有助于后续的安全审计和追踪。MQTT 5.0的用户...
消息 Mesh：传统应用平滑上云 云原生 Mesh 技术让传统应用能够以零成本或低成本的方式享受到分布式架构的技术红利：去中心化、可观测性、异构系统服务治理等。通过消息 Mesh 接管 IBMMQ 流量，实现平滑上云享受分布式架构红利的同时逐步...
普通消息 定时和延时消息 顺序消息 事务消息 普通消息 普通消息是指消息队列中无特性的消息，区别于有特性的定时/延时消息、顺序消息和事务消息。TCP Java SDK 收发普通消息的示例代码 发送普通消息（三种方式）发送消息（多线程）订阅消息...
阿里云架构设计（System Architecture Design）可辅助您完成业务系统的云上架构设计、快速配置和优化资源确保系统高效运行，并协助您进行架构长远规划。
部署架构图 选用的产品 云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 是由阿里巴巴自研并捐赠给Apache基金会，并与开源社区共建的消息中间件，该产品服务于阿里巴巴集团已超过13年，经过交易核心链路反复打磨与历年双十一高并发场景的...
这种体系结构可以提高站点的可扩展性，同时能更轻便地应对企业架构升级和系统拓展。事件驱动架构扩展 下图是订单服务系统的事件驱动架构示例，该架构中 事件总线EventBridge 负责收集各种订单状态的事件后分发事件至目标端。
整体架构 消息 Mesh 化后的整体架构，如下图所示：与原有的消息架构相比，主要的变化有：客户端不再与服务端直连，而是通过 Sidecar 进行请求的中转。对客户端而言，Sidecar 实际上是它唯一能感知到的消息服务端；对服务端而言，Sidecar 则...
既然采用写扩散的方式来记录消息，系统需要：为每个用户创建一个message_inbox，用于储存该用户的消息。为每一条消息创建一个自增的sync_id，用于记录消息的顺序。记录用户在每个客户端上的同步ID。通过对用户在各客户端上的数据进行对比和...
什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）产品提供了两种类型的权限策略：系统策略和自定义策略。系统策略统一由阿里云创建，策略的版本...
方案架构 双模微服务平台通过 SOFA 微服务和 Service Mesh 微服务，提供了既支持 SOFA 框架又支持 Service Mesh 架构的微服务管理和治理能力,解决用户在技术转型期间与未改造的遗留系统相互之间的打通和过渡问题，帮助金融机构平稳地从传统...
消息持久化 云消息队列 RocketMQ 版 会默认对消息进行持久化，即将接收到的消息存储到 云消息队列 RocketMQ 版 服务端的存储文件中，保证消息的可回溯性和系统故障场景下的可恢复性。模型关系 在整个 云消息队列 RocketMQ 版 的领域模型中...
方案架构 因为 云消息队列 RocketMQ 版 具有重试功能且能保证消息不丢失，所以推出此方案来确保DB和缓存数据的强一致性，即在DB和缓存间使用 云消息队列 RocketMQ 版，架构如下图所示。方案优势 云消息队列 RocketMQ 版 有以下优势：巨大的...
本文介绍 云消息队列 RabbitMQ 版 服务端默认的消费重试策略，帮助您理解消费失败后的消息处理逻辑，并选择合适的消息处理策略。消费重试流程 消费重试机制通过在临时性故障发生时自动重新尝试发送或处理消息，提升系统的可靠性和数据一致...
新系统，即云原生架构下，Mesh 是 Pod 里的 Sidecar，但老系统往往没有跑在 K8s 上，就自然不支持 Pod 和 Sidecar 的运维模式，所以我们就得用 Agent 的模式来管理 Mesh 进程，使得 Mesh 能够帮助老架构下的应用完成服务化改造，并支持新...
对于很多大型企业（如阿里巴巴）来说，经过多年的技术演进，系统工具和架构已经高度垂直化，服务器规模也达到了比较大的体量。当服务规模大于一定量（如10000台）时，小概率的硬件故障每天都会发生。这时如果需要人的干预，系统就无法可靠...
混合分布式事务 有些系统在使用数据库保证系统内数据一致的同时，也会使用消息队列作为和其他系统间的消息传递，完成不同系统间的数据一致。例如会员注册服务和邮件发送服务，当用户注册会员成功，需要给用户发送一封邮件，告诉用户注册...
脆弱性识别和分析：识别云上信息系统的部署架构，配置及安全防护等方面的脆弱性。对信息系统的设计方案、安全解决方案等进行静态分析，识别体系结构中存在的脆弱性。采用安全扫描，配置审核等方式识别评估范围内的云上资产的脆弱性。分析...
场景示例 以下图电商交易场景为例，从客户下单到收到商品这一过程会生产一系列消息：订单消息 支付消息 物流消息 这些消息会发送到名称为Trade_Topic的Topic中，被各个不同的下游系统所订阅：支付系统：只需订阅支付消息。物流系统：只需...