根据消息来回复-根据消息来回复文档介绍内容-阿里云

消息过滤

功能描述消息过滤功能指消息生产者向Topic中发送消息时，设置消息属性对消息进行分类，消费者订阅Topic时，根据消息属性设置过滤条件对消息进行过滤，只有符合过滤条件的消息才会被投递到消费端进行消费。消费者订阅Topic时若未设置过滤...

更新记录

本文为您介绍ChatApp消息服务文档更新的最新动态，基于此您可以及时了解ChatApp消息服务的新增特性及功能变更。2023年11月更新记录时间特性内容描述 2023.11.21 新增控制台-目录管理，增加商品目录授权按钮用于授权Meta商品目录。控制...

消息处理时长自适应

所以，MessageMinimalLife是为了确保消息能活到被ChangeVisibility，用户可以自己根据业务压力来设置。TimerInterval是Manager内部的Timer的Interval。只需要确保在Message到达MessageMinimalLife之前，Timer会被启动就足够了。时间可以...

SDK下载

在使用云消息队列 MQTT 版客户端（下文简称MQTT客户端）收发消息前，需根据云消息队列 MQTT 版所支持的开发语言下载对应SDK。云消息队列 MQTT 版默认支持标准的MQTT 3.1.1协议，理论上能够适配所有的MQTT客户端，但不排除部分MQTT客户...

SDK下载

在使用云消息队列 MQTT 版客户端（下文简称MQTT客户端）收发消息前，需根据云消息队列 MQTT 版所支持的开发语言下载对应SDK。云消息队列 MQTT 版默认支持标准的MQTT 3.1.1协议，理论上能够适配所有的MQTT客户端，但不排除部分MQTT客户...

Exchange

使用示例 Headers Exchange根据消息Headers属性和Binding Headers属性的匹配规则路由消息的示例如下：Message 消息Headers属性 Binding Headers属性 Queue Message A type=read resource=group type=read resource=group x-match=all type=...

全球消息路由定价详情

计费项全球消息路由的计费公式如下：消息传输费用消息传输费用=消息传输量×消息传输单价以进行消息路由传输的消息数量为维度计费，计费单价根据月消息传输总量阶梯变化。具体单价，请参见本文中的计费单价。消息传输量=（普通消息+...

ModifyInstance

该参数需与 Parameter.N.Value 一起使用，云消息队列 RabbitMQ 版实例支持的变更配置包括：变更公网TPS流量峰值：您需设置 Parameter.N.Code 为 MaxEipTps，对应 Parameter.N.Value 参数，请根据云消息队列 RabbitMQ 版控制台购买页所...

应用场景

自助服务设置多种消息回复，更快解决用户问题。身份验证（OTP）使用绑定的常用社交账号（如WhatsApp）来验证用户身份，用户无需每次都输入冗长的密码来进行校验，提升用户体验度。客户关怀通过 ChatApp 消息服务实现与用户的双向交流，...

基本概念

本文说明云消息队列 Kafka 版涉及的专有名词和术语，帮助您更好地理解相关概念并使用该产品。Apache Kafka 一款开源的分布式数据流处理平台，可以实时发布、订阅、存储和处理数据流。更多信息，请参见 Apache Kafka。云消息队列 Kafka 版...

概述

本文介绍使用社区版TCP协议的Java SDK访问阿里云云消息队列 RocketMQ 版来收发消息的流程。使用说明社区版SDK仅在开源RocketMQ迁移上云且不希望修改代码时使用，其他场景推荐您使用阿里云云消息队列 RocketMQ 版提供的商业版SDK进行接...

消息过滤

使用SDK订阅主题消息时，可以通过设置消息的标签值来进行消息过滤。完整的示例代码，请参见步骤五：发布消息。向主题发送消息时设置消息的标签值的示例代码如下：TopicMessage message=new Base64TopicMessage();这里的标签值要和订阅规则...

实例升降配

存储规格不涉及云消息队列 RocketMQ 版的存储空间根据实际使用量按量付费，您可以随时调整消息存储时长来控制占用的存储空间。公网访问类型支持支持升配和降配。升配：开启公网访问。降配：关闭公网访问。公网流量带宽支持支持升配...

注意要点

