消息收发常见问题
若先启动生产者发送消息，如果Topic从未有过订阅，则即使设置了离线消息（QoS=1且 cleanSession=false），消费者启动后也不会收到离线消息；如果Topic被消费者订阅过，消费者离线后，若设置了离线消息，这些离线消息会在消费者再次上线后被...
Subscribe
参数名称 是否必选 说明 参数值 Endpoint 是 描述此次订阅中接收消息的终端地址。目前四种Endpoint：HttpEndpoint：必须以http://为前缀。QueueEndpoint：格式为acs:mns:{REGION}:{AccountID}:queues/{QueueName}。MailEndpoint：格式为...
新零售电子价签解决方案（MQTT）
MQTT服务器 云消息队列 MQTT 版 提供的MQTT协议交互的服务端节点，用于接收消息并转发消息。MQTT客户端 用于和MQTT服务器交互的节点，本方案中特指发送或接收价格变更消息的智能AP。P2P消息 云消息队列 MQTT 版 在标准的MQTT协议基础上提供...
名词解释
X 消费者 消息消费者，即接收消息的程序。消息存活时间 消息在Queue中的有效期。某条消息在Queue中的留存时间超过配置的消息存活时间时，则该消息过期。消息存活时间的值必须为非负整型数，单位为毫秒。例如，某条消息的存活时间的值是1000...
事务消息
事务消息回查步骤如下：生产者收到消息回查后，需要检查对应消息的本地事务执行的最终结果。生产者根据检查得到的本地事务的最终状态再次提交二次确认，服务端仍按照步骤4对半事务消息进行处理。使用规则 生产消息规则 事务消息发送完成...
注意要点
开启发送确认，服务端收到消息后，会调用本地方法确认消息收到。mandatory 设置为true时，如果消息因为路由原因，未到达Queue，客户端添加的 ReturnListener 接口将会被调用。发送消息时，强烈建议自定义msgId，即消息的唯一标识。可用于...
配置工单审批消息
在页面右上角单击 消息接收人管理，找到对应的消息接收人，检查消息接收人邮箱地址是否正确。说明 请确保账号联系人邮箱地址正确，如果有误，可单击手机号后的 修改 进行更正。完成以上设置，当数据管理DMS的工单流转到对应阿里云账号且...
设置消息接收通知
背景信息 使用消息接收通知功能时，支持通过站内信、邮件、短信 接收通知，您需要在收到通知后手动自行处理。说明 如果需要通过程序自动订阅弹性伸缩相关的事件，请创建事件通知功能，设置通过云监控、MNS主题或者MNS队列等产品订阅事件，...
设置实例到期欠费预警提醒通知
欠费预警接收设置 登录 云消息队列 Kafka 版 控制台。单击页面右上方的 图标，进入 消息中心 页面。在左侧导航栏，单击 基本接收管理。在 基本接收管理 页面的 消息类型 中勾选 产品的欠费、停服、即将释放相关信息通知，单击 修改。在 ...
顺序消息
消息消费 云消息队列 RocketMQ 版 按照存储的顺序将消息投递给Consumer，Consumer收到消息后也不对消息顺序做任何处理，按照接收到的顺序进行消费。Consumer消费消息时，同一Sharding Key的消息使用单线程消费，保证消息消费顺序和存储顺序...
集群消费和广播消费
消费者，即消息的订阅方，从订阅的Topic中接收消息并消费。使用相同Group ID的多个消费者属于同一个消费者集群。同一个集群下的消费者消费逻辑必须完全一致（包括Tag的使用）。更多信息，请参见 订阅关系一致。集群消费 基本概念 集群消费...
消息查询
以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息。不设置也不会影响消息正常收发。msg.setKey("TestKey"+System.currentTimeMillis());按 Topic 查询 按Topic查询一般用在Message ID和Message Key都无法获得的...
Serverless实例计费说明
计费公式 消息收发费用＝消息收发次数累计值（次）×消息收发单价（元/次）消息收发次数计算规则 消息收发次数=接收消息次数+投递消息次数 接收消息次数：表示服务端收到生产者发送的消息条数，例如，某个Topic中收到5条消息，则计算为5次...
消息加密传输
本文介绍如何进一步提高您与 消息服务MNS 服务之间的网络链路上的安全性。背景信息 消息服务MNS 提供在公网HTTPS上进行消息加密传输的服务。对于包含敏感信息的消息，进一步提高您与阿里云服务之间的网络链路上的安全性，目前有以下两种...
发送消息API
使用发送消息API从生产者发送消息至 云消息队列 RocketMQ 版 服务端。请求构造 请求行 POST/topics/TopicName/messages?ns=INSTANCE_ID HTTP/1.1 参数说明如下。参数 是否必选 说明 TopicName 是 将消息发送至的Topic名称。ns 否 实例ID，...
消息堆积和延迟问题
本文主要介绍 云消息队列 RocketMQ 版 TCP协议的Java客户端使用过程中，经常会出现的消息堆积和消息延迟的问题。通过了解 云消息队列 RocketMQ 版 客户端的消费原理和消息堆积的...若收到消息堆积报警，处理方法，请参见 如何处理消息堆积。
订阅消息API
订阅者可通过调用订阅消息API来消费 云消息队列 RocketMQ 版 服务端中的消息。请求构造 请求行 GET/topics/TopicName/messages?ns=INSTANCE_ID&consumer=GID&tag=taga&numOfMessages=3&waitseconds=3 HTTP/1.1 重要 请求行总长度不能超过...
消息收发功能
消息收发为 云消息队列 MQTT 版 最基本的功能，云消息队列 MQTT 版 支持终端和云端服务接入 云消息队列 MQTT 版 服务器，实现终端和终端、终端和云端的消息通信。本文介绍消息收发功能的基本场景和示例代码。背景信息 云消息队列 MQTT 版 ...
事务消息
生产者收到消息回查后，需要检查对应消息的本地事务执行的最终结果。生产者根据检查到的本地事务的最终状态再次提交二次确认，服务端仍按照步骤4对半事务消息进行处理。事务消息生命周期 初始化 半事务消息被生产者构建并完成初始化，待...
API概览
消息 API 标题 API概述 SendMessage 向云消息队列 MQTT 版发送单条消息 从服务端应用向云消息队列 MQTT 版发送单条消息。客户端 API 标题 API概述 QuerySessionByClientId 查询客户端在线状态*QuerySessionByClientId*接口一般用于线上追踪...
查看实例风险
Topic 格式转换 同步发送问题 碎片化发送问题 单分区Topic风险 Topic分区倾斜问题 生产流量 分区数量配额 分区分配策略问题 Group 消费消息接收耗时 消费消息排队耗时 消费消息读磁盘耗时 消费消息读磁盘耗时 消费消息格式转换时间 Group...
订阅关系（Subscription）
通过配置订阅关系，可控制如下传输行为：消息过滤规则：用于控制消费者在消费消息时，选择主题内的哪些消息进行消费，设置消费过滤规则可以高效地过滤消费者需要的消息集合，灵活根据不同的业务场景设置不同的消息接收范围。具体信息，请...
主题模型快速入门
可选：在 队列收发消息快速体验 页面的 接收消息 区域，单击 编辑接收消息参数，在 编辑接收消息参数 面板配置 单次获取最大条数 和 轮询时间，然后单击 确定。在 队列收发消息快速体验 页面的 接收消息 区域，单击 接收消息。接收消息 ...
RESTful API概览
BatchSendMessage 批量发送消息 API调用 ReceiveMessage 消费消息 控制台、API调用 BatchReceiveMessage 批量消费消息 API调用 DeleteMessage 删除消息 控制台、API调用 BatchDeleteMessage 批量删除消息 API调用 PeekMessage 查看消息 API...
消息撤回
通过控制台撤回 登录 mPaaS 控制台，选择目标应用后，从左侧导航栏进入 消息推送>消息管理 页面。选择消息推送任务类型，进入相应的消息列表页。选择要撤回的消息，单击 撤回 并确认即可。执行撤回操作后，推送中的消息将会停止推送，已推...
Demo工程
接收消息。接收普通消息：运行 RocketMQConsumer 类。接收事务消息：运行 RocketMQConsumer 类。接收顺序消息：运行 RocketMQOrderConsumer 类。可以看到消息被接收打印的日志。因为有初始化，所以需等待几秒，在生产环境中不会经常初始化...
如何有效防止API的重放攻击？
API重放攻击（Replay Attacks）又称重播攻击、回放攻击，这种攻击会不断恶意或欺诈性地重复一个有效的API请求。攻击者利用网络监听或者其他方式盗取API请求，进行一定的处理后，再把它重新发给认证服务器，是黑客常用的攻击方式之一。HTTPS...
回执消息简介与配置流程
当您使用智能联络中心API接口进行呼入、呼出任务后，可以通过配置MNS消息队列消费模式或HTTP批量推送模式接收通话回执消息。说明 如果出现网络异常、响应超时等情况，可能导致回执消息推送重复。HTTP批量推送模式的响应超时时间为700 ms。...
订阅选项
如下表所示，发布者发布消息中 Retain 标识可为：True：发布消息中有 Retain 标识，根据 Retain As Publish 设置，决定设备收到消息中是否保留该标识。False：发布消息中没有 Retain 标识，Retain As Publish 设置无效，消息中都不会保留该...
PublishMessage
调用PublishMessage接口向指定的主题发布消息，消息发布到主题后随即会被推送给Endpoint消费。请求头 该接口使用公共请求头，无特殊请求头。更多信息，请参见 公共参数。请求语法 POST/topics/$TopicName/messages HTTP/1.1 说明 当您调用...
队列模型快速入门
可选：在 队列收发消息快速体验 页面的 接收消息 区域，单击 编辑接收消息参数，在 编辑接收消息参数 面板配置 单次获取最大条数 和 轮询时间，然后单击 确定。在 队列收发消息快速体验 页面的 接收消息 区域，单击 接收消息。接收消息 ...
RESTful API概览
本文列举了消息服务MNS主题模式提供的API。主题管理 API 说明 CreateTopic 创建主题 SetTopicAttributes 修改主题属性 GetTopicAttributes 获取主题属性 DeleteTopic 删除主题 ListTopic 获取主题列表 订阅管理 API 说明 Subscribe 创建...
配置消息监控告警实现风险预警
告警处理：收到消息堆积量告警后，建议按照如下步骤处理：进入 消息队列RocketMQ版控制台 的仪表盘页面，查看指定Group的消息堆积曲线，分析堆积量的变化趋势，找到初始产生堆积的时刻。基于业务的变更及应用日志，分析初始堆积时刻的变化...
配置消息监控告警实现风险预警
告警处理：收到消息收发TPS告警后，建议按照如下步骤处理：进入 消息队列RocketMQ版控制台 的仪表盘页面，查看指定Topic或Group的消息收发TPS曲线，分析流量的变化趋势是否正常。基于业务模型判断流量趋势的合理性，分析是否异常。配置公网...
自由使用Group
打开自由使用Group的开关表示 云消息队列 Kafka 版 允许未在控制台创建的Group可以调用API进行消息消费和位点提交等操作，如果关闭自由使用Group功能，那么未在控制台创建的Group（即控制台上 自动创建 栏显示为 是 的Group）将无法进行...
API报警设置
4.设置API分组的报警规则 1、如果需要对该API分组下的所有API应用相同的报警规则，进入API分组详情页，点击详情页右上角的 开启云监控。2、在第一次配置API分组云监控时，会有弹出框提示用户创建 API网关-监控服务关联角色。3、点击确定后...
配置记录HTTP请求应答日志
如果需要在日志中记录API网关收到的HTTP的请求及API网关返回给客户端的HTTP应答，您可以在分组详情中进行设置。记录请求Headers：逗号分隔需要记录的Header名称（如上图所示），'*' 记录全部 记录应答Headers：逗号分隔需要记录的Header...
API 概览
消息队列提供以下相关 API 接口。Topic 管理 API 描述 CreateMqSofamqTopic 创建 Topic DeleteMqSofamqTopic 删除 Topic ListMqSofamqTopic 查询 Topic 列表 UpdateMqSofamqTopic 更新 Topic 的读写权限 UpdateMqSofamqTopicRemark 修改 ...
SendMessage
调用SendMessage接口发送消息到指定的队列。授权信息 默认仅限阿里云账号使用本接口，RAM用户只有在被授予了相关API操作权限后方可使用。本接口的授权信息如下表所示。更多信息，请参见 授权策略和示例。Name Value API SendMessage RAM...
共享实例
计费币种：人民币 有效调用次数：API网关收到的所有API请求，均为有效调用，会计入收费范围；每月（自然月）前一百万次API调用免费，当月超过部分按阶梯计费。2.公网出访流量费用 共享实例的公网出访流量费用的计费逻辑，与专享实例的公网...
- 产品推荐
- 这些文档可能帮助您