消息堆积和延迟问题
背景信息 消息处理流程中，如果客户端的消费速度跟不上服务端的发送速度，未处理的消息会越来越多，这部分消息就被称为堆积消息。消息出现堆积进而会造成消息消费延迟。以下场景需要重点关注消息堆积和延迟的问题：业务系统上下游能力不...
应用场景
事务消息处理 此时，需要利用 云消息队列 RocketMQ 版 所提供的事务消息来实现系统间的状态数据一致性。流程说明如下：注册系统向 云消息队列 RocketMQ 版 发送半事务消息。1.1 半事务消息发送成功，进入2。1.2 半事务消息发送失败，注册...
应用场景
其高性能的消息处理能力可以承接流量脉冲而不被击垮，在确保系统可用性的同时，通过快速有效的请求响应技术提升用户体验。其海量消息堆积能力确保下游业务在安全水位内平滑稳定地运行，避免流量高峰的冲击。分布式缓存同步 大量并发访问...
应用场景
本文为您介绍 SOFAStack 消息队列的适用场景，以便您更好地判断如何在业务中使用消息队列。在互联网金融场景里，其业务涉及广泛，如支付交易、收费计息、商户结算、业务营销、会员积分、风险核查等；同时，也会涉及许多业务峰值时刻，如双 ...
消费者负载均衡
消费示例二：使用SimpleConsumer消费普通消息，主动获取消息处理并提交。会按照订阅的主题自动获取，无需关注消息负载均衡。List<MessageView>messageViewList=null;try { messageViewList=simpleConsumer.receive(10,Duration.ofSeconds...
消息幂等
负载均衡时消息重复（包括但不限于网络抖动、服务端重启以及Consumer应用重启）当 云消息队列 RabbitMQ 版 的服务端或客户端重启、扩容或缩容时，会触发Rebalance，此时Consumer可能会收到重复消息。处理方法 以Message ID为幂等键对消息...
钉钉机器人
目前，仅支持信息推送，不支持返回消息处理。节点配置 在业务逻辑编辑页面的 节点 中，选择对应功能节点配置业务流，钉钉机器人配置如下。配置项 说明 节点名称 设置节点名称。支持中文汉字、英文字母、数字和下划线（_），长度不超过30个...
订阅消息
class ExampleMessageListener:public MessageListener { public:Action consume(Message&message,ConsumeContext&context){/此处为具体的消息处理过程，确认消息被处理成功请返回CommitMessage。如果有消费异常，或者期望重新消费，可以...
批量消费
批量消息处理。return Action.CommitMessage;} });启动batchConsumer。batchConsumer.start();System.out.println("Consumer start success.");等待固定时间防止进程退出。try { Thread.sleep(200000);} catch(InterruptedException e){ e....
应用场景
事务型业务流程编排 复杂的业务场景如电商网站、酒店和机票预定等应用通常要访问多个远程服务，并且对操作事务性语义（即所有步骤全部成功或全部失败，不存在中间状态）有较高要求。在流量较小、数据存储集中的应用中，事务性可以通过关系...
什么是验证码2.0
应用服务端结合业务逻辑处理业务。完成后，向客户端网页返回验证结果和业务处理结果。客户端页面显示提示信息，进行业务处理。如果验证不通过，客户端页面会重新唤起验证码，流程返回 步骤 1。无痕验证 时序图说明：用户在网页完成应用业务...
消费幂等
负载均衡时消息重复（包括但不限于网络抖动、Broker重启以及消费者应用重启）当 消息队列RocketMQ版 的Broker或客户端重启、扩容或缩容时，会触发Rebalance，此时消费者可能会收到少量重复消息。处理方法 因为不同的Message ID对应的消息...
Transaction Table2.0概述
随着当前数据处理业务场景日趋复杂，很多业务场景并不要求延时秒级更新可见或者行级更新，更多的需求是分钟级或者小时级的近实时数据处理叠加海量数据批处理场景，MaxCompute支持基于Transaction Table2.0实现近实时的增全量一体的数据存储...
回执消息配置
云通信的所有业务消息都支持MNS消息服务向外发送。用户在 短信服务控制台 启用MNS消息服务订阅指定的消息类型（MessageType）时，系统会自动生成该类型的独立消息队列及名称（QueueName）。您可使用此消息队列名称（QueueName）和消息类型...
消息幂等
为了防止消息重复消费导致业务处理异常，SOFAStack 消息队列的消费者在接收到消息后，有必要根据业务上的唯一 Key 对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况...
日志管理
本案例要查询某个客户端消息处理量，即输入客户端IP地址，查询语句格式为$ClientIP，例如 10.10.10.0。如果您要查询某个客户端的某类操作日志，可使用多个关键字组合方式，例如$ClientIP and(SendMessage or BatchSendMessage)。查询结果...
开源对比
提供强大的索引能力，可根据Queue、消息ID、消息处理耗时等完成不同维度的查询。详细信息，请参见 消息轨迹。消息轨迹信息以文本格式存储在服务器的log文件中，查询和定位问题效率较低。服务和性能 项目 云消息队列 RabbitMQ 版 开源...
使用函数计算实现消息数据清洗
消息数据清洗功能提供常见的消息处理模板，如消息分割、动态路由和消息富化等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。本文介绍 云消息队列 RocketMQ 版 消息数据清洗模板的类型和使用方式。背景信息 消息...
延时消息
若延时时间超过延时消息最大延时时间，则当作普通消息处理，即消息发送后被立即投递给消费者消费。最大延时时间根据实例类型不同有所差异，具体数值，请参见 集群限制。若您为延时消息设置了消息存活时间，则 延时消息的实际存活时间＝min{...
术语表
前置业务会话一般用于数据的预先处理，例如导出登录Cookie。后置业务会话 在压测结束时执行的业务会话，用于在常规业务会话执行完成后执行必要操作，功能类似于JMeter中的TearDown Thread Group。重要 只有主动单击结束压测才会执行后置...
集群消费和广播消费
广播模式下，消息队列保证每条消息至少被每台客户端消费一次，但是并不会重投消费失败的消息，因此业务方需要关注消费失败的情况。广播模式下，客户端每一次重启都会从最新消息消费。客户端在被停止期间发送至服务端的消息将会被自动跳过，...
消息处理时长自适应
本文介绍如何使消息处理时长自适应。背景信息 消息服务MNS 的规范中，每条消息都有个默认的VisibilityTimeout，Worker在接收到消息后，Timeout就开始计时了。如果Worker在Timeout时间内没能处理完消息，那么消息就有可能被其他Worker接收到...
集群消费和广播消费
适用场景 消息负载均衡：当业务消息量很大时，可以使用集群消费模式将消息分配给多个消费者进行处理，实现负载均衡。每个消费者只处理其中一部分消息，从而提高消息的处理效率和吞吐量。分布式数据处理：在大规模数据处理的场景中，使用...
可观测性体系概述
作为一款典型的分布式中间件产品，云消息队列 RocketMQ 版 被广泛应用于业务核心链路中，每条消息都关联着核心业务数据的变化，通过可观测能力及时发现问题、定位问题、解决问题对于业务运行是一项重要的保障能力。本文介绍 云消息队列 ...
订阅消息
批量消息处理。return Action.CommitMessage;} });启动batchConsumer。batchConsumer.start();System.out.println("Consumer start success.");等待固定时间防止进程退出。try { Thread.sleep(200000);} catch(InterruptedException e){ e....
共享订阅
使用场景 服务端负载均衡 当大量设备接入物联网平台并向物联网平台发送消息时，需要有多个业务服务端来处理这些消息，物联网平台的共享订阅特性可以帮助客户将消息分发到多个业务服务端，实现负载均衡。在下图中，业务服务端A、B使用相同的...
回执消息简介与配置流程
云通信的所有业务消息都支持MNS消息服务向外发送。用户在 ChatApp消息服务控制台 启用MNS消息服务订阅指定的消息类型（MessageType）时，系统会自动生成该类型的独立消息队列及名称（QueueName）。您可使用此消息队列名称（QueueName）和...
主题使用手册
} 步骤六：从队列接收和删除消息 消息从主题推送到队列后，从队列中取出并删除该条消息。try {/调用receiveMessage函数进行消息的拉取。waitSeconds非0表示这次receiveMessage是一次http long polling，如果queue内没有message，那么这次...
什么是消息队列RabbitMQ版？
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品。云消息队列 RabbitMQ 版 兼容开源RabbitMQ客户端，解决开源各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等云...
消息通知功能说明
激活媒体处理消息通知功能。启用媒体处理消息通知功能步骤 激活媒体处理消息通知功能。媒体处理通过MNS实现转码作业及模板分析作业结束时的消息通知功能，因此激活此功能请先 开通MNS服务。创建MNS通知主题。登录 MNS控制台（选择与媒体...
系统函数分类
函数分类 数据探索系统函数的类型包含分为以下几种：函数类型 说明 时间函数 处理日期、时间类型数据，实现加减日期、提取日期字段、获取当前时间、转换日期格式等业务处理能力。字符串函数 处理字符串类型数据，实现截取字符串、替换字符...
媒体处理常见问题
媒体处理创建消息主题出现“Only one topic can be created！错误。目前媒体处理每个用户只能开一个管道，无法创建多管道，所以会出现Only one topic can be created！这个错误。开启管道或添加管道，请参见 创建管道。媒体处理服务中...
仪表盘
业务背景 云消息队列 RocketMQ 版 的消息收发流程中，队列的堆积情况、缓冲情况以及消息处理各关节的耗时等，会直接反映当前业务处理的性能和服务端运行的状态。因此，云消息队列 RocketMQ 版 的重点指标主要涉及以下业务场景。消息堆积...
接口和参数说明
本文介绍 云消息队列 MQTT 版 云端Java SDK提供的接口和相关的参数说明。使用说明 公共参数和网络参数可在 ChannelConfig.class 中设置。ChannelConfig.class 路径为 server-sdk-{SDK Version}\com\alibaba\mqtt\server\config ，其中 {SDK...
查看消费者状态
请参见 订阅关系不一致 消息堆积 在 Group 详情 页面，看到Group ID的 处理中消息量、就绪消息量 和 排队时间 的值高于预期。请参见 如何处理消息堆积 查看Group ID基本信息 查询入口 登录 云消息队列 RocketMQ 版 控制台，在左侧导航栏...
配额与限制
消费不可见时间指的是消息处理+失败后重试间隔的总时长，建议设置时取值比实际需要耗费的时间稍微长一些。消费者长轮询超时时间 取值范围：最小值5秒，最大值20秒。支持用户在取值范围内自定义调整。设置长轮询超时时间后，如果当前服务端...
使用Canal将MySQL的数据同步至云消息队列 Kafka 版
较小的批量处理数值可能降低吞吐量，而较大的批量处理数值将会浪费更多内存空间，分配一个指定的批量处理消息缓冲区有助于提高客户端和服务端的性能。说明 kafka.batch.size 与 kafka.linger.ms 参数都是控制批量处理消息的条件，满足其中...
故障发现
7*24监控值班 对于有条件的企业，可以设立全球...抑制周期性误报，当跌落型异常在同一时刻持续多天时抑制该报警，对应每天大促或消息型任务每天定时跌落的业务场景。建议重点覆盖成功（总）量、成功（失败）率、失败量三类场景的业务指标。
迁移上云概述
消息收发无大量重复 保证迁移过程中不会出现大量的消息重复，业务方无需为迁移方案单独处理系统性重复消息。消息收发无明显延迟 保证迁移过程中消息收发端到端延迟不会有明显变化，不会因迁移导致大量消息接收不到。方案设计原理 为满足...
使用异常
public class MessageListenerImpl implements MessageListener {@Override public Action consume(Message message,ConsumeContext context){/消息处理逻辑抛出异常，消息将重试 doConsumeMessage(message);如果在 doConsumeMessage()方法...
- 产品推荐
- 这些文档可能帮助您