钉钉机器人
目前，仅支持信息推送，不支持返回消息处理。节点配置 在业务逻辑编辑页面的 节点 中，选择对应功能节点配置业务流，钉钉机器人配置如下。配置项 说明 节点名称 设置节点名称。支持中文汉字、英文字母、数字和下划线（_），长度不超过30个...
欠费说明
本文为您介绍使用媒体处理服务过程中欠费的原因、欠费处理策略及如何查看欠费金额。欠费原因 以下情况媒体处理服务会产生欠费：场景 欠费原因 您 未购买 媒体处理资源包 当您的阿里云账号的可用额度（包含阿里云账户余额、代金券、优惠券等...
日志管理概述
应用场景 您在收发消息的过程中，是否遇到过以下问题：消息成功发送到队列，但消费端收不到消息，消息去哪儿了？消息被谁消费了、消费了几次？消费端宕机了，消费失败的消息什么时候可以再次被消费？消息发布到主题，Endpoint却迟迟收不到...
订阅消息
class ExampleMessageListener:public MessageListener { public:Action consume(Message&message,ConsumeContext&context){/此处为具体的消息处理过程，确认消息被处理成功请返回CommitMessage。如果有消费异常，或者期望重新消费，可以...
合规&认证
Dataphin作为平台工具提供商，只会严格执行用户的指示处理相关业务数据，除按与用户协商一致或执行明确的法律法规要求外，不对用户业务数据进行任何非授权的使用或披露。用户应对业务数据来源、内容及处理数据的合法性负责，请谨慎判断数据...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Node.js SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装Node.js SDK。更多信息，请参见 ...
RocketMQ全链路追踪解决方案
process PushConsumer中 MessageListener 接口对消息的处理过程，span以消息进入 MessageListener 为开始，离开 MessageListener 时结束。以上几个span的关系如下：receive span未启用时：process span为send span的子级。receive span启用...
使用函数计算实现消息数据清洗
消息数据清洗功能提供常见的消息处理模板，如消息分割、动态路由和消息富化等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。本文介绍 云消息队列 RocketMQ 版 消息数据清洗模板的类型和使用方式。背景信息 消息...
使用函数计算实现消息数据清洗
消息数据清洗功能提供常见的消息处理模板，如消息分割、动态路由和消息富化等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。本文介绍 云消息队列 RocketMQ 版 消息数据清洗模板的类型和使用方式。背景信息 消息...
消息查询
重要 若按Topic查询消息，请注意以下几点：按Topic查询属于范围查询，获取Topic下符合时间条件的所有消息，消息量大，建议尽量缩短查询区间。按Topic查询消息量大，采用分页展示。查询结果说明 您可以在控制台的 消息查询 页面看到查询到的...
可观测性体系概述
作为一款典型的分布式中间件产品，云消息队列 RocketMQ 版 被广泛应用于业务核心链路中，每条消息都关联着核心业务数据的变化，通过可观测能力及时发现问题、定位问题、解决问题对于业务运行是一项重要的保障能力。本文介绍 云消息队列 ...
基本概念
本文将向您介绍文件存储NAS产品的使用架构以及涉及的基本概念，以便于您更好地理解和使用NAS。文件存储NAS使用架构 文件存储NAS是一个可共享访问、弹性扩展、高可靠、高性能的分布式文件系统。可支持上千台弹性计算ECS、容器服务ACK等计算...
上下线通知规则管理
业务应用一般部署在阿里云的服务器上，业务应用通过向后端云产品订阅这条消息来获取所有客户端的上下线动作。流程说明 规则限制 限制项 限制值 说明 单实例规则数量 100 如果默认限制不满足，请联系 云消息队列 MQTT 版 技术支持，钉钉群号...
MQTT和RocketMQ进行数据互通（跨产品数据流出）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
节省计划适配客户业务最佳实践
场景一：平稳型业务 场景说明：业务常年处于一个相对平稳的趋势，虽然可能会释放和创建实例，但是较长时间内的使用量是相对稳定的。平稳型业务特点如下：总体业务负载量比较稳定，无明显的波峰波谷，同时所有业务线使用都比较稳定。平稳型...
什么是RRPC
消息体为用户传入的数据，Topic为物联网平台定义的Topic，且携带RRPC消息ID。设备收到下行消息后，按照指定Topic格式（包含之前物联网平台下发的唯一RRPC消息ID），回复一条RRPC响应消息给物联网平台。物联网平台提取RRPC消息ID，和之前的...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的Node.js SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示...
Serverless后付费实例计费说明
计费公式 每小时消息收发费用＝消息收发次数累计值（次）×消息收发单价（元/次）消息收发次数计算规则 消息收发次数=接收消息次数+投递消息次数 接收消息次数：表示Queue接收到消息的条数，例如Exchange收到一条消息通过路由计算到3个...
收发定时消息和延时消息
背景信息 延时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时消息。定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端...
什么是Topic
设备、业务服务器、物联网平台的通信过程请参见 使用Topic通信。MQTT（Message Queuing Telemetry Transport）是一种基于 发布/订阅 模型的消息传输协议，具有低开销、高拓展、协议简单、双向通信等优点，可以利用较少的设备资源和网络资源...
消息堆积
常见的消息堆积相关问题如下：如何处理消息堆积？除了异步解耦功能，消息队列还有挡住前端数据洪峰的重要功能，以此保证后端系统的稳定性。这要求消息队列具有一定的消息堆积能力。消息队列能支持 10 亿级别的消息堆积，不会因为消息堆积...
欠费说明
消息服务MNS 处于欠费状态...当您的账户余额不足以支付账单金额，消息服务MNS 处于欠费状态超过7天，阿里云将停止 消息服务MNS 的服务，即您不能再访问API，未处理的消息数据将按队列设置的消息过期时间自动过期释放，被释放的数据不可恢复。
媒体处理常见问题
媒体处理创建消息主题出现“Only one topic can be created！错误。目前媒体处理每个用户只能开一个管道，无法创建多管道，所以会出现Only one topic can be created！这个错误。开启管道或添加管道，请参见 创建管道。媒体处理服务中...
消息类型
支付宝扣款执行前，发送一条半事务消息，扣款事务执行成功后，将消息状态更新为 Commit，余额宝系统订阅消息队列的扣款消息，做相应的存款业务处理。交互流程 事务消息交互流程如下图。事务消息发送步骤如下：发送方将半事务消息发送至消息...
消费者分类
建议使用SimpleConsumer消费类型，可以在消费时自定义消息的预估处理时长，若实际业务中预估的消息处理时长不符合预期，也可以通过接口提前修改。需要异步化、批量消费等高级定制场景：SimpleConsumer在SDK内部没有复杂的线程封装，完全由...
日志字段详情
队列消息操作日志 队列消息操作日志是指操作队列消息所产生的日志，例如发送消息、消费消息、删除消息等操作。一条消息操作日志中包含多个字段，每个字段都有自己的含义。根据操作的不同，消息操作日志所包含的字段也不相同。以下分别介绍...
消费进度管理
业务回溯，纠正处理：由于业务消费逻辑出现异常，消息被错误处理。若您希望重新消费这些已被处理的消息，可以通过重置消费位点快速将消费位点更新到历史指定位置，实现消费回溯。重置功能 云消息队列 RocketMQ 版 的重置消费位点提供以下...
HttpEndpoint
参数名称 说明 TopicOwner 被订阅主题的拥有者 TopicName 被订阅主题的名称 Subscriber 订阅者 SubscriptionName 订阅名称 MessageId 消息编号 Message 消息正文 MessageMD5 消息的MD5值 MessageTag 消息标签（用于消息过滤）PublishTime ...
重置消费位点
业务回溯，纠正处理：由于业务消费逻辑出现异常，消息被错误处理。若您希望重新消费这些已被处理的消息，可以通过重置消费位点快速将消费位点更新到历史指定位置，实现消费回溯。注意事项 重置消费位点的范围是重置指定Group对于目标Topic...
消息通知
异步处理请求返回时仅返回任务ID，您需要在处理请求内添加消息通知参数，以在数据处理完成时获取到数据处理任务的结果。注意事项 仅异步处理支持消息通知。消息通知仅支持MNS主题。关于MNS的更多信息，请参见 消息服务MNS快速入门。参数...
回执消息配置
云通信的所有业务消息都支持MNS消息服务向外发送。用户在 短信服务控制台 启用MNS消息服务订阅指定的消息类型（MessageType）时，系统会自动生成该类型的独立消息队列及名称（QueueName）。您可使用此消息队列名称（QueueName）和消息类型...
Token鉴权概述
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的Token相关的请求以及消息收发业务。使用流程 Token鉴权模式相比签名模式更加复杂，您需要按照下图所示的流程，部署您的应用服务器。而且在初始化时，...
通过可观测性能力进行故障处理最佳实践
根据业务逻辑或指标的变化趋势定位具体原因，例如消息处理耗时变长，则可以查看消费者服务的内存、CPU等是否过载；或查看消费逻辑依赖的下游业务逻辑的运行状态进行进一步分析。生产异常场景实践方案 查看消息发送成功率（rocketmq_send_...
Token鉴权概述
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的Token相关的请求以及消息收发业务。使用流程 Token鉴权模式相比签名模式更加复杂，您需要按照下图所示的流程，部署您的应用服务器。而且在初始化时，...
顺序消息
顺序消息可以保证消息的消费顺序和发送的顺序一致，即先发送的先消费，后发送的后消费，常用于金融证券、电商业务等对消息指令顺序有严格要求的场景。本文介绍 云消息队列 RocketMQ 版 顺序消息的概念、适用场景、实现原理以及使用过程中的...
传统型负载均衡CLB实践教程
传统型负载均衡CLB实践教程索引 子产品 分类 教程链接 传统型负载均衡CLB 基础业务转发 使用CLB部署HTTPS业务（单向认证）使用CLB部署HTTPS业务（双向认证）单CLB实例配置多域名HTTPS网站（HTTPS多域名）高级特性转发 将HTTP访问重定向至...
自定义鉴权模式
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的鉴权相关的请求以及消息收发业务。使用说明 无论使用何种鉴权模式，本质上可以归结为身份认证和资源权限两个基本功能。身份认证，即客户端的身份标识，...
邮件推送事件通知概述
适用场景 异步获取邮件推送结果消息，再根据业务需求进行处理，例如重新发送。批量发送邮件，根据邮件推送结果消息异步统计邮件发送结果。监控邮件推送结果，例如大量邮件推送失败时，系统会及时向用户发送通知。邮件推送结果消息通过多种...
使用Canal和RocketMQ实现数据库变更订阅处理
Canal可以将变更记录可靠地投递到 云消息队列 RocketMQ 版 中，借助 云消息队列 RocketMQ 版 丰富的消息处理策略实现多样化的业务逻辑。Canal是一个开源项目，仓库地址请参见 Canal。方案介绍 基于Binlog日志实现增量订阅和消费的典型业务...
使用Canal和RocketMQ实现数据库变更订阅处理
Canal可以将变更记录可靠地投递到 云消息队列 RocketMQ 版 中，借助 云消息队列 RocketMQ 版 丰富的消息处理策略实现多样化的业务逻辑。Canal是一个开源项目，仓库地址请参见 Canal。方案介绍 基于Binlog日志实现增量订阅和消费的典型业务...
- 产品推荐
- 这些文档可能帮助您