查看消息
实时消息：当管理员为您的云电脑设置定时任务、即时操作（关机和重启）、更改策略、变更资源规格、分配或回收资源，以及系统升级和远程协助等都将触发实时消息，您在使用云电脑时可在实时消息面板查看弹出的消息框。说明 仅1.3.0及以上版本...
查看消息引擎监控信息
实例监控 展示消息引擎维度的相关监控，例如实时写入流量、实时读取流量和实时消息写入数等。Topic监控 展示Topic维度的监控，可以指定Topic查看。例如查看指定Topic的实时写入流量、实时读取流量和实时消息写入数等。Group监控 展示消费者...
查看数据指标
发送到平台的消息量 设备发送到物联网平台的实时消息数量。按设备与物联网平台的通信协议类型进行区分显示。平台发出的消息量 从物联网平台发送到设备和服务端的实时消息数量。按设备与物联网平台的通信协议类型进行区分显示。规则引擎消息...
什么是服务端订阅
设备实时消息直接推送，推送限流或失败时进入堆积队列，堆积态消息采用降级模式，不会影响实时推送能力。即使消费者的客户端宕机，或因消费能力不足堆积了消息，消费端恢复后，设备生成的消息也可以和堆积消息并行发送，使设备优先恢复实时...
查看实例信息和运行数据
实时消息上下行TPS 消息上下行TPS 实时消息转发TPS 消息转发TPS 数据服务 标准型和尊享型 实时时序存储IOPS 时序存储IOPS 实时时序存储空间 时序存储空间 实时数据处理单元 数据处理单元 实时离线存储空间 离线存储空间 高精度秒级监控 ...
权益分发
在电商和新零售领域，权益分发适用于对特定的用户进行指定运营活动的...支持实时消息收发以及重试功能，确保消息不丢，从而保证消息强一致性。更多信息 云消息队列 RocketMQ 版 的功能与特性详情，请参见以下文档：功能与特性概述 消息重试
如何处理消息堆积
问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警，登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象：在 Group 详情 页面，看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹，单击 创建查询任务，...
可观测性体系概述
指标 云消息队列 RocketMQ 版 中定义了详细的Metrics指标，这些指标覆盖生产者、消费者、服务端及消息收发关键接口和流程的统计数据，并支持从实例、Topic和Group等多个维度进行聚合展示，帮助您实时监控消息业务或 云消息队列 RocketMQ 版...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
功能与特性概述
消息类型对比 消息类型 是否支持可靠同步发送 是否支持可靠异步发送 是否支持Oneway发送 是否支持多线程发送 性能 普通消息 是 是 是 是 最高 事务消息 定时和延时消息 分区顺序消息 是 否 否 否 高 全局顺序消息 一般 消息特性 消息重试：...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
应用场景
通过 云消息队列 Kafka 版 的发布/订阅模型，您可以实时收集网站活动数据（例如注册、登录、充值、支付、购买），根据业务数据类型将消息发布到不同的Topic，然后利用订阅消息的实时投递，将消息流用于实时处理、实时监控或者加载到Hadoop...
消息过滤
实时计算系统：需要订阅所有和交易相关的消息。过滤效果如下图所示：Tag标签设置 Tag由生产者发送消息时设置，每条消息允许设置一个Tag标签。Tag使用可见字符，建议长度不超过128字符。Tag匹配时大小写敏感，例如，TAG A和tag a属于两个...
消息过滤
实时计算系统：需要订阅所有和交易相关的消息。过滤示意图如下所示。配置方式 云消息队列 RocketMQ 版 支持通过SDK配置Tag过滤功能，分别在消息发送和订阅代码中设置消息Tag和订阅消息Tag。SDK详细信息，请参见 SDK参考概述。消息发送端和...
消费者分类
内部原理 在PushConsumer类型中，消息的实时处理能力是基于SDK内部的典型Reactor线程模型实现的。如下图所示，SDK内置了一个长轮询线程，先将消息异步拉取到SDK内置的缓存队列中，再分别提交到消费线程中，触发监听器执行本地消费逻辑。...
仪表盘
当前时间－最早一条未提交消息的就绪时间 PushConsumer消费场景 在PushConsumer类型中，消息的实时处理能力是基于SDK内部的典型Reactor线程模型实现的。如下图所示，SDK内置了一个长轮询线程，先将消息异步拉取到SDK内置的缓存队列中，再...
典型使用场景
而接合LindormStreams+Blink/Spark，可以构建出一套完整的实时数据系统：应用解耦-实时同步到消息队列 通常业务发生之后，应用系统产生的数据需要被其他应用使用或根据这个事件驱动其他应用的业务逻辑，应用之间一般通过消息队列进行消息...
MySQL分库分表实践
实时同步DDL消息处理策略 根据业务情况为任务设置DDL消息处理策略。本示例DDL消息处理策略设置如下所示。单击 下一步。运行资源设置 根据业务情况进行运行资源设置，包括资源组、连接数，并发数等。单击 完成配置。运行任务 配置完成之后，...
消息堆积和延迟问题
业务系统对消息的消费实时性要求较高，即使是短暂的堆积造成的消息延迟也无法接受。客户端消费原理 云消息队列 RocketMQ 版 TCP协议客户端的消费流程如下图所示。SDK客户端使用Push模式消费消息时，分为以下两个阶段：阶段一：获取消息，...
应用场景
推荐系统 推荐系统作为当前所有业务精细化运营的主要手段，广泛应用在电商、短视频、新闻等场景，具有数据量大、实时更新、个性化推荐等特点，因此需要支持海量消息存储以及实时与离线分析。推荐系统的核心需求如下：行为日志：存储客户端...
QPS限制
100 删除互动消息应用 100 创建消息组 100 更新消息组 100 查询消息组成员 100 查询指定用户下消息组 100 获取消息组详情 100 加入消息组 200 禁言消息组全员 100 批量禁言消息组内成员 100 批量取消消息组内禁言成员 100 查询被禁言的消息...
搭配云HBase和Spark构建一体化数据处理平台
实时计算：通过X-Pack Spark Streaming实时地消费 云消息队列 Kafka 版 的消息，写入到云HBase中对外提供在线查询。实时存储与检索：云HBase融合Solr以及Phoenix SQL层能够提供海量的实时存储，以及在线查询检索。批处理、数仓及算法：在线...
使用客户端发送消息后，如何确定是否发送成功？
如果回调成功则说明消息发送成功。大部分客户端在发送之后，会返回...此外，您还可以在控制台通过以下方式确认消息发送是否正常：查看Topic的分区状态，可以实时看到各个分区的消息数量。查看Topic的流量监控，可以看到分钟级别的流量曲线。
产品功能
运维配套 云消息队列 RabbitMQ 版 提供一整套完善、便捷、易用的产品运维工具：监控告警：实时监控在线连接、消息堆积、投递延迟，及时发现问题。资源报表：设备查询、分组在线设备管理、消息收发统计等。OpenAPI（RESTful）：提供自助资源...
基于Flink的资讯场景实时数仓
本文介绍如何针对资讯聚合类业务场景搭建基于 云消息队列 Kafka 版 和实时计算Flink的实时数仓。场景描述 本文首先介绍什么是实时数仓以及相关技术架构，接着介绍资讯聚合类业务的典型场景及其业务目标，并据此设计了相应的技术架构。然后...
Topic与Tag最佳实践
消息量级是否相当：有些业务消息虽然量小但是实时性要求高，如果跟某些万亿量级的消息使用同一个Topic，则有可能会因为过长的等待时间而“饿死”，此时需要将不同量级的消息进行拆分，使用不同的Topic。总的来说，针对消息分类，您可以选择...
消息队列
概述 智能对话分析服务作为消息的生产者，通过向您的阿里云消息队列RocketMQ服务中发送消息的方式推送相关信息给您，您作为消息的消费者从RocketMQ中接收并消费消息，从而实现低延迟、高并发、高可用的消息推送。视频讲解 授权 需要您授权...
消息队列
概述 智能对话分析服务作为消息的生产者，通过向您的阿里云消息队列RocketMQ服务中发送消息的方式推送相关信息给您，您作为消息的消费者从RocketMQ中接收并消费消息，从而实现低延迟、高并发、高可用的消息推送。授权 需要您授权，允许智能...
仪表盘
借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力，云消息队列 RocketMQ 版 提供可实时进行数据统计的仪表盘功能。该功能可帮助您一站式、全方位、多维度地统计和观测指标，进而快速了解业务的运行状态。本文介绍仪表盘...
集群消费和广播消费
集群消费和广播消费是 云消息队列 RocketMQ 版 的基本消费模式，您可以在消费者客户端将消费模式设置为集群消费或者广播消费，用于控制同一条消息只能被集群内一个消费者消费到，还是会被集群内每个消费者都消费到。背景信息 云消息队列 ...
查看实例风险
云消息队列 Kafka 版 实例的实时诊断功能能够定期对实例进行检测，支持查看诊断发现的问题、提供修复建议，并将异常的检查项上报告警给相关联系人。实现方案 报警通知说明 仅紧急且不健康的报警会发送报警通知。如果未添加报警联系人，则...
监控报警
云监控服务具有指标采集、可视化、实时报警等功能，云消息队列 RocketMQ 版 支持通过云监控创建监控规则，帮助您自动监控服务的运行状态，并自动发送报警通知，便于您及时预警服务的异常信息，提高运维效率。监控项说明 说明 消息堆积量、...
功能与优势
可以更加高效便捷的对包含分库分表等架构的业务数据库、消息中间件中的数据进行实时的入湖入仓。实时风控场景能力 企业级复杂事件处理（CEP）支持作业无需重启动态可配置规则，实现在线实时风控等场景的不间断生产级能力。应用于实时营销、...
云消息队列 RocketMQ 版
重要 鉴于 云消息队列 RocketMQ 版 4.x标准版当前最高可达每秒5千条消息的限速机制，使用该版作为实时计算Flink版对接的消息中间件，可能会导致Flink作业运行不稳定。因此，在选择消息中间件时，如果您正在或计划通过标准版RocketMQ与Flink...
查看实例风险
云消息队列 Kafka 版 实例的实时诊断功能能够定期对实例进行检测，支持查看诊断发现的问题、提供修复建议，并将异常的检查项上报告警给相关联系人，帮助您及时处理异常。实现方案 检测项 说明 若检测出实例存在风险，请参考控制台上提示的...
监控报警
云监控服务具有指标采集、可视化、实时报警等功能，云消息队列 MQTT 版 支持通过云监控创建告警规则，帮助您自动监控服务的运行状态，并自动发送报警通知，便于您及时预警服务的异常信息，提高运维效率。监控项说明 说明 云监控中统计的...
查询MNS日志
阿里云消息服务（MNS）日志推送到日志服务后，可进行实时查询，本文介绍实时查询的常用场景及操作步骤，您也可以通过多个关键字组合方式实现更加复杂的查询。前提条件 已采集到MNS日志。具体操作，请参见 MNS日志。已配置索引。具体操作，...
顺序消息
如需保证消息生产的顺序性，则必须满足以下条件：同一消息组（MessageGroup）消息生产顺序性的范围为消息组，生产者发送消息时可以为每条消息设置消息组，只有同一消息组内的消息可以保证顺序性，不同消息组或未设置消息组的消息之间不保证...
监控报警
Byte InstanceStorageSize userId、instanceId Sum 已就绪消息排队时间（Group）millisecond ReadyMessageQueueTime userId、instanceId、groupId Maximum 已就绪消息排队时间（Group&Topic）millisecond ReadyMessageQueueTimePerGidTopic...
2022年及之前公告
本文为您介绍实时计算Flink版2022年及之前产品公告，包括平台升级、API版本升级等。2022年9月19日，API版本升级公告 2022年9月19日，我们对实时计算Flink版API版本进行了升级。后续将默认使用新的API版本（V2版本）为您服务。相较于V1版本...
- 产品推荐
- 这些文档可能帮助您