前端集成说明
方便调试 requests.send改为第1步中的消息处理方法，确认消息是否正常发送和接收 接收到消息后，假如使用 ChatSSE 对接的，则需要使用isvParser方法将对话机器人消息转换为ChatUI-Pro消息的消息格式，注意isvParser使用格式是`isvParser({...
0006-00000002
问题描述 PostObject请求上传超时。问题原因 您通过PostObject请求上传文件时，由于网络环境或...问题示例 无 解决方案 参考网络超时处理方法排查并解决PostObject请求上传超时的问题。更多信息，请参见 网络超时处理。相关文档 PostObject
0006-00000106
问题描述 PostObject请求表单读取超时。问题原因 您通过PostObject请求上传文件时，由于网络环境...问题示例 无 解决方案 参考网络超时处理方法排查并解决PostObject请求上传超时的问题。更多信息，请参见 网络超时处理。相关文档 PostObject
消息轨迹
按消息处理耗时：在 按消息处理耗时 页签中，选择要查询消息的Queue，输入消息处理耗时时间（单位为秒），设置查询 时间范围，然后单击 查询。在查询的消息列表，选择要查询消息轨迹的消息，在其 操作 列，单击 轨迹详情。在消息轨迹详情...
话单错误码
此IE必须在消息中存在，才能处理消息。网络问题导致用户未接续成功。97 发送此原因的设备收到了一条消息，此消息缺少一个信息元素，该信息元素必须在消息中存在，才能对该消息进行处理。网络问题导致用户未接续成功。98 发送此原因的设备已...
消息处理时长自适应
本文介绍如何使消息处理时长自适应。背景信息 消息服务MNS 的规范中，每条消息都有个默认的VisibilityTimeout，Worker在接收到消息后，Timeout就开始计时了。如果Worker在Timeout时间内没能处理完消息，那么消息就有可能被其他Worker接收到...
监控报警
监控项说明 说明 消息堆积量、消息处理延迟时间、已就绪消息量、已就绪消息排队时间等消息堆积场景相关的指标的详细说明，请参见 堆积场景指标说明。指标分类 监控指标 MetricName 统计方法 单位 Instance 实例API调用TPS InstanceApi...
消息轨迹
如下图所示，设备上报数据后，查看消息轨迹，可发现在数据流转操作中：发布到另一个Topic（republish）、插入到表格存储（ots）和发布到AMQP服务端订阅消费组的消息处理成功。存储到实例内时间序列数据库（tsdb in vpc）因参数非法，及 ...
消息服务MNS中删除消息时报“message not exist”的...
本文介绍了当MNS删除消息时返回“message not exist”的问题描述、问题原因和解决方案。问题描述 消息服务MNS中删除消息时报如下错误。...如果 VisibilityTimeout 设置得太大，当消息处理失败时，将不能在短时间内再次处理该条消息。
UpdateDIProjectConfig
当前DataWorks仅支持为同步解决方案任务中的实时同步DDL消息处理策略设置默认的全局配置。如果您的同步解决方案任务包含实时同步任务，则配置 DDL消息处理规则时会读取此处的全局配置为默认配置。您也可以根据实际业务需求修改目标同步任务...
ListDIProjectConfig
当前DataWorks仅支持为同步解决方案任务中的实时同步DDL消息处理策略设置默认的全局配置。如果您的同步解决方案任务包含实时同步任务，则配置 DDL消息处理规则时会读取此处的全局配置为默认配置。您也可以根据实际业务需求修改目标同步任务...
通知点击处理
自定义消息处理 如需处理消息，可以重写 MPPushMsgServiceAdapter 的 onMessageReceive 和 onChannelMessageClick 方法：public class MyPushMsgService extends MPPushMsgServiceAdapter {/*自建通道收到消息的回调（非厂商通道）*@param ...
仪表盘
堆积消息量（已就绪消息+处理中消息）top20 GroupIDs 统计堆积的消息量最多的前20个Group。单位：条。处理中消息量 top20 GroupIDs 统计处理中的消息量最多的前20个Group。单位：条。消费处理耗时 top20 GroupIDs 统计消费处理耗时最长的前...
消息重试
返回 Action.ReconsumeLater（推荐）返回 Null 抛出异常 示例代码：public class MessageListenerImpl implements MessageListener{@Override public Action consume(Message message,ConsumeContext context){/方法 3：消息处理逻辑抛出...
开源对比
提供强大的索引能力，可根据Queue、消息ID、消息处理耗时等完成不同维度的查询。详细信息，请参见 消息轨迹。消息轨迹信息以文本格式存储在服务器的log文件中，查询和定位问题效率较低。服务和性能 项目 云消息队列 RabbitMQ 版 开源...
顺序消息
有限重试 云消息队列 RocketMQ 版 顺序消息投递仅在重试次数限定范围内，即一条消息如果一直重试失败，超过最大重试次数后将不再重试，跳过这条消息消费，不会一直阻塞后续消息处理。对于需要严格保证消费顺序的场景，请务必设置合理的重试...
收发顺序消息
2.消息处理成功，返回OrderAction.Success。Override public OrderAction consume(Message message,ConsumeOrderContext context){ System.out.println(message);return OrderAction.Success;} });consumer.start();} }
iOS 接口
消息处理完成通知回调（callback），参数是通知里面的 userInfo(notify.userInfo)。回调 SyncSDK，表示业务数据已经处理在 registerSyncBizWithName 接口注册的通知处理函数中，数据处理完后调用。无返回值。class="reference-link">+...
云产品流转概述
一条消息处理后可以写入多个云产品，写入云产品限制请参见下一条：写入云产品消息量。对于被限流的消息，系统会自动重试处理，多次重试失败的数据会被丢弃。公共实例：1,000 TPS 企业版实例：查看实例的可用资源 写入云产品消息量 公共实例...
现代IM系统中的消息系统—架构
消息处理服务器对消息先存储后同步，先写入发件箱Timeline（存储库），后写扩散至各个接收端的收件箱（同步库）。消息数据写入存储库后，会被近实时的构建索引，索引包括文本消息的全文索引以及多字段索引（发送方、消息类型等）。对于在线...
消息队列
任务A作为生产者循环向消息队列发送消息，任务B作为消费者循环从消息队列接收消息，一般情况下，消费者处理数据是要花费很长时间，所以会导致消息产生的速度大于消息处理的速度，使得消息队列溢出。所以可以通过调整任务B优先级大于任务A来...
消息堆积
解决方法 面对消息堆积，且有明显性能下降的情况，可采取以下措施处理：在消息队列控制台，通过 查看消费者状态 获取消息堆积的消费者实例所对应的宿主机 IP 地址，并登录该宿主机或容器。执行以下任一命令查看进程 pid。ps-ef|grep java ...
消息服务MNS中HttpEndpoint接口接收不到消息时的排查...
概述 本文主要介绍消息服务MNS中HttpEndpoint接口接收不到消息时的排查方法。排查步骤 请参考如下步骤进行排查。使用 主题HTTP Endpoint本地调试工具 进行调试，检查HttpEndpoint接口接收消息的逻辑是否存在问题。使用该工具可分别针对鉴权...
Windows实例通过外部访问网络不通的处理
本文介绍Windows实例不能正常通过外部网络访问的处理方法。问题描述 Windows系统的ECS实例不能正常通过外部网络访问。可能原因 用户从外部访问Windows实例时，发现无法 ping 通、无法访问业务、或者无法 telnet 到业务监听的端口。从公网...
示例代码
class ExampleMessageListener:public MessageListener { public:Action consume(Message&message,ConsumeContext&context){/此处为具体的消息处理过程，确认消息被处理成功请返回CommitMessage。如果有消费异常，或者期望重新消费，可以...
使用Exactly-Once投递语义收发消息
云消息队列 RocketMQ 版 的Exactly-Once投递语义适用于接收消息>处理消息>结果持久化到数据库的流程，能够保证您的每一条消息消费的最终处理结果写入到您的数据库有且仅有一次，保证消息消费的幂等。更多Exactly-Once投递语义的概念和典型...
示例代码
云消息队列 RocketMQ 版 5.x版本实例可兼容Java ONS 1.x SDK客户端接入，您可以使用ONS 1.x SDK的接入5.x实例进行消息收发。本文为您介绍Java ONS 1.x SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力...
调用TCP协议的SDK收发普通消息
class MyMsgListener:public MessageListener { public:MyMsgListener(){ } virtual~MyMsgListener(){ } virtual Action consume(Message&message,ConsumeContext&context){/自定义消息处理细节。return CommitMessage;CONSUME_SUCCESS;} }...
捷旅假期
本文以捷旅假期为例，介绍如何通过 函数计算、云消息队列 RocketMQ 版 及对象存储等云服务，处理瞬时并发消息等问题。客户介绍 深圳市捷旅国际旅行社有限公司（简称“深捷旅”），自2001年成立以来专注于酒店行业的客房分销业务以及酒店...
Dashboard
借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力，云消息队列 RabbitMQ 版 为企业版和铂金版实例提供Dashboard大盘功能。通过该功能，您可以查看企业版和铂金版实例、Vhost、Queue和Exchange的各种指标数据，帮助您及时...
捷旅假期
本文以捷旅假期为例，介绍如何通过 函数计算、云消息队列 RocketMQ 版 及对象存储等云服务，处理瞬时并发消息等问题。客户介绍 深圳市捷旅国际旅行社有限公司（简称“深捷旅”），自2001年成立以来专注于酒店行业的客房分销业务以及酒店...
在Windows实例无法访问外部网络如何处理？
本文介绍了在Windows实例中访问外部网络不通的处理方法。问题描述 在Windows系统的ECS实例中，无法使用浏览器访问外部网络，如图所示。可能原因 造成该问题的原因与 Windows实例通过外部访问网络不通的处理 类似，常见问题原因参考如下。...
通知和消息有什么区别
消息：发送后不会在系统通知栏弹窗，需要自定义样式和打开方式。iOS和Android的消息都走移动推送自己的通道。通知：会自动在系统通知栏弹窗，用户可以执行打开或者清除通知的操作。注意 一般场景iOS需App在后台或者杀死状态下才会在通知栏...
广播拉取消息模型
本文介绍如何高效利用该模型实现多消费者并行拉取与处理消息。说明 本文以Java SDK为例介绍广播拉取消息流程，其他语言SDK请参见 新版SDK参考（推荐）。前提条件 安装IDEA 您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。...
日志管理概述
错误码 描述 建议处理方法 2xx 消息推送成功。无。其它HTTP状态码 消息推送给用户，Endpoint返回了非2xx的状态码。检查Endpoint端处理逻辑。InvalidHost 订阅指定的Endpoint不合法。确认订阅中Endpoint是否真实有效，可使用curl或telnet...
日志字段详情
队列消息操作日志 队列消息操作日志是指操作队列消息所产生的日志，例如发送消息、消费消息、删除消息等操作。一条消息操作日志中包含多个字段，每个字段都有自己的含义。根据操作的不同，消息操作日志所包含的字段也不相同。以下分别介绍...
mPaaS 框架介绍
框架会率先回调该方法，让接入应用可以预先处理通知消息。当返回DTFrameworkCallbackResultContinue时，框架会把通知消息通过UIApplicationDidReceiveRemoteNotification广播给全局监听者。并调用completionHandler...
消费者分类
SimpleConsumer适用于以下场景：消息处理时长不可控：如果消息处理时长无法预估，经常有长时间耗时的消息处理情况。建议使用SimpleConsumer消费类型，可以在消费时自定义消息的预估处理时长，若实际业务中预估的消息处理时长不符合预期，也...
消息堆积和延迟问题
背景信息 消息处理流程中，如果客户端的消费速度跟不上服务端的发送速度，未处理的消息会越来越多，这部分消息就被称为堆积消息。消息出现堆积进而会造成消息消费延迟。以下场景需要重点关注消息堆积和延迟的问题：业务系统上下游能力不...
什么是RRPC
在设备端开发处理RRPC消息数据的方法，请参见 RRPC功能开发示例。用户服务器调用物联网平台的 RRpc 接口。物联网平台收到服务器端RRPC调用请求，向设备下发一条RRPC请求消息。消息体为用户传入的数据，Topic为物联网平台定义的Topic，且...
- 产品推荐
- 这些文档可能帮助您