消息队列
任务A作为生产者循环向消息队列发送消息，任务B作为消费者循环从消息队列接收消息，一般情况下，消费者处理数据是要花费很长时间，所以会导致消息产生的速度大于消息处理的速度，使得消息队列溢出。所以可以通过调整任务B优先级大于任务A来...
产品架构
发送的消息可以是网站的页面访问、服务器日志，也可以是CPU和内存相关的系统资源信息。Kafka Broker 用于存储消息的服务器。Kafka Broker支持水平扩展。Kafka Broker节点的数量越多，云消息队列 Kafka 版 集群的吞吐率越高。Group 通过pull...
使用云消息队列 Kafka 版时出现消息堆积
此时，需要排查 步骤2 的消费耗时，请参见下文的 消息堆积的处理方式 章节进行处理。说明 消息堆积大多是消费速度过慢或者消费线程阻塞造成的，建议不要在消费逻辑中有太多耗时的操作。分区消息堆积，下游消费却无异常。下游可能采用了 ...
开通服务
开通媒体处理服务前，您需要先进行实名认证。完成认证后，进入媒体处理控制台进行相关的授权操作。请您按照以下步骤完成开通MPS服务。前提条件 您已经注册了阿里云账号并完成账号实名认证。注册地址请参见 阿里云官网。注册指引请参见 注册...
ARMS统一告警管理最佳实践
本文介绍告警统一管理的最佳实践，以帮助企业更好地处理异构监控系统所带来的挑战和问题。背景信息 在云原生时代，企业IT基础设施的规模越来越大，越来越多的系统和服务被部署在云环境中。为了监控这些复杂的IT环境，企业通常会选择使用...
订阅者最佳实践
消费失败 云消息队列 Kafka 版 是按分区逐条消息顺序向前推进消费的，如果消费端拿到某条消息后执行消费逻辑失败，例如应用服务器出现了脏数据，导致某条消息处理失败，等待人工干预，那么有以下两种处理方式：失败后一直尝试再次执行消费...
部署数据库
常用数据库简介 常用数据库包含以下三种：Oracle Oracle可以支持多种不同的硬件和操作系统平台，从台式机到大型或超级计算机，为各种硬件结构提供高度的可伸缩性，支持对称多处理器、群集多处理器、大规模处理器等，并提供广泛的国际语言...
消息收发计算规格费用
计算规格说明 计算规格能力约束 消息收发TPS 云消息队列 RocketMQ 版 计算规格的大小，实际是 云消息队列 RocketMQ 版 处理消息收发的TPS上限。不同的规格对应不同的TPS上限，具体对应关系，请参见 实例规格。其他资源配额 每个实例规格除...
ARMS告警精细管理最佳实践
如下图所示是一个典型的垂直业务系统应该配置的告警信息，在这个垂直系统中不同层次的组件所产生的告警它的处理方式和处理人会完全不同。当业务由多个垂直业务组成，并且部署在全球多个区域时，带来的告警规则配置复杂度=垂直业务*依赖组件...
查询消息轨迹
收集疑似有问题的消息信息，包括Message ID、Message Key、Topic以及大概的发送时间。进入 云消息队列 RocketMQ 版 控制台，根据已有的信息创建查询任务，查询相关的消息的轨迹。查看结果并分析判断原因。如果轨迹显示 尚未消费，则可以...
排查追踪
错误码 SDK的API在异常时会抛出HttpDnsError类型的错误，有错误码code和错误信息message两个字段，可以根据具体错误码排查错误原因 错误码 错误信息 处理方法 备注 HTTPDNS_000 系统错误 查看具体的错误信息，会有系统错误的错误码 场景是...
AMD实例规格与操作系统兼容性说明
各操作系统对AMD Genoa处理器（8代AMD规格族）兼容性说明 下表列出了支持AMD Genoa处理器的不同操作系统版本。操作系统 官方兼容的操作系统版本 官方兼容性说明文档 已知的不兼容风险 Windows Windows Server 2019 Windows Server 2022 ...
收发顺序消息
顺序消息FIFO（First In First Out）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的C/C++ SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，...
查看消费者状态
应用场景 消费者状态信息包括在线状态、订阅关系、消费TPS、消息堆积量和线程堆栈信息等，经常被应用于以下故障排查场景：故障场景 现象 处理建议 订阅关系不一致 在 Group 详情 页面，看到Group ID的 订阅关系 显示 订阅关系不一致，请...
技术面临的挑战与革新
在分布式数据库中，同样也可以采用这种模式，将事务集中在一个节点处理，而这限制了事务处理的扩展能力，系统能处理的事务操作的数据范围受限于单个节点所能访问的数据范围，事务处理能力也受限于单个节点的处理能力。
通过可观测性能力进行故障处理最佳实践
消息处理成功率=消息处理成功次数/消息处理失败次数+成功次数。查询方式，请查看 仪表盘 中，消费者指标下的统计面板。根据业务逻辑或指标的变化趋势定位具体原因，例如消息处理耗时变长，则可以查看消费者服务的内存、CPU等是否过载；或...
发现和排查实例问题
系统事件中会同时提供应对措施、事件周期等信息，建议您及时处理系统事件，避免实例重启、停止等问题影响您的业务。更多信息，请参见 ECS系统事件概述。通知包年包月实例到期的系统事件示例如下图所示。请确保在 消息中心 开启接收ECS到期...
消息过滤
使用 云消息队列 RocketMQ 版 的消息过滤功能，可以帮助消费者更高效地过滤自己需要的消息集合，避免大量无效消息投递给消费者，降低下游系统处理压力。云消息队列 RocketMQ 版 主要解决的单个业务域即同一个主题内不同消息子集的过滤问题...
消费进度管理
若您希望重新消费这些已被处理的消息，可以通过重置消费位点快速将消费位点更新到历史指定位置，实现消费回溯。重置功能 云消息队列 RocketMQ 版 的重置消费位点提供以下能力：从最新位点开始消费 Group ID消费指定Topic中的消息时，会跳过...
应用场景
风控监测系统 实时计算Flink版可以处理复杂的流处理和批处理任务，也提供了强大的API，执行复杂的数学计算并执行复杂事件处理规则，帮助企业对实时数据进行实时分析，提高企业的风控能力。例如检测APP中的点击行为、识别loT数据流不规则...
云市场店铺工单系统介绍
开通店铺工单系统的好处：及时处理售前咨询，获得销售机会。提升用户对服务商的信任度，促进用户快速下单。提升服务商的售后服务效率，及时响应用户问题，提升服务体验并促进续费。不断提升服务解决率、商品好评率等服务能力，整体提升商品...
批量消费
批量消息处理。return Action.CommitMessage;} });启动batchConsumer。batchConsumer.start();System.out.println("Consumer start success.");等待固定时间防止进程退出。try { Thread.sleep(200000);} catch(InterruptedException e){ e....
事务消息
半事务消息：暂不能投递的消息，生产者已经成功地将消息发送到了 云消息队列 RocketMQ 版 服务端，但是 云消息队列 RocketMQ 版 服务端未收到生产者对该消息的二次确认，此时该消息被标记成“暂不能投递”状态，处于该种状态下的消息即半...
削峰填谷
上图中，黄色区域代表超出消息处理能力的部分。将黄色部分的消息平均分布到之后的空闲时间去处理，既可以保证系统负载处在一个稳定的水位，又可以尽可能地处理更多消息。通过配置流控规则，可以达到消息匀速处理的效果。功能原理 限流降级...
削峰填谷
上图中，黄色的部分代表超出消息处理能力的部分。把黄色部分的消息平均到之后的空闲时间去处理，这样既可以保证系统负载处在一个稳定的水位，又可以尽可能地处理更多消息。通过配置流控规则，可以达到消息匀速处理的效果。功能原理 AHAS流...
消息轨迹
按消息处理耗时：在 按消息处理耗时 页签中，选择要查询消息的Queue，输入消息处理耗时时间（单位为秒），设置查询 时间范围，然后单击 查询。在查询的消息列表，选择要查询消息轨迹的消息，在其 操作 列，单击 轨迹详情。在消息轨迹详情...
使用Exactly-Once投递语义收发消息
云消息队列 RocketMQ 版 的Exactly-Once投递语义适用于接收消息>处理消息>结果持久化到数据库的流程，能够保证您的每一条消息消费的最终处理结果写入到您的数据库有且仅有一次，保证消息消费的幂等。更多Exactly-Once投递语义的概念和典型...
通知点击处理
如需处理收到的消息，请参考 自定义消息处理。厂商通道收到消息后手机系统会自动发出通知，推送 SDK 和开发者都无法干预，只有当用户点击通知后，推送 SDK 才能收到消息，并自动打开网页，如需：跳转到应用内页面，请参考 跳转应用内页面。...
Windows系统异常重启以及蓝屏的处理方法
本文介绍Windows系统异常重启以及蓝屏的处理方法。问题描述 在Windows系统下，有时会遇到蓝屏（BSOD，Blue Screen of Death）情况。Windows操作系统在遇到异常的情况下，为了防止数据丢失，系统自动崩溃蓝屏，如果有配置内存转储文件...
管理事件
事件用于记录和通知云资源信息，包括资源异常、操作执行情况以及资源状态变化等。E-MapReduce（简称EMR）会记录当前集群资源发生的系统事件，并自动将其同步到云监控服务。您可以在EMR控制台查看集群的事件，并在云监控控制台中设置事件告...
如何优化高并发IM系统架构
新架构中自增操作是在表格存储系统内部处理的，就算多个应用服务器同时给表格存储中的同一个接收方写数据，表格存储内部也能保证这些消息是串行处理，每个消息都有一个独立的消息ID，且严格递增。使用主键列自增功能，就不再需要队列服务，...
概述
SOFAStack 消息队列（SOFAStack MQ，简称 SOFAMQ）是基于 Apache RocketMQ 构建的分布式消息中间件，并与金融分布式架构 SOFAStack 深度集成，为分布式应用系统提供异步解耦和削峰填谷的能力，支持事务消息、顺序消息、定时消息等多种消息...
配置流控规则
系统需处理的请求是随机不可控的，而系统的处理能力是有限的，因此就需要根据系统的处理能力对流量进行控制。功能入口 登录 MSE治理中心控制台，并在顶部菜单栏选择地域。在左侧导航栏，选择 治理中心>应用治理。在 应用列表 页面，单击...
主机规则管理
安全告警事件误报处理 在处理告警类型为 精准防御 的告警事件时，如果您发现云安全中心的系统防御规则检测出的安全告警事件，在经过您识别后为正常的业务进程，您可以在 恶意行为防御 页面的 系统防御规则 页签下关闭该系统防御规则，或者...
应用场景
其高性能的消息处理能力可以承接流量脉冲而不被击垮，在确保系统可用性的同时，通过快速有效的请求响应技术提升用户体验。其海量消息堆积能力确保下游业务在安全水位内平滑稳定地运行，避免流量高峰的冲击。分布式缓存同步 大量并发访问...
通知
单击 通知 页面下的 系统通知 页签，处理收到的凭证授权通知消息。单击 接受授权，则弹出下面的弹窗，提示用户配置凭证的数据出口等设置。单击 拒绝，弹出如下弹窗。无论接受或者拒绝，都会在 通知列表 中将 状态（全部）改成 已处理。网关...
HLS标准加密
在 授权主体 搜索框搜索 AliyunMtsDefaultRole，选择系统创建的可供媒体处理使用的角色。在 选择权限 下方的搜索框搜索 KMS 并选择 AliyunKMSFullAccess，然后单击 确定。完成授权后，媒体处理可以访问您的KMS服务。收到加密视频请求时，...
HLS标准加密
视频加密旨在通过对视频内容进行深度安全处理，确保视频数据不被非法获取和传播，可有效防止视频泄露和盗链问题，广泛用于在线教育及财经等对内容安全性要求高的领域。阿里云目前支持两种加密方式：阿里云私有加密（推荐）和HLS标准加密。...
基本概念
函数计算 系统会可靠地处理该消息，但不会返回具体的调用情况和函数执行状态。如您想获取异步调用结果，必须通过配置异步调用目标来实现。具体信息，请参见 异步调用功能概览。如您想追踪并保存异步调用各个阶段的状态，可以选择开启异步...
智能接入网关App FAQ
本文为您介绍使用智能接入网关App过程中常见问题和处理方法。登录阿里云网络客户端时，报错“[1000]程序异常请重启错误”，怎么处理？阿里云网络客户端账号无法删除，怎么处理？阿里云网络客户端启动2~5分钟和管控连接断开，怎么处理？使用...
- 产品推荐
- 这些文档可能帮助您