分布式链路配置
分布式链路模块提供自定义链路配置功能，方便用户快速查看和定位问题，比如应用节点错误率是否过高、应用的响应时间是否能接受等。链路采样配置 链路采样配置支持链路关键字段采集配置、链路采样率配置、链路采样率配置。功能入口 在左侧...
功能与特性概述
云消息队列 RocketMQ 版 的分布式特点和瞬变的网络条件，或者用户应用重启发布的情况下，可能导致消费者收到重复的消息。开发人员应将其应用程序设计为多次处理一条消息不会产生任何错误或不一致性。消息幂等最佳实践请参见 消费幂等。消息...
主题（Topic）
Transaction：事务消息，云消息队列 RocketMQ 版 支持分布式事务消息，支持应用数据库更新和消息调用的事务一致性保障。约束：每个主题只支持一种消息类型。行为约束 消息类型强制校验 云消息队列 RocketMQ 版 5.x版本将消息类型拆分到主题...
消息（Message）
Transaction：事务消息，云消息队列 RocketMQ 版 支持分布式事务消息，支持应用数据库更新和消息调用的事务一致性保障。消息队列 定义：实际存储当前消息的队列。更多信息，请参见 队列（MessageQueue）。取值：由服务端指定并填充。消息...
中间件产品总览
SOFABoot 基于 Spring Boot 自研的开发框架 集成 SOFA 中间件，且中间件可插拔 服务网格 将传统微服务和 Service Mesh 进行融合 对接经典应用服务和容器应用服务 提供丰富的服务治理功能 消息队列 基于 Apache RocketMQ 构建的分布式消息...
开源对比
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品，能够兼容开源RabbitMQ客户端，与开源RabbitMQ相比，能够解决各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等...
可观测性体系概述
作为一款典型的分布式中间件产品，云消息队列 RocketMQ 版 被广泛应用于业务核心链路中，每条消息都关联着核心业务数据的变化，通过可观测能力及时发现问题、定位问题、解决问题对于业务运行是一项重要的保障能力。本文介绍 云消息队列 ...
常见问题
运维管理 容器应用服务常见问题 经典应用服务常见问题 中间件 SOFABoot 常见问题 微服务常见问题 微服务故障排查之 DRM 微服务故障排查之限流 微服务故障排查之 RPC 服务网格-故障排查 消息队列常见问题 任务调度常见问题 分布式链路跟踪...
消息类型
事务消息 事务消息：消息队列提供类似 X/Open XA 的分布式事务功能，通过消息队列事务消息能达到分布式事务的最终一致。半事务消息：暂不能投递的消息，发送方已经成功地将消息发送到了消息队列服务端，但是服务端未收到生产者对该消息的二...
基本概念
发起方 Initiator，分布式事务的发起方负责启动分布式事务，通过调用参与者的服务，将参与者纳入到分布式事务当中，并决定整个分布式事务是提交还是回滚。一个分布式事务有且只能有一个发起方。分组标识 用于在网关上做全局的唯一标识，...
Spring集成
云消息队列 RabbitMQ 版 是集群分布式架构，在 CONNECTION 模式下，创建多个connection可以帮助客户端更好地和集群的多个服务节点连接，更高效地发送和消费消息。参数设置如下：/缓存模式设置为CONNECTION。connectionFactory.setCacheMode...
功能特性
分布式事务（Distributed Transaction-eXtended，简称 DTX）是蚂蚁集团自主研发的金融级分布式事务中间件，支持跨数据库、跨服务以及混合的方式处理分布式应用，具备多种接入模式和金融级配套功能，本文将主要介绍分布式事务的功能特性。...
功能特性
SOFAStack 消息队列在阿里云多个地域（Region）提供了高可用消息云服务。单个地域内采用多机房部署，可用性极高，即使整个机房都不可用，仍然可以为应用提供消息发布服务。消息队列提供 TCP 协议语言接入方式，方便应用快速接入消息队列...
附录：SOFAStack 产品目录
消息队列 SOFAStack 消息队列是基于 Apache RocketMQ 构建的分布式消息中间件，为分布式应用提供异步解耦和削峰填谷的能力，支持多种消息类型，提供高可靠、高吞吐量、高可用、事务一致性的异步通讯能力。产品架构 产品优势 开箱即用 多种...
收发事务消息
消息队列提供类似 X/Open XA 的分布式事务功能，通过消息队列事务消息，能达到分布式事务的最终一致。说明 对于新手用户，建议在正式收发消息前，阅读 Demo 工程来了解搭建消息队列工程的具体步骤。交互流程 事务消息交互流程如下图所示。...
消息队列指标
主要操作如下：搜索设置 正则过滤：输入正则表达式，可以将图表里的 key，按照正则表达式进行过滤。例如：曲线名或表格的列值里有 datasource_1、datasource_2，则搜索 datasource 即可过滤出所有含 datasource 的 key。应用场景包括：接口...
消息堆积
除了异步解耦功能，消息队列还有挡住前端数据洪峰的重要功能，以此保证后端系统的稳定性。这要求消息队列具有一定的消息堆积能力。消息队列能支持 10 亿级别的消息堆积，不会因为消息堆积导致性能明显下降。问题描述 在消息队列控制台的...
2019年
分布式模型子任务详情，增加队列维度，可以看到每台机器缓存的子任务队列。无 优化 Worker因为server负载高被误guarantined，可以自动恢复，不同重启客户端。分布式模型子任务详情，运行中可以真实显示每台机器正在运行的子任务数。Master...
消息队列RabbitMQ版是否支持顺序消息？
不支持。与开源RabbitMQ的单机部署天然支持顺序消息不同，阿里云 云消息队列 RabbitMQ 版 为自研产品，分布式部署，暂不支持顺序消息。
消息轨迹
在分布式应用中，云消息队列 RocketMQ 版 作为全链路中异步解耦的关键服务，提供的消息轨迹数据可有效将业务上下游信息串联起来，帮助您更好地排查异常信息，定位问题。本文介绍消息轨迹的使用场景、云消息队列 RocketMQ 版 定义的轨迹参数...
常见问题
开通分布式事务之后，SOFABoot、Dubbo、消息队列、数据访问代理、RDS、MySQL、Oracle、OceanBase 能否都加入分布式事务？可以，分布式事务已经打通了 SOFABoot、Dubbo、消息队列、数据访问代理、RDS、MySQL、Oracle、OceanBase 之间的事务...
步骤五：到控制台验证
基于 开发单元化应用 中的转账与积分场景，在完成相应的转账或存款等操作后，您可以前往各个产品控制台验证单元化效果：分布式链路跟踪：查看单元间流量走向 分布式事务：查看事务执行情况 消息队列：查看消息轨迹 微服务：按单元推送动态...
延时消息
因为 云消息队列 RabbitMQ 版 的消息是分布式存储的，如果您使用pull模式的 basic.get 方法获取消息，并不能保证正好从存储的节点获取消息。常见问题 为什么实际的延时时间大于设置的延时时间？因为客户端使用了pull模式的basic.get方法...
配置相关
与消息队列配置相关的常见问题如下：消息队列消息在服务器保存多长时间？消息队列消息 Body 的长度限制是多少？消息队列客户端如何设置消费线程数？消息队列消息在服务器保存多长时间？存储的消息最多保存 3 天，超过 3 天未消费的消息会被...
产品架构
本文介绍 SOFAStack 消息队列的系统部署架构，方便您更好地理解消息队列的高可用性。消息队列在任何一个环境都是可扩展的，生产者必须是一个集群，消息服务器必须是一个集群，消费者也同样。集群级别的高可用，是消息队列跟其他的消息...
消息查询
SOFAStack 消息队列提供了三种消息查询的方式，分别是按 Message ID、Message Key 以及 Topic 查询。操作步骤 登录 SOFAStack 控制台。在左侧导航栏，选择 中间件>消息队列>消息查询。在 消息查询 页面，您可单击以下任一页签，然后按页面...
操作链路概述
本文将引导您快速体验 SOFAStack 消息队列，从创建资源、配置接入点到使用 SDK 收发消息。具体操作步骤如下：创建资源 创建工作空间 创建 Topic 创建 Group ID 获取 AK（AccessKey ID）和 SK（AccessKey Secret）获取接入配置 发送消息 ...
使用异常
本节将介绍消息队列常见的使用异常问题及相应的解决方案。无法连接 Broker 客户端启动失败，出现“Can not find name server with endpoint”报错 启动 Producer、Consumer 失败，Group ID 重复 主动订阅消息，获取队列列表失败 消息显示 ...
查看订阅关系
在 SOFAStack 消息队列控制台，您可实时查看 Group ID 和 Topic 之间的订阅关系。本文介绍如何在消息队列控制台查看订阅关系。从 Topic 视角，查看即个 Topic 被哪些 Group ID 订阅了。从 Group 视角，查看某个 Group ID 订阅了哪些 Topic...
10 分钟本地试用公有云消息队列
本节介绍如何快速本地试用公有云消息队列服务。操作步骤 开通消息队列服务。说明 如果已开通服务，可以忽略这一步。如果没有账号，可使用支付宝扫描登录。登录 消息队列产品 页面。在 开通 SOFAMQ 消息队列体验版 页面，单击 确认开通。若...
什么是消息队列RabbitMQ版？
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品。云消息队列 RabbitMQ 版 兼容开源RabbitMQ客户端，解决开源各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等云...
重置消费位点
在左侧导航栏，选择 中间件>消息队列>Group 管理。单击目标 Group ID 操作列的 重置消费位点，然后在 重置消费位点 对话框配置以下信息：Topic：选择重置消费位点针对的 Topic。重置类型：清除所有堆积消息，从最新位点开始消费：若选择...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。说明 对于新手用户，建议在正式收发消息前，阅读 Demo工程 来了解搭建 云消息队列 RocketMQ 版 工程的...
接口和参数说明
SOFAStack 消息队列提供 Java SDK 实现消息发送与订阅，您可通过本文了解消息发送和订阅相关接口的参数说明。通用参数 参数名 参数说明 ENDPOINT 设置 TCP 协议接入点，从消息队列控制台的 概览>接入配置 获取。INSTANCE_ID 设置实例 ID，...
开源RabbitMQ迁移上云
在使用开源RabbitMQ集群时，当您希望能够解决各种稳定性痛点（例如消息堆积、脑裂等问题）、实现高并发、分布式、灵活扩缩容时，您可以将开源RabbitMQ集群迁移至 云消息队列 RabbitMQ 版，本文介绍迁移上云的前提条件、操作步骤、注意事项...
API 概览
消息队列提供以下相关 API 接口。Topic 管理 API 描述 CreateMqSofamqTopic 创建 Topic DeleteMqSofamqTopic 删除 Topic ListMqSofamqTopic 查询 Topic 列表 UpdateMqSofamqTopic 更新 Topic 的读写权限 UpdateMqSofamqTopicRemark 修改 ...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图所示。更多信息，请参见 事务消息。前提条件 您已完成以下操作：下载C...
什么是云消息队列 Kafka 版？
云消息队列 Kafka 版 是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。云消息队列 Kafka 版 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，已成为大数据生态中不可或缺的部分。产品优势 云消息队列 ...
日志配置
本文介绍 SOFAStack 消息队列的客户端日志的打印方式，以及默认和自定义配置。打印客户端日志 消息队列的 TCP Java SDK 基于 SLF4J 接口编程。依赖 log4j 或 logback 作为日志实现的示例代码如下所示。方式一：依赖 log4j 作为日志实现...
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/...
- 产品推荐
- 这些文档可能帮助您