本文介绍使用开源的客户端SDK接入云消息队列 RabbitMQ 版服务端时的注意事项。要点说明 com.rabbitmq.client.ConnectionFactory 接口设置 com.rabbitmq.client.ConnectionFactory 接口时，必须开启连接自动恢复功能，保证服务端升级时...

直播互动解决方案

使用云消息队列 MQTT 版的客户端收发消息时，服务端会根据MQTT客户端设置的Username和Password参数来进行鉴权。针对不同的权限验证场景，Username和Password参数具备不同的含义。在此场景下，Token鉴权模式更加适用。详细信息，请参见 ...

消息负载均衡策略

生产者负载均衡策略无序消息（普通消息、事务消息、定时和延时消息）：Producer将消息以轮询的方式发送至Queue，如下图所示：图中Msg1、Msg2代表第一条消息、第二条消息，生产者会把第一条消息发送至Queue 1，然后第二条消息发送至Queue 2...

默认配置映射关系

在创建消息流入或流出任务时，您可以选择系统的默认配置来定义消息转换规则，从而提高创建任务的效率。本文介绍了默认配置的映射关系详情。同构消息映射关系当消息的流入方和流出方为同一服务类型时，配置详情，请参见下文：基于事件流...

实例类型

底层硬件资源共享，多个实例共享同一个后端集群，由云消息队列 MQTT 版来保证多租户场景下的服务可用性。共享实例（逻辑隔离）。底层硬件资源共享，多个实例共享同一个后端集群，由云消息队列 MQTT 版来保证多租户场景下的服务可用性。...

SDK FAQ

本文记录通过SDK收发消息时常见的问题。开源客户端是否可以直接访问云上服务？云消息队列 RabbitMQ 版完全兼容开源RabbitMQ。开源RabbitMQ可以直接访问云上服务。您需要通过云消息队列 RabbitMQ 版控制台生成静态用户名密码之后，通过...

默认配置映射关系

在创建消息流入或流出任务时，您可以选择系统的默认配置来定义消息转换规则，从而提高创建任务的效率。本文介绍了默认配置的映射关系详情。同构消息映射关系当消息的流入方和流出方为同一服务类型时，配置详情，请参见下文：基于事件流...

默认配置映射关系

在创建消息流入或流出任务时，您可以选择系统的默认配置来定义消息转换规则，从而提高创建任务的效率。本文介绍了默认配置的映射关系详情。同构消息映射关系当消息的流入方和流出方为同一服务类型时，配置详情，请参见下文：基于事件流...

默认配置映射关系

在创建消息流入或流出任务时，您可以选择系统的默认配置来定义消息转换规则，从而提高创建任务的效率。本文介绍了默认配置的映射关系详情。同构消息映射关系当消息的流入方和流出方为同一服务类型时，配置详情，请参见下文：基于事件流...

创建资源

创建Topic Topic是云消息队列 RocketMQ 版里对消息的一级归类，例如创建名称为Topic_Trade的Topic来识别交易类消息，消息生产者将消息发送到Topic_Trade，而消息消费者则通过订阅该Topic来获取和消费消息。Topic的使用说明如下：Topic不...

创建资源

创建Topic Topic是云消息队列 RocketMQ 版里对消息的一级归类，例如创建名称为Topic_Trade的Topic来识别交易类消息，消息生产者将消息发送到Topic_Trade，而消息消费者则通过订阅该Topic来获取和消费消息。Topic的使用说明如下：Topic不...

UpdateInstance-更新实例

云消息队列 RocketMQ 版的消息存储完全实现 Serverless 弹性，按照实际存储空间收取费用，您可以通过调整消息保存时长来控制消息的存储容量。更多信息，请参见存储费用。72 traceOn boolean 否是否开启消息轨迹功能。true：开启消息轨迹...

领域模型概述

云消息队列 RocketMQ 版通过流式特性的无限队列结构来存储消息，消息在队列内具备顺序性存储特征。消息（Message）：云消息队列 RocketMQ 版的最小传输单元。消息具备不可变性，在初始化发送和完成存储后即不可变。消息消费消费者分组...

实例使用变更

如您只需使用MQTT协议来收发消息，则更容易理解。变更说明的详细信息，请参见资源使用变更。说明您可以在控制台实例详情页面通过内核版本字段确认您的实例是V2.x.x还是V3.x.x版本。控制台使用变更 V2.x.x和V3.x.x版本间的差异在于...

