消息堆积和延迟问题
此时仅通过调整 云消息队列 RocketMQ 版 SDK的消费并发度并不能解决问题，需要对数据库容量进行升配才能从根本上提高客户端消费能力。消费并发度 云消息队列 RocketMQ 版 消费消息的并发度计算方法如下表所示。消息类型 消费并发度 普通...
使用云消息队列 Kafka 版时出现消息堆积
建议您及时手动提交位点解决消息堆积问题。消息堆积的处理方式 经过上述判断，确认消息的确存在堆积情况时，建议打印消息的消费耗时，或者根据堆栈信息查看线程执行情况。根据以下方案适当调整以加快消息的消费速度，避免出现消息堆积。...
使用Topic通信
自定义Topic 如果设备的消息格式不是 Alink JSON，必须使用 消息解析 将设备上报的自定义Topic数据解析为 Alink JSON 格式，通过自定义Topic下发设备的数据格式没有限制。消息解析的概念和使用步骤，请参见 什么是消息解析。物模型Topic ...
业务逻辑
本文介绍使用业务逻辑开发工具中相关常见问题及解决方法。MQTT发布节点的消息包内容格式是什么？消息包内容是要发送的消息实体，必须为二进制格式的数据。更多信息，请参见 MQTT发布。云数据库MySQL节点是否支持跨地域使用？支持。更多信息...
API错误码
调用短信服务API接口失败时会返回错误码，请根据错误码和错误信息排查问题。错误码（Code）错误信息（Message）原因及解决方案 isv.SMS_SIGNATURE_SCENE_ILLEGAL 签名和模板类型不一致 原因：模板和签名类型不一致。错误示例：用验证码签名...
生产者负载均衡
背景信息 了解生产者负载均衡策略，可以帮助您解决如下问题：消息发送的容灾策略：您可以根据生产者负载均衡策略，明确当局部节点出现故障时，消息发送如何进行容灾切换。消息发送的顺序性机制：通过生产者负载均衡策略，您可以进一步了解...
消费者负载均衡
背景信息 了解消费者负载均衡策略，可以帮助您解决以下问题：消息消费处理的容灾策略：您可以根据消费者负载均衡策略，明确当局部节点出现故障时，消息如何进行消费重试和容灾切换。消息消费的顺序性机制：通过消费者负载均衡策略，您可以...
消息格式描述
本文介绍物联网平台支持的MQTT 5.0新特性的消息格式描述。功能说明 MQTT 5.0增加了两个属性描述消息的格式：有效载荷标识（Payload Format Indicator）和内容类型（Content Type）。这两属性可以应用到发布消息（Publish）或者遗嘱消息中。...
Subscribe
NotifyContentFormat Boolean 否 SIMPLIFIED 用于定义向Endpoint推送的消息格式。取值范围：XML JSON SIMPLIFIED 消息格式的具体描述，请参见 NotifyContentFormat。默认值：XML。如果您使用Terraform管理 alicloud_message_service_...
消息服务MNS中删除消息时报“message not exist”的...
本文介绍了当MNS删除消息时返回“message not exist”的问题描述、问题原因和解决方案。问题描述 消息服务MNS中删除消息时报如下错误。message not exist 问题原因 VisibilityTimeout 到期，该消息的ReceiptHandle失效，导致消息删除失败。...
Subscription
NotifyContentFormat 推送给Endpoint的消息格式。取值范围：XML或者SIMPLIFIED。具体推送消息的格式，请参见 NotifyContentFormat。CreateTime 订阅的创建时间，从1970-1-1 00:00:00到现在的秒值。LastModifyTime 修改订阅属性信息的最近...
Subscribe
NotifyContentFormat 否 描述了向Endpoint推送的消息格式。XML、JSON或者SIMPLIFIED，默认为XML。消息格式的具体描述，请参见 NotifyContentFormat。Response 返回消息由返回状态行、HTTP头和消息体三部分组成：...
Subscription
NotifyContentFormat 推送给Endpoint的消息格式。取值范围：XML或者SIMPLIFIED。具体推送消息的格式，请参见 NotifyContentFormat。CreateTime 订阅的创建时间，从1970-1-1 00:00:00到现在的秒值。LastModifyTime 修改订阅属性信息的最近...
服务支持
云消息系列 RocketMQ 版常见问题 产品功能常见问题 客户端连接常见问题 售卖、计费和实例升降配常见问题 控制台常见问题 消息发送常见问题 消息消费常见问题 相关协议 阿里云产品服务协议（通用）云消息队列 RocketMQ 版服务等级协议
视频流接入常见问题
本文介绍视频流接入的常见问题及解决方法。视频流接入问题分析 问题现象 视频流接入是一个涉及浏览器、视频流、播放器多方的综合问题，DataV产品作为可视化页面搭建工具，只是将视频播放器以组件的形式进行集成，由于定位手段比较有限，...
视频流接入常见问题
本文介绍视频流接入的常见问题及解决方法。视频流接入问题分析 问题现象 视频流接入是一个涉及浏览器、视频流、播放器多方的综合问题，DataV产品作为可视化页面搭建工具，只是将视频播放器以组件的形式进行集成，由于定位手段比较有限，...
重复来电分析
一次性解决来电数量：以下两种情况均算作相同问题一次性解决 如果重复来电的两通电话，客户问的是非关联问题或者关联问题中的不相同问题，则第一通算作一次性解决，该通话对应客服的相同问题一次性解决电话数加一；如果某个客户在一通电话...
附录：消息格式
本文介绍DataWorks开放消息的消息结构、不同类型事件的消息格式及各字段含义，帮助您快速获取和感知事件消息的状态变更信息。注意事项 DataWorks发送的核心消息内容您可参照消息实体格式进行查看。通过EventBridge发送的消息，会在消息实体...
GetSubscriptionAttributes
取值说明如下：XML JSON SIMPLIFIED 消息格式的具体描述，请参见 NotifyContentFormat。FilterTag String important 描述了该订阅中消息过滤的标签（仅标签一致的消息才会被推送）。CreateTime Long 1449554806 Subscription的创建时间，从...
主题模型快速入门
重试策略支持选择以下任一类型：退避重试 指数衰减重试 消息推送格式：设置推送消息到接收端的消息格式。消息推送格式可以选择以下任一类型：SIMPLIFIED JSON XML 订阅管理 页面目标订阅已创建。发布消息 您可以在控制台把向主题发布的消息...
OSS事件通知概述
本文介绍对象存储OSS事件通知的背景信息、适用场景、事件类型以及消息格式。背景信息 如下图所示，如果您创建了事件通知规则，当您在请求OSS进行相关操作时，消息服务MNS 将OSS指定资源上产生的事件以消息的方式推送到接收端。在请求OSS...
基于Flink的资讯场景实时数仓
解决的问题 通过 云消息队列 Kafka 版 和实时计算Flink实现实时数据处理和数据流。通过 云消息队列 Kafka 版 和实时计算Flink实现实时数据分析。通过 云消息队列 Kafka 版 和实时计算Flink实现事件触发。部署架构图 选用的产品 云消息队列 ...
为什么查询到的消息创建时间与设置的消息查询时间点...
问题现象 登录 云消息队列 Kafka 版 控制台，在 ...如果查询到的 消息创建时间 为空值，说明客户端版本较低，消息格式中缺少时间属性。解决方案 如果查询到的 消息创建时间 为空值，您可以升级客户端版本至2.2.0版本以上，推荐使用2.4.0版本。
主题控制台操作帮助
重试策略支持选择以下任一类型：退避重试 指数衰减重试 消息推送格式：设置推送消息到接收端的消息格式。消息推送格式可以选择以下任一类型：SIMPLIFIED JSON XML 订阅管理 页面目标订阅已创建。编辑订阅 登录 消息服务MNS控制台。在左侧...
主题控制台操作帮助
重试策略支持选择以下任一类型：退避重试 指数衰减重试 消息推送格式：设置推送消息到接收端的消息格式。消息推送格式可以选择以下任一类型：SIMPLIFIED JSON XML 订阅管理 页面目标订阅已创建。编辑订阅 登录 消息服务MNS控制台。在左侧...
OTA升级概述
消息格式 上报版本号 Topic：/ota/device/inform/${YourProductKey}/${YourDeviceName} 消息格式 {"id":1,"params":{"version":"1.0.0","module":"mcu"/该参数如果不填，表示默认版本号default } } 参数 类型 说明 id String 消息ID号。...
查看实例风险
Topic 格式转换 同步发送问题 碎片化发送问题 单分区Topic风险 Topic分区倾斜问题 生产流量 分区数量配额 分区分配策略问题 Group 消费消息接收耗时 消费消息排队耗时 消费消息读磁盘耗时 消费消息读磁盘耗时 消费消息格式转换时间 Group...
如何处理消息堆积
问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警，登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象：在 Group 详情 页面，看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹，单击 创建查询任务，...
主题使用手册
步骤四：创建订阅 对已创建的主题进行订阅，在订阅时需要设置对应的推送Endpoint地址（目前支持HTTP、邮件、队列、移动推送以及短信）、错误重试策略、推送消息格式等。public class SubscribeDemo { public static void main(String[]args...
直播互动解决方案
消息示例如下：topic:"roomSend/message"，body:"{ 'peer':'xxx','roomId':'123456','msg':'xxx' }"说明 HTML网页客户端发送的消息格式为JSON。云消息队列 MQTT 版 根据创建的数据流出规则将消息转发至 云消息队列 RocketMQ 版。订阅了 云...
常见问题
本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。产品功能常见问题 消息队列RocketMQ版5.x系列相比4.x系列实例有什么优势？消息队列RocketMQ版5.x系列实例兼容哪些版本客户端？消息队列RocketMQ版支持哪些语言客户端？消息队列...
常见问题
本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。产品功能常见问题 云消息队列 RocketMQ 版5.0系列相比4.0系列实例有什么优势？云消息队列 RocketMQ 版5.0系列实例兼容哪些版本客户端？云消息队列 RocketMQ 版支持哪些语言客户端？云...
消息保序递交解决方案
本文介绍消息传递中的乱序问题及其解决方案。
查询消息轨迹
云消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数，例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等，并支持可视化查询。当消息收发结果不符合预期...
提交消息解析脚本
sn=default 的自定义Topic上报自定义格式消息时，物联网平台收到消息数据后，需调用消息解析脚本将自定义格式数据转换为JSON结构体，再流转给后续业务系统。本文介绍如何在物联网平台控制台提交消息解析脚本实现自定义格式数据解析。使用与...
公共云基础服务说明书
订阅支持 阿里云针对购买云产品的客户，将提供消息订阅基础支持，目前提供的消息种类主要包含产品消息、故障消息、服务消息、活动消息几大类，客户可根据需要登录阿里云官网进入 消息中心 设置订阅或查看消息。3.服务SLA 电话/官网在线咨询...
AMQP客户端接收不到实时消息，为什么？
本文介绍通过物联网平台配置的AMQP服务端订阅消息无法接收的常见问题及解决方法。配置AMQP服务端订阅后，为什么在线消费端收不到消息？问题描述 AMQP服务端订阅完成后，消费组对应在线AMQP客户端没有接收到消息。可能原因 当前设备通信的...
错误码查询
您可以通过返回结果中的错误码快速地定位问题，并根据对应的解决方案尝试修改代码或者反馈给终端用户加以解决。错误码分类 错误码表示 服务端错误码 服务端报错 8位错误码，例如：50000000 客户操作错误导致的服务端报错 8位错误码，例如：...
查看Rebalance详情
当消费客户端出现Rebalance时，您可以查看Rebalance的详情，包括Rebalance的时间、耗时、次数、原因以及...后续步骤 当客户端频繁出现Rebalance时，您可以参考以下文档解决此问题：使用云消息队列 Kafka 版时消费客户端频繁出现Rebalance。
什么是消息服务MNS
多种消息格式 XML：消息体为XML格式，包含消息正文和消息属性。JSON：消息体为JSON格式，包含消息正文和消息属性。SIMPLIFIED：消息体即用户端发布的消息，不包含任何属性信息（精简格式，即文本格式）。更多信息，请参见：NotifyStrategy ...
- 产品推荐
- 这些文档可能帮助您