重置消费位点
若这部分堆积消息可以丢弃，您可以通过重置消费位点快速将消费位点更新到指定位置，绕过这部分堆积的消息，减少下游处理压力。业务回溯，纠正处理：由于业务消费逻辑出现异常，消息被错误处理。若您希望重新消费这些已被处理的消息，可以...
商品目录模板最佳实践
目录消息可以编辑正文部分内容，添加页脚信息。多件商品消息：用于设置显示多商品展示的产品目录模板。多件商品消息可以编辑头部信息和正文内容，添加页脚信息。通过单击预览部分的头部信息、正文信息、页脚信息进行对应内容的编辑。保存...
转换规则
您可以通过规则条件来识别用户请求中携带的特定参数信息，实现针对指定用户请求重写URL、修改请求头或者修改响应头的操作。不同套餐的支持情况 基础版 标准版 高级版 企业版 支持配置的规则数量 10条 25条 50条 125条 重写URL 支持 支持 ...
消费进度管理
若这部分堆积消息可以丢弃，您可以通过重置消费位点快速将消费位点更新到指定位置，绕过这部分堆积的消息，减少下游处理压力。业务回溯，纠正处理：由于业务消费逻辑出现异常，消息被错误处理。若您希望重新消费这些已被处理的消息，可以...
Upsert Kafka
参数取值如下：csv json avro debezium-json canal-json maxwell-json avro-confluent raw key.fields-prefix 为所有Kafka消息key部分指定自定义前缀，以避免与消息value部分格式字段重名。String 否 无 该配置项仅用于源表和结果表的列名...
死信消息
应用场景 典型死信消息处理场景 消息重试失败后，您可以选择将死信消息存储到指定的死信Topic中，通过另外创建一个ConsumerGroup消费这些死信消息来处理异常链路或分析死信消息。典型错误使用死信消息场景 处理死信消息时，如果将死信消息...
顺序消息
顺序消息可以保证消息的消费顺序和发送的顺序一致，即先发送的先消费，后发送的后消费，常用于金融证券、电商业务等对消息指令顺序有严格要求的场景。本文介绍 云消息队列 RocketMQ 版 顺序消息的概念、适用场景、实现原理以及使用过程中的...
现代IM系统中的消息系统—架构
消息同步系统最重要的衡量指标就是消息传递的实时性、完整性以及能支撑的消息规模。在功能上，至少要支持在线和离线推送，有些IM系统还支持多端同步。消息存储：指消息的持久化保存。传统消息系统通常只能支持消息在接收端的本地存储，数据...
产品架构
本文介绍 云消息队列 Kafka 版 的系统架构和发布/订阅模型。云消息队列 Kafka 版 系统架构 如 云消息队列 Kafka 版的系统架构 所示，一个 云消息队列 Kafka 版 集群包括Producer、Kafka Broker、Group、ZooKeeper。图 1.云消息队列 Kafka ...
Queue
队列是消息存储的目的地，队列可以分成普通队列和延时队列。如果发送消息时不指定消息延时，被发送到普通队列的消息立刻可以被消费，而发送到延时队列需要经过设定的延时时间后才能被消费。QueueURL 格式：http://$AccountId.mns.<Region>....
Topic与Tag最佳实践
在 消息队列RocketMQ版 中，Topic与Tag都是业务上用来归类的标识，区分在于Topic是一级分类，而Tag可以理解为是二级分类。您可通过本文了解如何搭配使用Topic和Tag来实现消息过滤。背景信息 Topic和Tag的定义如下：Topic 消息主题，通过...
如何配置MNS以支持更大的消息大小？
本文介绍如何配置 消息服务MNS 以支持更大的消息大小。要配置最大消息大小，请使用SetQueueAttributes方法设置MaximumMessageSize属性。此属性指定队列中的消息可以包含的字节数限值。可以设置为1024字节（1 KB）到最大65536字节（64 KB）...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的C#SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示。更多...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的Node.js SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的Go SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示。更...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的PHP SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示。更...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的Java SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示。...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的Python SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的C++ SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示。更...
定时/延时消息
定时/延时消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 说明 定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻...
链路数据透传
链路数据透传功能支持应用向调用上下文中存放数据，使得整个链路上的应用都可以操作该数据。您可以分别向链路的 request 和 response 中放入数据进行透传，并可获取到链路中相应的数据。使用方式如下：RpcInvokeContext.getContext()....
配置HTTP请求头
背景信息 HTTP请求头是HTTP的请求消息头的组成部分之一，可携带特定请求参数信息并传递给服务器。当CDN节点请求回源站拉取资源时，源站可获取到回源请求头中携带的信息。您可以通过该功能，改写用户回源请求中的HTTP Header信息，携带特定...
消息负载均衡策略
生产者负载均衡策略 无序消息（普通消息、事务消息、定时和延时消息）：Producer将消息以轮询的方式发送至Queue，如下图所示：图中Msg1、Msg2代表第一条消息、第二条消息，生产者会把第一条消息发送至Queue 1，然后第二条消息发送至Queue 2...
音视频通信解决方案（MQTT）
音视频管控服务还需要根据用户A邀请的信息找到用户B信息，同样封装一条邀请入会的消息，传递流程同 步骤2。会议参与者用户B收到参数后加入会议，本次通信初始化完成。基于上述设计思路，可以使用 云消息队列 MQTT 版 消息实现其他自定义...
接入点对比
云消息队列 Kafka 版 提供默认接入点、SSL接入点和SASL接入点以适用不同的连接及安全需求。默认接入点适用于在保密性较高的VPC环境收发消息；SASL接入点适用于无需对传输链路加密但需对消息收发鉴权；需要链路加密和消息鉴权，建议使用SSL...
在线教育视频直播
发送的消息可以存储在表格存储中。解决的问题 解决视频直播中手机端的推拉流问题。解决直播中手机端互发消息和消息内容的安全审核问题，同时低成本保存消息。部署架构图 选用的产品 云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 是由...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的PHP SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装PHP SDK。更多信息，请参见 准备环境...
收发定时消息和延时消息
背景信息 延时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时消息。定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端...
收发定时消息
定时消息可以做到在指定时间戳之后才可被消费者消费，适用于对消息生产和消费有时间窗口要求，或者利用消息触发定时任务的场景。定时消息的概念介绍及使用过程中的注意事项，请参见 定时和延时消息。前提条件 您已完成以下操作：下载C/C++ ...
收发定时消息
定时消息可以做到在指定时间戳之后才可被消费者消费，适用于对消息生产和消费有时间窗口要求，或者利用消息触发定时任务的场景。定时消息的概念介绍及使用过程中的注意事项，请参见 定时和延时消息。前提条件 下载.NET SDK。更多信息，请...
收发定时消息
背景信息 定时消息可以做到在指定时间戳之后才可被消费者消费，适用于对消息生产和消费有时间窗口要求，或者利用消息触发定时任务的场景。定时消息的概念介绍及使用过程中的注意事项，请参见 定时和延时消息。说明 对于新手用户，建议在...
【已恢复】WhatsApp 消息发送异常公告
由于与 WhatsApp 的通信出现异常，出现部分消息发送失败，我们正在与合作伙伴沟通尽快解决问题并第一时间恢复。2024 年 4 月 4 日【更新】针对影响消息发送的故障的修复程序已部署完毕，截至新加坡标准时间 2024 年 4 月 4 日上午 4:45此...
订阅消息API
订阅者可通过调用订阅消息API来消费 云消息队列 RocketMQ 版 服务端中的消息。请求构造 请求行 GET/topics/TopicName/messages?ns=INSTANCE_ID&consumer=GID&tag=taga&numOfMessages=3&waitseconds=3 HTTP/1.1 重要 请求行总长度不能超过...
消费者分组（ConsumerGroup）
取值：重试策略包括：最大重试次数：表示消息可以重新被投递的最大次数，超过最大重试次数还没被成功消费，消息将被投递至死信队列或丢弃。重试间隔：云消息队列 RocketMQ 版 服务端重新投递消息的间隔时间。最大重试次数和重试间隔的取值...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Node.js SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装Node.js SDK。更多信息，请参见 ...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的C#SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装C#SDK。更多信息，请参见 准备环境。...
基础版/铂金版实例计费
本文介绍 云消息队列 MQTT 版 的基础版和铂金版实例的计费项目和计费价格。计费概述 云消息队列 MQTT 版 的实例类型有基础版、铂金版 和专业版，各类型实例的差异，请参见 实例类型。其中基础版和铂金版实例的计费方式和计费项均相同，具体...
收发定时消息和延时消息
背景信息 延时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时消息。定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Python SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装Python SDK。更多信息，请参见 ...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Java SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装Java SDK。更多信息，请参见 准备...
- 产品推荐
- 这些文档可能帮助您