API概览

在消息收发模型中，生产者将消息发送至主题，消费者通过订阅指定的主题来消费其中的消息。UpdateTopic 更新主题更新主题的备注信息。DeleteTopic 删除主题删除指定主题。ListTopics 查询主题列表查询指定实例下的主题列表信息。GetTopic...

安装CPP动态库

在使用社区版C++ SDK接入阿里云云消息队列 RocketMQ 版来收发消息前，您需按本文提供的操作步骤安装CPP动态库。前提条件在开始做准备工作前，请确保您的操作系统满足以下条件：Linux：CentOS 6.8、CentOS 7.2、RHEL 6.x、RHEL 7.x ...

MNS相对于自主研发、商用或开源的消息队列系统有什么...

本文介绍与自行构建系统来管理消息队列或使用商用、开源的消息和通知服务相比，使用消息服务MNS 的优势。消息服务MNS 的优势如下所示：无需大量前期投入来进行开发、配置。随着您业务量的不断增大，无需持续投入硬件和管理资源。缺省提供...

Topic管理

消息生产者将消息发送到Topic中，而消息消费者则通过订阅该Topic来消费消息。本文介绍如何在云消息队列 RocketMQ 版控制台上创建、删除、更新和查询Topic。注意事项 Topic不能跨实例使用，例如在实例A中创建的Topic A不能在实例B中使用。...

队列（MessageQueue）

行为约束每个主题下会由一到多个队列来存储消息，每个主题对应的队列数与消息类型以及实例所处地域（Region）相关，队列数暂不支持修改。版本兼容性队列的名称属性在云消息队列 RocketMQ 版服务端的不同版本中有如下差异：服务端3.x/4....

获取MQTT客户端在线状态

业务应用一般部署在阿里云的服务器上，业务应用通过向后端存储消息队列订阅这条消息来获取所有客户端的上下线动作。该方式属于异步感知客户端的状态，且感知到的是上下线事件，而非在线状态，云端应用需要根据事件发生的时间序列分析出客户...

仪表盘

这些不再投递的消息会根据Group的死信策略配置保存至指定Topic或被丢弃。uid instance_id topic consumer_group Gauge rocketmq_storage_size byte 实例所使用的存储空间大小，包含所有文件的大小。uid instance_id 生产者Metrics指标 ...

MQTT客户端上下线事件数据流出

业务应用一般部署在阿里云的服务器上，业务应用通过向后端云产品订阅这条消息来获取所有客户端的上下线动作。该方式属于异步感知客户端的状态，且感知到的是上下线事件，而非在线状态，云端应用需要根据事件发生的时间序列分析出客户端的...

订阅关系清理

云消息队列 MQTT 版是否会自动加载离线消息并下发到客户端，需要根据 QoS 和 cleanSession 两个参数来决定。更多信息，请参见名词解释。订阅关系变化会影响实例的计费情况，计费的更多信息，请参见计费概述。操作步骤警告若开启订阅...

查看接入点

如需使用客户端连接云消息队列 Kafka 版收发消息，您需要根据客户端的网络环境类型及传输的安全需要来配置接入点。默认接入点适用于在保密性较高的VPC环境收发消息；SASL接入点适用于无需对传输链路加密但需对消息收发鉴权；同时需要链路...

CreateInstance-创建实例

云消息队列 RocketMQ 版的消息存储完全实现 Serverless 弹性，按照实际存储空间收取费用，您可以通过调整消息保存时长来控制消息的存储容量。更多信息，请参见存储费用。72 chargeType string 否计费模式。参数取值如下：provisioned：...

评估规格

使用说明云消息队列 Kafka 版提供的规格评估功能将根据您输入的自建Kafka集群的信息，如集群流量情况、磁盘容量和类型、分区数量等，来为您评估并推荐需要的云消息队列 Kafka 版实例规格，帮助您提前根据推荐部署云消息队列 Kafka 版 ...

GetInstance-获取指定实例的详情

消息队列 RocketMQ 版的消息存储完全实现 Serverless 弹性，按照实际存储空间收取费用，您可以通过调整消息保存时长来控制消息的存储容量。更多信息，请参见存储费用。72 supportAutoScaling boolean 实例是否支持开启规格外突发弹性能力...

根据消息来回复

新品推荐