消息收发常见问题
为什么会出现一条消息同一时间重试多次？为什么消息会一直重试？消息发送时提示GroupID没有权限。使用RocketMQ数据流入MQTT功能时，为什么子级Topic后会多了一个“/”?消息发送返回“Too many publishes in progress”错误。本地测试先发送...
消息堆积和延迟问题
本文主要介绍 云消息队列 RocketMQ 版 TCP协议的Java客户端使用过程中，经常会出现的消息堆积和消息延迟的问题。通过了解 云消息队列 RocketMQ 版 客户端的消费原理和消息堆积的主要原因，帮助您可以在业务部署前更好的规划资源和配置，或...
通过可观测性能力进行故障处理最佳实践
例如，消息堆积量可明确反映消息消费阶段出现问题；消息生产调用成功率则可以明确反映消息发送阶段是否正常。三级指标：三级指标可作为对二级指标的进一步分析，通过三级指标能够高效定位二级指标波动的具体原因。消费异常场景实践方案 ...
计费概述
因此，您的 阿里云产品消费汇总 中，会出现 云消息队列 RocketMQ 版 的产品消费明细。实例类型和计费模式 云消息队列 MQTT 版 提供的实例类型及其计费方式如下，如需了解实例类型间的功能差异，请参见 实例类型。实例类型 计费模式 说明 ...
查看实例风险
Topic 格式转换 同步发送问题 碎片化发送问题 单分区Topic风险 Topic分区倾斜问题 生产流量 分区数量配额 分区分配策略问题 Group 消费消息接收耗时 消费消息排队耗时 消费消息读磁盘耗时 消费消息读磁盘耗时 消费消息格式转换时间 Group...
TCP协议客户端大版本发布
该策略可能会出现以下问题：消费者数量比和Queue数量多时，部分消费者获取不到消息的现象。部分消费者异常或者处理缓慢，其他消费者空闲却无法共同分担堆积压力的情况。以消息为粒度进行负载，负载策略更加均衡。避免了队列级负载策略可能...
消息过滤
可能原因：若多个消费者是通过同一个消费者分组（Group ID）订阅的指定Topic，则所有消费者的过滤条件即订阅的Tag要一致，否则会出现订阅关系不一致，导致部分消息丢失。消费者设置了过滤条件，消息消费数量是按照过滤前还是过滤后计算呢？...
SmsUp
根据文档中具体的消息格式进行消息体的解析 String arg=(String)contentMap.get("arg");编写您的业务代码 arg 代表回执消息体中的参数，可填写的值为：dest_code、send_time、sequence_id、phone_number、content。package ...
升级Broker可能产生哪些影响？
此外，升级和重启Broker期间，各个分区处理的消息量也会出现一定的不均衡，需要您评估一下升级变更对您业务可能产生的影响。升级所有Broker大概需要5分钟~15分钟。如果有多个实例，可以考虑先升级测试集群，验证通过后再升级生产集群。说明...
使用Topic通信
设备主动订阅Topic后，设备详情页的 Topic列表 页签才会出现相应Topic。订阅方式如下：使用MQTT.fx接入物联网平台：设备在线后使用 Subscribe 功能订阅设备Topic。可以使用控制台的 在线调试 功能，进行 设置属性 或 调用服务。...
查看消费状态
有消息堆积就一定是出现问题了吗？不一定。一般分为以下三种情况：最近消费时间与当前时间接近，并且堆积量保持在一个稳定的数值之间波动，没有持续扩大。说明客户端一直在拉取最新消息，没有消息堆积，属于正常情况。堆积量逐步扩大，并且...
使用自定义Topic通信
相关文档 物联网平台要求设备上报消息的数据格式要求为Alink JSON，如果设备的消息格式不是Alink JSON，必须使用消息解析将设备上报的自定义Topic数据解析为Alink JSON格式，通过自定义Topic下发设备的数据格式没有限制。消息解析的概念和...
设置消息通知
消息推送格式 推送给用户的消息格式。SIMPLIFIED：消息体即用户发布的消息，不包含任何属性信息。JSON：消息体为JSON格式，包含消息正文和消息属性。XML：消息体为XML格式，包含消息正文和消息属性。单击 确定，完成创建。创建队列 在MNS...
使用Canal和RocketMQ实现数据库变更订阅处理
false 链路轨迹追踪设置 使用Canal发送变更事件到 云消息队列 RocketMQ 版 时，可以选择开启 云消息队列 RocketMQ 版 的云上消息轨迹功能，以便出现异常时可以快速定位链路问题。开启链路轨迹追踪功能，需要设置如下参数：rocketmq.enable....
使用Canal和RocketMQ实现数据库变更订阅处理
false 链路轨迹追踪设置 使用Canal发送变更事件到 云消息队列 RocketMQ 版 时，可以选择开启 云消息队列 RocketMQ 版 的云上消息轨迹功能，以便出现异常时可以快速定位链路问题。开启链路轨迹追踪功能，需要设置如下参数：rocketmq.enable....
消费幂等
适用场景 在互联网应用中，尤其在网络不稳定的情况下，消息队列RocketMQ版 的消息有可能会出现重复。如果消息重复会影响您的业务处理，请对消息做幂等处理。消息重复的场景如下：发送时消息重复 当一条消息已被成功发送到服务端并完成持久...
发送普通消息（三种方式）
由于在oneway方式发送消息时没有请求应答处理，如果出现消息发送失败，则会因为没有重试而导致数据丢失。若数据不可丢，建议选用可靠同步或可靠异步发送方式。producer.sendOneway(msg);}/在应用退出前，销毁Producer对象。注意：销毁...
管理Kafka JSON Catalog
本文将从以下方面为您介绍如何管理Kafka JSON Catalog：创建Kafka JSON Catalog 查看Kafka JSON Catalog 使用Kafka JSON Catalog 删除Kafka JSON Catalog 使用限制 Kafka JSON Catalog仅支持消息格式为JSON的Topic，暂不支持其他格式。...
开源对比
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品，能够兼容开源RabbitMQ客户端，与开源RabbitMQ相比，能够解决各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等...
附录：消息格式
通过EventBridge发送的消息，会在消息实体格式基础上增加其他消息内容，EventBridge完整消息格式示例，请参见 附录一：发送给EventBridge的消息格式。消息事件类型列表 事件类型为事件消息中 type 的取值，不同类型的事件对应的息实体格式...
控制台的常见问题
介绍控制台操作过程中遇到的常见问题。项目授权 控制台项目管理，添加子成员提示“无权访问”功能定义 生活物联网平台里的自有品牌App如何删除？设备属性定义为JSON对象，上报时可使用JSON数组吗？控制台本地定时属性，找不到按星期重复的...
示例代码
由于在oneway方式发送消息时没有请求应答处理，如果出现消息发送失败，则会因为没有重试而导致数据丢失。若数据不可丢，建议选用可靠同步或可靠异步发送方式。producer.sendOneway(msg);}/在应用退出前，销毁Producer对象。注意：销毁...
MQTT快速入门
在以下使用情况中出现的问题 云消息队列 MQTT 版 产品方概不负责：客户端不使用域名接入而是使用IP地址接入，产品方更新了域名解析导致原有IP地址失效。客户端网络对IP地址设置网络防火墙策略，产品方更新了域名解析后新IP地址被您的防火墙...
使用限制
单实例消息收发TPS 根据购买的规格进行限流，云消息队列 MQTT 版 消息收发TPS超过规格上限后，客户端（包含开源MQTT客户端和云端SDK）可能会出现连接断开、响应超时和消息丢弃等情况，不保证消息可靠到达。在MQTT客户端场景下，单MQTT客户...
定时/延时消息
定时/延时消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 说明 定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻...
消息幂等
适用场景 在互联网应用中，尤其在网络不稳定的情况下，云消息队列 RabbitMQ 版 的消息有可能会出现重复。如果消息重复消费会影响您的业务处理，请对消息做幂等处理。消息重复的可能原因如下：发送时消息重复 当一条消息已被成功发送到服务...
升级实例版本
由于2.x版本的消息存储格式与0.10.x版本不同，您在完成升级之后，将无法回退到0.10.x版本，请您谨慎操作。升级小版本 升级小版本是指非跨大版本的升级，主要是修复开源Bug和性能优化，不涉及兼容性问题。例如将 云消息队列 Kafka 版 实例的...
如何处理消息堆积
问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警，登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象：在 Group 详情 页面，看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹，单击 创建查询任务，...
通信消息相关问题
发送到MNS队列中的消息格式：{"messageid":"12345","messagetype":"status/upload","topic":"null/topic","payload":{},"timestamp":1469564576 } 您可根据 topic 字段进行判断。如何从物联网平台云端下发指令到设备端？您可调用物联网平台...
云端运行日志
\t\r，输入内容会被拆分为多个词，从而导致查询日志失败，页面会出现报错提示：日志查询，查询参数异常。搜索条件 说明 DeviceName 输入设备名称。根据设备名称，搜索该设备的相关日志。TraceId 输入追踪ID，搜索串联模块日志。内容...
常见问题
一般使用常见问题 数据源类 配置和接入类 告警类 数据源类 日志支持哪些时间格式？支持如下时间格式：normal：最常见的时间格式 2016-12-13 10:00:14 apache：apache 时间格式 08/May/2017 01:13:52_long：完整时间戳，精确到毫秒，格式 ...
快速使用MQTT的Java SDK收发消息（终端和终端消息收发...
在以下使用情况中出现的问题 云消息队列 MQTT 版 产品方概不负责：终端或云端不使用域名接入而是使用IP地址接入，产品方更新了域名解析导致原有IP地址失效。终端或云端网络侧对IP地址设置网络防火墙策略，产品方更新了域名解析后新IP地址被...
使用云消息队列 Kafka 版时客户端的报错及解决方案
报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权（sasl.mechanisms）失败 说明 该报错仅出现在 云消息队列 Kafka 版 的公网实例中。确保servers配置正确。通过 telnet 命令排除网络问题。如果网络...
快速使用MQTT的Java SDK收发消息（终端和云端消息收发...
在以下使用情况中出现的问题 云消息队列 MQTT 版 产品方概不负责：终端或云端不使用域名接入而是使用IP地址接入，产品方更新了域名解析导致原有IP地址失效。终端或云端网络侧对IP地址设置网络防火墙策略，产品方更新了域名解析后新IP地址被...
OnsDLQMessageResendById-重发指定的死信消息
重发指定Message ID的死信消息，使该消息能够被Consumer再次消费。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则...
MQTT和RocketMQ进行数据互通（跨产品数据流出）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
MQTT和RocketMQ进行数据互通（跨产品数据流入）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
MQTT和RocketMQ进行数据互通（客户端上下线通知）
MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息，云消息队列 MQTT 版 支持将该条消息数据导出至其他阿里云产品，并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的 云消息队列 RocketMQ 版 数据互通...
客户端连接常见问题
本文介绍 云消息队列 MQTT 版 客户端连接服务端时的常见问题。使用安卓的Demo，返回连接失败报错。问题描述 资源填写正确，且网络可以连通。AK（AccessKey ID）、SK（AccessKey Secret）填写正确且已授权。可能原因 接入点格式不正确，正确...
查看实例风险
云消息队列 Kafka 版 实例的实时诊断功能能够定期对实例进行检测，支持查看诊断发现的问题、提供修复建议，并将异常的检查项上报告警给相关联系人，帮助您及时处理异常。实现方案 检测项 说明 若检测出实例存在风险，请参考控制台上提示的...
- 产品推荐
- 这些文档可能帮助您