在线教育视频直播
部署架构图 选用的产品 云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 是由阿里巴巴自研并捐赠给Apache基金会，并与开源社区共建的消息中间件，该产品服务于阿里巴巴集团已超过13年，经过交易核心链路反复打磨与历年双十一高并发场景的...
领域模型概述
消息传输模型介绍 主流的消息中间件的传输模型主要为点对点模型和发布订阅模型。点对点模型 点对点模型也叫队列模型，具有如下特点：消费匿名：消息上下游沟通的唯一的身份就是队列，下游消费者从队列获取消息无法声明独立身份。一对一通信...
消息过滤
应用场景 云消息队列 RocketMQ 版 作为发布订阅模型的消息中间件广泛应用于上下游业务集成场景。在实际业务场景中，同一个主题下的消息往往会被多个不同的下游业务方处理，各下游的处理逻辑不同，只关注自身逻辑需要的消息子集。使用 云...
使用Spring Cloud框架收发消息
sh run_demo.sh 程序打印如下信息，说明接收到控制台程序通过 kafka.output.topic.name 配置的Topic所发送的消息。Send:hello world!Send:hello world!Send:hello world!Send:hello world!登录 云消息队列 Kafka 版 控制台 验证消息收发...
Spring集成
}@Bean public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory){/RabbitMQ消息模板，该模板封装了多种常用的消息操作。return new RabbitTemplate(connectionFactory);} } 消息生产 在RabbitMQService中通过依赖注入...
什么是云消息队列 MQTT 版
云消息队列 MQTT 版 是阿里云推出的一款面向移动互联网以及物联网领域的轻量级消息中间件。如果说传统的消息队列中间件一般应用于微服务之间，那么适用于物联网的 云消息队列 MQTT 版 则实现了端与云之间的消息传递和真正意义上的万物互联...
版本说明
0.6（2020-01-10）发布 SOFAStack 消息队列，是基于 Apache RocketMQ 构建的分布式消息中间件，并与金融分布式架构 SOFAStack 深度集成。支持多种消息类型：普通消息、定时消息、分区顺序消息、事务消息。详见 消息类型。提供专业、可靠、...
什么是云消息队列 RocketMQ 版？
实现削峰填谷的功能，消息中间件需要支持海量的消息堆积能力以及处理好冷热消息混合情况下的流量模型。云消息队列 RocketMQ 版 能够提供亿级消息堆积能力，可以在大促等流量峰值场景下抗住流量洪峰，保证下游业务能够在安全水位内平滑稳定...
概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 消息集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等...
概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 消息集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等...
概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 消息集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等...
消息（Message）
系统默认的消息最大限制如下：普通和顺序消息：4 MB 事务和定时或延时消息：64 KB 使用建议 单条消息不建议传输超大负载 作为一款消息中间件产品，云消息队列 RocketMQ 版 一般传输的是都是业务事件数据。单个原子消息事件的数据大小需要...
消费重试
云消息队列 RocketMQ 版 作为金融级的可靠业务消息中间件，在消息投递处理机制的设计上天然支持可靠传输策略，通过完整的确认和重试机制保证每条消息都按照业务的预期被处理。了解 云消息队列 RocketMQ 版 的消息确认机制以及消费重试策略...
集成概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 Connector生态集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据...
中间件产品总览
Spring Boot 自研的开发框架 集成 SOFA 中间件，且中间件可插拔 服务网格 将传统微服务和 Service Mesh 进行融合 对接经典应用服务和容器应用服务 提供丰富的服务治理功能 消息队列 基于 Apache RocketMQ 构建的分布式消息中间件 ...
消息数、活跃消息数、延迟消息数分别表示哪些消息？
本文介绍控制台上的消息数、活跃消息数、延迟消息数分别表示哪些类型的消息。各消息数的概念如下：消息数：成功发送的和没有发送的所有消息数。活跃消息数：未经处理的消息数。延迟消息数：设置了延迟时间的消息数。
消息超时和重试机制
本文介绍 云消息队列 RabbitMQ 版 服务端默认的消息重试机制，帮助您理解消费失败后的消息处理逻辑，并选择合适的消息处理策略。重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试...
顺序消息
在 云消息队列 RocketMQ 版 中，消息的顺序需要由以下三个阶段保证：消息发送 如上图所示，A1、B1、A2、A3、B2、B3是订单A和订单B的消息产生的顺序，业务上要求同一订单的消息保持顺序，例如订单A的消息发送和消费都按照A1、A2、A3的顺序。...
消息查询
如需查看完整的消息内容，请下载相应的消息，下载的消息最大为10 MB，如果超过10 MB，则只下载10 MB的内容。查询结果最多显示10条消息，且总大小不能超过10 MB。如果3条消息的总大小已经超过10 MB，那么控制台上只显示2条消息。如果10条...
什么是ChatApp 消息服务
ChatApp 消息服务（ChatApp Message Service）是阿里云为全球企业打造的一款高效触达用户的消息引擎，通过与WhatsApp平台合作，使您轻松地使用WhatsApp平台的消息服务，触达全球10亿+用户，通过丰富的消息类型，提升您与客户的互动体验，...
Topic与Tag最佳实践
消息量级是否相当：有些业务消息虽然量小但是实时性要求高，如果跟某些万亿量级的消息使用同一个Topic，则有可能会因为过长的等待时间而“饿死”，此时需要将不同量级的消息进行拆分，使用不同的Topic。总的来说，针对消息分类，您可以选择...
主题（Topic）
定义数据的身份和权限 云消息队列 RocketMQ 版 的消息本身是匿名无身份的，同一分类的消息使用相同的主题来做身份识别和权限管理。模型关系 在整个 云消息队列 RocketMQ 版 的领域模型中，主题所处的流程和位置如下：主题是 云消息队列 ...
顺序消息
如上图所示，消息组1和消息组4的消息混合存储在队列1中，云消息队列 RocketMQ 版 保证消息组1中的消息G1-M1、G1-M2、G1-M3是按发送顺序存储，且消息组4的消息G4-M1、G4-M2也是按顺序存储，但消息组1和消息组4中的消息不涉及顺序关系。...
消息优先级为1，就一定优先吗？
优先级为1的消息就一定比优先级为2的消息更早被消费吗？本文关于该问题进行介绍。消息服务MNS 发送消息时，可以指定消息的优先级权值（取值范围1~16，1为最高优先级，默认优先级为8）。优先级越高的消息，越容易更早被消费。如果顺序发送...
基本概念
具体的指标含义和计算公式如下：分类 指标 定义 计算公式 消息数量指标 处理中的消息（inflight messages）在消费者客户端正在处理，但客户端还未返回消费结果的消息。最晚一条拉取消息的位点－最晚一条提交消息的位点 已就绪的消息（ready...
消息负载均衡策略
云消息队列 RocketMQ 版 的消息负载均衡策略针对生产者和消费者有所差异。对消费者而言，消息负载均衡策略在一定程度上影响消息堆积。背景信息 随着SDK版本的升级，云消息队列 RocketMQ 版 的负载均衡策略也有所优化，根据SDK版本，负载...
仪表盘
堆积消息量（已就绪+处理中）统计指定实例下的消息堆积总量，包括已就绪的消息和处理中的消息。单位：条。处理中消息量 统计在消费者客户端正在处理但客户端还未返回消费成功响应的消息的数量。单位：条。已就绪消息量 统计在 云消息队列 ...
为什么查询到的消息创建时间与设置的消息查询时间点...
问题现象 登录 云消息队列 Kafka 版 控制台，在 消息查询 页面，查询方式 选择 按时间点查询，时间点 设置需查询的时间点，查询到的 消息创建时间 与设置的查询时间点偏差很大，或者查询到的 消息创建时间 值为空值。可能原因 设置的查询...
消息路由
在左侧导航栏，选择 中间件>消息队列>消息路由。单击 创建路由任务，然后在 创建路由任务 对话框配置任务信息：源 Topic：输入需要同步的消息所属 Topic 名称。目标单元：选择消息将被同步到的 Topic 所属单元。目标 Topic：输入消息将被...
MQTT与RocketMQ的消息结构映射
本文针对使用 云消息队列 RocketMQ 版 SDK与 云消息队列 MQTT 版 交互的场景，提供交互中所涉及的消息结构和属性字段的映射关系，方便您更好的理解和组合使用这两个产品。云消息队列 MQTT 版 是一款面向移动端的网关产品，可通过数据互通...
普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。说明 您在调用SDK收发消息时需注意，云消息队列 RocketMQ 版 提供的四种消息类型所对应的Topic不能混用，例如，您创建的普通消息...
主题模型快速入门
接收消息 发布消息成功后，您可以从队列中取出消息，与发布到主题的消息进行对比，确认接收的消息和发布的消息是否一致。本文介绍如何在控制台接收主题推送到队列的消息。在 队列列表 页面，找到目标队列，在其右侧 操作 列选择 更多>收发...
QueueMessage
MNS会尽量让高优先级的消息先出队列，正是因为分布式消息队列的一些特性不能百分之百保证高优先级的消息先被消费。消息类型 延时消息 这类消息发送到队列后，需要经过DelaySeconds指定的时间后才可被消费。发送（batch）send message请求时...
重置消费位点
重置消费位点功能只能重置对消费者可见的消息，不能重置定时中、重试等待中的消息。重试消费位点只能在消费者在线时进行操作。操作步骤 登录 云消息队列 RocketMQ 版 控制台，在左侧导航栏单击 实例列表。在顶部菜单栏选择地域，如 华东1...
消费失败是否支持重试？
重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试机制和关闭消息重试机制。云消息队列 RabbitMQ 版 服务端默认的消息重试机制如下：如果您没有开启Consumer客户端消费消息，则不会...
云消息队列 Kafka 版何时删除旧消息？
当往Kafka Topic中写入数据提示磁盘空间已满或 Queue full 时，为避免因磁盘容量不足而导致机器宕机，进而影响服务可用性，云消息队列 Kafka 版 会根据磁盘使用率的多少，执行不同的消息清理策略。清理策略 磁盘使用率每天凌晨4:00集中删除...
消息检索
目前表格存储不支持单个字段大于2 MB，超过2 MB的消息不会被同步，因此超过该大小的消息也无法在 云消息队列 Kafka 版 控制台的 消息检索 页面检索出来。表格存储中的数据保留时长与 云消息队列 Kafka 版 实例消息保留时长具有相同的数据...
死信消息
死信消息可观测指标 指标说明 指标类型 指标项 Metrics元数据指标 rocketmq_send_to_dlq_messages：每分钟转为死信状态的消息量 云监控项 每分钟转为死信状态的消息量（GroupId&Topic）：SendDLQMessageCountPerGid 每分钟转为死信状态的...
Queue
如果发送消息时不指定消息延时，被发送到普通队列的消息立刻可以被消费，而发送到延时队列需要经过设定的延时时间后才能被消费。QueueURL 格式：http://$AccountId.mns.<Region>.aliyuncs.com/queues/$QueueName。mns.<Region>.aliyuncs....
消费进度管理
消费位点小于最小消息位点时是无效的，相当于消费者要消费的消息已经从队列中删除了，是无法消费到的，此时服务端会将消费位点强制纠正到合法的消息位点。消费位点初始值 消费位点初始值指的是消费者分组首次启动消费者消费消息时，服务端...
- 产品推荐
- 这些文档可能帮助您