JMS概述
背景信息 JMS是一种消息传递标准，允许基于Java EE（Java平台企业版）的应用程序组件创建、发送、接收、读取消息。JMS使分布式应用能够以松耦合、可靠、异步的方式进行通信。云消息队列 RabbitMQ 版 JMS库支持 JMS 1.1。云消息队列 ...
转换规则
修改请求头 HTTP请求头是HTTP的请求消息头的组成部分之一，可携带特定请求参数信息并传递给服务器。您可以通过配置回源HTTP请求头实现，支持增加、删除、变更或替换回源HTTP请求头，满足更多实际业务需求。修改响应头 节点HTTP响应头是HTTP...
模型介绍
消息（Timeline）模型是针对消息数据场景所设计的，能够满足消息数据场景对消息保序、海量消息存储、实时同步的业务需求，同时支持全文检索与多维度组合查询。适用于IM、Feed流等消息场景。模型结构 消息模型以简单为设计目标，核心模块...
现代IM系统中的消息系统—架构
IM系统中最核心的部分是消息系统，消息系统中最核心的功能是消息同步、存储和检索。消息同步：指将消息完整的、快速的从发送方传递到接收方。消息同步系统最重要的衡量指标就是消息传递的实时性、完整性以及能支撑的消息规模。在功能上，...
Upsert Kafka
参数取值如下：csv json avro debezium-json canal-json maxwell-json avro-confluent raw key.fields-prefix 为所有Kafka消息key部分指定自定义前缀，以避免与消息value部分格式字段重名。String 否 无 该配置项仅用于源表和结果表的列名...
顺序消息
顺序消息可以保证消息的消费顺序和发送的顺序一致，即先发送的先消费，后发送的后消费，常用于金融证券、电商业务等对消息指令顺序有严格要求的场景。本文介绍 云消息队列 RocketMQ 版 顺序消息的概念、适用场景、实现原理以及使用过程中的...
消息（Message）
对于定时消息和事务消息，消息保存时间指的是消息生效对消费方可见的服务端系统时间。取值：由服务端系统填充。说明：客户端系统时钟和服务端系统时钟可能存在偏差，消息保留时间是以服务端系统时钟为准。消费重试次数 定义：消息消费失败...
基本概念
消息队列（MessageQueue）队列是 云消息队列 RocketMQ 版 中消息存储和传输的实际容器，也是消息的最小存储单元。云消息队列 RocketMQ 版 的所有主题都是由多个队列组成，以此实现队列数量的水平拆分和队列内部的流式存储。队列通过QueueId...
队列模型基本概念
Endpoint 消息服务MNS 的访问域名地址，格式如下：http://$AccountId.mns.$Region.aliyuncs.com mns.<Region>.aliyuncs.com ： Region是 消息服务MNS 服务部署的地域，您可以根据应用需要选择不同的地域。AccountId：队列所有者的账号ID，...
功能与特性概述
消息类型对比 消息类型 是否支持可靠同步发送 是否支持可靠异步发送 是否支持Oneway发送 是否支持多线程发送 性能 普通消息 是 是 是 是 最高 事务消息 定时和延时消息 分区顺序消息 是 否 否 否 高 全局顺序消息 一般 消息特性 消息重试：...
如何保证我的消息队列中的消息是安全的？
本文介绍阿里云如何保证消息队列中的消息是安全的。消息服务MNS 提供了安全可靠的身份验证机制，确保您的队列受到保护，防止遭到未经授权的访问。只有阿里云账户拥有者才能访问其创建的队列。
普通消息
普通消息为 云消息队列 RocketMQ 版 中最基础的消息，区别于有特性的顺序消息、定时/延时消息和事务消息。本文为您介绍普通消息的应用场景、功能原理、使用方法和使用建议。应用场景 普通消息一般应用于微服务解耦、事件驱动、数据集成等...
延时消息
如果您希望消息被投递后延迟一段时间被消费者消费，您可以使用 云消息队列 RabbitMQ 版 的延时消息。云消息队列 RabbitMQ 版 原生支持延时消息，使用方式比开源RabbitMQ更简单。什么是延时消息 延时消息是指在指定时间段之后才被消费者消费...
使用云消息队列 Kafka 版时出现消息堆积
使用 云消息队列 Kafka 版 时，可能会发现Group中出现消息堆积。本文介绍如何判断消息堆积是否属于正常情况，以及处理方法。客户端消费流程 了解客户端消费流程，有助于理解消息是否堆积。一般情况下，客户端消费流程大致如下：判断消息...
实例限流最佳实践
云消息队列 RabbitMQ 版 会对单实例的TPS流量峰值进行限流，本文介绍 云消息队列 RabbitMQ 版 实例的限流规则、限流后的行为以及限流最佳实践等。限流后行为 当 云消息队列 RabbitMQ 版 实例的TPS流量峰值超过您所购买实例的TPS规格上限时...
Group管理
Group表示一类Producer或Consumer，这类Producer或Consumer通常生产或消费同一类消息，且消息发布或订阅的逻辑一致。使用 云消息队列 RocketMQ 版 进行消息收发，您需要创建Group ID用于标识同一类生产者实例或者同一类消费者实例。本文...
消息队列RocketMQ版是否能保证消息不重复？
绝大多数情况下，消息是不重复的。作为一款分布式消息中间件，在网络抖动、应用处理超时等异常情况下，无法保证消息不重复，但是能保证消息不丢失。
云消息队列 Kafka 版自定义权限策略参考
否 DeleteTopic 删除Topic 否 ListGroup 查看 Group 是 CreateGroup 创建 Group 否 UpdateGroup 更新 Group 配置 否 DeleteGroup 删除 Group 否 QueryMessage 查询消息 是 SendMessage 发送消息 否 DownloadMessage 下载消息 是 ...
HttpEndpoint
参数名称 说明 TopicOwner 被订阅主题的拥有者 TopicName 被订阅主题的名称 Subscriber 订阅者 SubscriptionName 订阅名称 MessageId 消息编号 Message 消息正文 MessageMD5 消息的MD5值 MessageTag 消息标签（用于消息过滤）PublishTime ...
HTTP Endpoint
参数名称 说明 TopicOwner 被订阅主题的拥有者 TopicName 被订阅主题的名称 Subscriber 订阅者 SubscriptionName 订阅名称 MessageId 消息编号 Message 消息正文 MessageMD5 消息的MD5值 MessageTag 消息标签（用于消息过滤）PublishTime ...
队列使用手册
NextVisibleTime是 消息服务MNS 的消息的一个重要属性。更多信息，请参见 QueueMessage。receiptHandle=NULL;try {/1.直接调用receiveMessage函数。receiveMessage函数接受waitSeconds参数，无特殊情况建议设置为30。waitSeconds非0表示...
队列使用手册
NextVisibleTime是 消息服务MNS 的消息里一个非常重要的属性。更多信息，请参见 QueueMessage。try {/1.直接调用receiveMessage函数。receiveMessage函数接受waitSeconds参数，无特殊情况建议设置为30。waitSeconds非0表示这次...
ChatAppStatus
消息体格式 名称 类型 是否必填 描述 MessageId String 是 消息的ID。From String 是 消息发送方号码。To String 是 消息接收方号码。Timestamp Long 是 时间戳为Unix timestamp 毫秒。Status String 是 消息发送状态。取值：Sent：消息已...
QueryMqttTraceMessagePublish-查询消息发送轨迹
mqtt-cn-i7m26mf*MsgId string 是 消息 ID，即 Message ID。AC1EC0030EAB78308DB16A3EC773*BeginTime long 是 查询范围的起始时间戳。单位：毫秒。1618646400000 EndTime long 是 查询范围的终止时间戳。单位：毫秒。1621591200000 返回...
事务消息
事务消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 分布式事务的诉求 分布式系统调用的特点为一个核心业务逻辑的执行，同时需要调用多个下游业务...
主题（Topic）
队列列表 定义：队列作为主题的组成单元，是消息存储的实际容器，一个主题内包含一个或多个队列，消息实际存储在主题的各队列内。更多信息，请参见 队列（MessageQueue）。取值：系统根据队列数量给主题分配队列，队列数量创建主题时定义。...
常见问题
如何配置MNS以支持更长的消息保留期 如何配置MNS以支持更大的消息大小 消息数、活跃消息数、延迟消息数分别表示哪些消息 消息服务消息批量操作注意事项 消息优先级为1，就一定优先吗 队列问题 不同地域中的同名队列是同一个队列吗 对于较长...
普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。说明 您在调用SDK收发消息时需注意，云消息队列 RocketMQ 版 提供的四种消息类型所对应的Topic不能混用，例如，您创建的普通消息...
发送消息API
MessageBody 是 消息内容。Properties 否 消息属性。属性（Properties）的序列化，其中特殊用途的键值说明如下：格式：key1:value1|key2:value2|key3:value3 键值说明如下。参数 类型 说明 KEYS String 消息的Key。STARTDELIVERTIME Long ...
消息加密传输
解决方案 以下是 消息服务MNS 对消息进行加密传输的解决方案。在消息发送端先对消息进行加密，然后再发送。在消息接收端先对消息进行解密，然后再消费。示例代码：SecurityQueue.zip，其中：SeurityQueue.java 提供 putMessage、popMessage...
死信消息
消息消费异常时会自动进行消费重试，达到最大重试次数后还未成功，则消息会转为死信状态。云消息队列 RocketMQ 版 支持将这些死信消息保存至指定Topic，方便后续进行业务恢复或回溯。本文介绍死信消息的应用场景、死信策略、使用限制、配置...
音视频通信解决方案（MQTT）
音视频管控服务还需要根据用户A邀请的信息找到用户B信息，同样封装一条邀请入会的消息，传递流程同 步骤2。会议参与者用户B收到参数后加入会议，本次通信初始化完成。基于上述设计思路，可以使用 云消息队列 MQTT 版 消息实现其他自定义...
发布者最佳实践
导致这种失败的原因可能是消息已经发送成功，但是ACK失败，也有可能是确实没发送成功。云消息队列 Kafka 版 是VIP网络架构，长时间不进行通信连接会被主动断开，因此，不是一直活跃的客户端会经常收到 connection reset by peer 错误，建议...
Queue
队列是消息存储的目的地，队列可以分成普通队列和延时队列。如果发送消息时不指定消息延时，被发送到普通队列的消息立刻可以被消费，而发送到延时队列需要经过设定的延时时间后才能被消费。QueueURL 格式：http://$AccountId.mns.<Region>....
ChatAppStatus
2023038470553398*8","ConversationId":"72222201111*","ConversationType":"service"}]字段说明 名称 类型 是否必填 描述 MessageId String 是 消息的ID。From String 是 消息发送方号码。To String 是 消息接收方号码。Timestamp Long ...
消息处理时长自适应
变量说明：MessageMinimalLife是消息注册时必须有的最少的Life长度。需要这个的原因是，例如消息register的时候已经只剩下0.1秒的超时时间了，注册进来也来不及ChangeVisibility延长生命。所以，MessageMinimalLife是为了确保消息能活到被...
ChatAppInbound
消息体格式 名称 类型 是否必选 描述 MessageId String 是 消息的ID。From String 是 消息发送方号码。To String 是 消息接收方号码。Timestamp Long 是 时间戳为Unix timestamp 毫秒。DisplayName String 是 号码显示的名称。Type String ...
传递步骤
本文介绍了传递步骤和其相关使用示例。介绍 传递（pass）步骤可以用来输出常量或者将输入转换成期望的输出。例如在开始定义流程时，如果您还没有创建任务步骤对应的函数计算 Function，可以先使用控制步骤和传递步骤规划并调试流程逻辑，...
【已恢复】WhatsApp 消息发送异常公告
由于与 WhatsApp 的通信出现异常，出现部分消息发送失败，我们正在与合作伙伴沟通尽快解决问题并第一时间恢复。2024 年 4 月 4 日【更新】针对影响消息发送的故障的修复程序已部署完毕，截至新加坡标准时间 2024 年 4 月 4 日上午 4:45此...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。不同消息类型所属的Topic不能混用，例如收发普通消息的Topic不能用来收发其他类型的消息。本文提供使用TCP协议下的C/C++ SDK收发...
- 产品推荐
- 这些文档可能帮助您