什么是消息队列RabbitMQ版？
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品。云消息队列 RabbitMQ 版 兼容开源RabbitMQ客户端，解决开源各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等云...
函数概述
SQL分析自身预置了诸多函数，可以满足大部分业务场景的数据处理需求。本文为您介绍SQL分析提供的函数类型及函数使用相关说明。背景信息 SQL分析预置的函数类型如下。函数类型 说明 数据预处理函数 进行平滑、滤波等操作，去除异常数据，...
引擎简介
云原生多模数据库 Lindorm 消息引擎是Lindorm面向IoT、车联网、日志等流式数据提供的数据接入服务，支持业务原始数据高吞吐写入，并基于流引擎的实时处理能力，业务只需做简单开发，即可快速实现数据的ETL并入库到Lindorm宽表引擎。...
消息通知功能说明
激活媒体处理消息通知功能。启用媒体处理消息通知功能步骤 激活媒体处理消息通知功能。媒体处理通过MNS实现转码作业及模板分析作业结束时的消息通知功能，因此激活此功能请先 开通MNS服务。创建MNS通知主题。登录 MNS控制台（选择与媒体...
重置消费位点
业务回溯，纠正处理：由于业务消费逻辑出现异常，消息被错误处理。若您希望重新消费这些已被处理的消息，可以通过重置消费位点快速将消费位点更新到历史指定位置，实现消费回溯。注意事项 重置消费位点的范围是重置指定Group对于目标Topic...
什么是弹性伸缩ESS
弹性伸缩（Elastic Scaling Service，简称ESS），也称为Auto Scaling，其能根据您设定的策略自动调整计算资源数量（即业务所需的实例数量），帮助您应对业务流量波动的同时，提高资源利用率，有效降低成本。本视频以ECS实例为例介绍弹性...
服务协议
阿里云理解并认可，您通过阿里云提供的服务，加工、存储、上传、下载、分发以及通过其他方式处理的数据，均为您的用户业务数据，您完全拥有您的用户业务数据。6.2．就用户业务数据，阿里云除执行您的服务要求外，不进行任何未获授权的使用...
离线异步任务场景
数据源集成 函数计算支持多种数据源触发方式，例如对象存储OSS、消息队列等，帮助业务简化数据源交互处理逻辑。功能原理 当GPU函数部署完成后，您可以选择通过异步调用或异步任务触发离线GPU任务的提交。函数计算默认通过按量GPU实例为您...
系统函数分类
函数分类 数据探索系统函数的类型包含分为以下几种：函数类型 说明 时间函数 处理日期、时间类型数据，实现加减日期、提取日期字段、获取当前时间、转换日期格式等业务处理能力。字符串函数 处理字符串类型数据，实现截取字符串、替换字符...
产品优势
核心消息处理系统采用无状态架构，无单点依赖，消息发送失败可自动重试。架构上难以支持万级的消息规模，消息上下行并发会给系统带来巨大的冲击。无法做到削峰填谷，影响高峰时正常业务运行。安全性 等保2.0版（三级等保），提供多重防护，...
接口和参数说明
本文介绍 云消息队列 MQTT 版 云端Java SDK提供的接口和相关的参数说明。使用说明 公共参数和网络参数可在 ChannelConfig.class 中设置。ChannelConfig.class 路径为 server-sdk-{SDK Version}\com\alibaba\mqtt\server\config ，其中 {SDK...
查看消费者状态
如果消息消费出现异常，您可以在 云消息队列 RocketMQ 版 控制台查看指定Group ID的消费状态，包括消费者在线状态、订阅关系一致性结果、消费堆积相关指标、消费者客户端信息等，帮助您快速定位异常原因。应用场景 消费者状态信息包括在线...
回执消息简介与配置流程
云通信的所有业务消息都支持MNS消息服务向外发送。用户在 语音服务控制台 启用MNS消息服务订阅指定的消息类型（MessageType）时，系统会自动生成该类型的独立消息队列及名称（QueueName）。用户可使用此消息队列名称（QueueName）和消息...
现代IM系统中的消息系统—架构
消息处理服务器对消息先存储后同步，先写入发件箱Timeline（存储库），后写扩散至各个接收端的收件箱（同步库）。消息数据写入存储库后，会被近实时的构建索引，索引包括文本消息的全文索引以及多字段索引（发送方、消息类型等）。对于在线...
回执消息简介与配置流程
云通信的所有业务消息都支持MNS消息服务向外发送。用户在 智能联络中心控制台 启用MNS消息服务订阅指定的消息类型时，系统会自动生成该类型的独立消息队列及名称（QueueName）。您可以使用此消息队列名称和消息类型，通过阿里云 获取...
Topic 与 Tag
在 SOFAStack 消息队列中，Topic 与 Tag 都是业务上用来归类的标识，区分在于 Topic 是一级分类，而 Tag 可以理解为是二级分类。您可通过本文了解如何搭配使用 Topic 和 Tag 来实现消息过滤。背景信息 Topic 和 Tag 的定义如下：Topic：...
测试与验证
基础测试数据非常适合真实业务模型，当然，也可以对基础测试数据进行过滤处理，获取单一业务场景测试数据。采用参数化测试数据 参数化测试数据主要根据业务请求参数，按测试模型场景构建。参数化测试涉及的范围很多，比如需要准备大量用户...
消息服务MNS中HttpEndpoint接口接收不到消息时的排查...
概述 本文主要介绍消息服务MNS中HttpEndpoint接口接收不到消息时的排查方法。排查步骤 请参考如下步骤进行排查。使用 主题HTTP Endpoint本地调试工具 进行调试，检查HttpEndpoint接口接收消息的逻辑是否存在问题。使用该工具可分别针对鉴权...
消息收发计算规格费用
针对高级特性消息：消息发送场景下：顺序消息、定时/延时消息和事务消息的调用次数需要在普通消息基础上乘以5倍倍率。例如，每秒钟发送10条事务消息，则消息发送TPS为10×5=50次/秒。消息消费场景下：顺序消息消费的调用次数需要在普通消息...
内建函数概述
MaxCompute自身预置了诸多函数，可以满足大部分业务场景的数据处理需求。本文为您介绍MaxCompute提供的函数类型及函数使用相关说明。背景信息 MaxCompute预置的函数类型如下。函数类型 说明 日期与时间函数 支持处理DATE、DATETIME、...
典型案例
通用-人事 伙伴客户案例｜阿里云RPA助力制造零售企业降本增效 ——人事场景篇 通用-供应链 伙伴客户案例｜阿里云RPA携手苏州好的全面提升制造行业工作效率 伙伴客户案例｜阿里云RPA携手尚阳科技，助力大型制造零售企业全面提升业务处理效率...
通过可观测性能力进行故障处理最佳实践
根据业务逻辑或指标的变化趋势定位具体原因，例如消息处理耗时变长，则可以查看消费者服务的内存、CPU等是否过载；或查看消费逻辑依赖的下游业务逻辑的运行状态进行进一步分析。生产异常场景实践方案 查看消息发送成功率（rocketmq_send_...
配额与限制
消费不可见时间指的是消息处理+失败后重试间隔的总时长，建议设置时取值比实际需要耗费的时间稍微长一些。消费者长轮询超时时间 取值范围：最小值5秒，最大值20秒。支持用户在取值范围内自定义调整。设置长轮询超时时间后，如果当前服务端...
负载均衡SLB产品家族介绍
NLB 面向海量终端连接、高并发消息服务、音视频传输等业务场景针对性地推出了TCPSSL卸载、新建连接限速、全端口监听等高级特性，在物联网MQTTS加密卸载等场景为用户提供多种辅助手段，是适合IoT业务的新一代负载均衡。更多信息，请参见 ...
消息过滤
在实际业务场景中，同一个主题下的消息往往会被多个不同的下游业务方处理，各下游的处理逻辑不同，只关注自身逻辑需要的消息子集。使用 云消息队列 RocketMQ 版 的消息过滤功能，可以帮助消费者更高效地过滤自己需要的消息集合，避免大量...
可视化MapReduce模型
用户可自行根据业务场景加载子任务对象且该业务对象实现BizSubTask接口*场景案例：*1、从数据库中加载未被处理的客户账户信息*2、构建省份城市地区信息列表，按区域分发任务处理*3、根据业务标签作为子任务分类，如：电器、日用品、食品等*...
可视化MapReduce模型
用户可自行根据业务场景加载子任务对象且该业务对象实现BizSubTask接口*场景案例：*1、从数据库中加载未被处理的客户账户信息*2、构建省份城市地区信息列表，按区域分发任务处理*3、根据业务标签作为子任务分类，如：电器、日用品、食品等*...
邮件推送事件通知概述
适用场景 异步获取邮件推送结果消息，再根据业务需求进行处理，例如重新发送。批量发送邮件，根据邮件推送结果消息异步统计邮件发送结果。监控邮件推送结果，例如大量邮件推送失败时，系统会及时向用户发送通知。邮件推送结果消息通过多种...
基本概念
名词 定义 补充说明或示例 业务领域（业务域）业务领域是基于业务场景与业务规则进行领域划分，抽象出来的业务单元。例如：商品域、交易域、营销域。领域模型 DDD方法论中的领域对象，通过对复杂业务的抽象，梳理出业务领域对象与对象关系...
生产者（Producer）
生产者通常被集成在业务系统中，将业务消息按照要求封装成 云消息队列 RocketMQ 版 的 消息（Message）并发送至服务端。在消息生产者中，可以定义如下传输行为：发送方式：生产者可通过API接口设置消息发送的方式。云消息队列 RocketMQ 版 ...
顺序消息
顺序消息可以保证消息的消费顺序和发送的顺序一致，即先发送的先消费，后发送的后消费，常用于金融证券、电商业务等对消息指令顺序有严格要求的场景。本文介绍 云消息队列 RocketMQ 版 顺序消息的概念、适用场景、实现原理以及使用过程中的...
使用Canal和RocketMQ实现数据库变更订阅处理
Canal可以将变更记录可靠地投递到 云消息队列 RocketMQ 版 中，借助 云消息队列 RocketMQ 版 丰富的消息处理策略实现多样化的业务逻辑。Canal是一个开源项目，仓库地址请参见 Canal。方案介绍 基于Binlog日志实现增量订阅和消费的典型业务...
使用Canal和RocketMQ实现数据库变更订阅处理
Canal可以将变更记录可靠地投递到 云消息队列 RocketMQ 版 中，借助 云消息队列 RocketMQ 版 丰富的消息处理策略实现多样化的业务逻辑。Canal是一个开源项目，仓库地址请参见 Canal。方案介绍 基于Binlog日志实现增量订阅和消费的典型业务...
性能测试技术指南
业务模型 分析 系统有很多业务，每种业务逻辑和业务量是不一样的，消耗系统的资源也不一样，因此业务种类、业务占比决定了系统的处理能力，业务模型在性能测试中起着关键性的作用。以电商场景为例，不同的促销形式和主推的类目决定了不同的...
使用Canal将MySQL的数据同步至云消息队列 Kafka 版
本教程介绍如何使用Canal将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Canal的主要用途是基于MySQL数据库增量日志解析，提供增量数据订阅和消费。Canal伪装自己为MySQL Slave，向MySQL Master发送dump请求。MySQL Master收到dump...
数据迁移
背景信息 传统关系型数据库不适合处理海量数据，如果您的数据存放在传统的关系型数据库且数据量庞大时，可以将数据迁移至 MaxCompute。MaxCompute为您提供了完善的数据迁移方案以及多种经典的分布式计算模型，能够快速地解决海量数据存储和...
广播拉取消息模型
本文介绍如何高效利用该模型实现多消费者并行拉取与处理消息。说明 本文以Java SDK为例介绍广播拉取消息流程，其他语言SDK请参见 新版SDK参考（推荐）。前提条件 安装IDEA 您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。...
概述
Serverless自定义处理 消息集成基于Serverless平台的优势，依托函数计算FC的用户自编码能力，支持用户基于Serverless Function函数计算平台自定义地完成业务逻辑的编写，完成自定义的数据处理分发功能。使用限制 使用消息集成功能时的限制...
设备数据存储和计算实践
事务型在线业务场景 应⽤系统需要使⽤⼀定周期（例如7天）的数据，用于事务型应⽤场景，并且需要分钟级处理要求。经营统计分析场景 数据统计分析需要保持1年至2年的数据周期，并且需要按⼩时或按天得出计算结果。基于⼈⼯智能的分析场景 ...
概述
Serverless自定义处理 消息集成基于Serverless平台的优势，依托函数计算FC的用户自编码能力，支持用户基于Serverless Function函数计算平台自定义地完成业务逻辑的编写，完成自定义的数据处理分发功能。使用限制 使用消息集成功能时的限制...
- 产品推荐
- 这些文档可能帮助您