EDI许可证

在线数据处理与交易业务经营许可证(简称:EDI证)是指经营含有相关业务的网站主办者向当地区县申请的证书证明,即《中华人民共和国增值电信业务经营许可证》,其中业务种类为:在线数据处理与交易处理业务。阿里云为您提供优质高效的代办...

消息堆积和延迟问题

背景信息 消息处理流程中,如果客户端的消费速度跟不上服务端的发送速度,未处理的消息会越来越多,这部分消息就被称为堆积消息。消息出现堆积进而会造成消息消费延迟。以下场景需要重点关注消息堆积和延迟的问题业务系统上下游能力不...

媒体处理

阿里云媒体处理(ApsaraVideo Media Processing,原MTS)是一种多媒体数据处理服务。它以经济、弹性和高可扩展的转换方法,将多媒体数据转码成适合在全平台播放的格式。并基于海量数据深度学习,对媒体的内容、文字、语音、场景多模态分析...

自然语言处理

自然语言处理(Natural Language Processing,简称NLP),是为各类企业及开发者提供的用于文本分析及挖掘的核心工具,已经在客服、资讯、金融、司法、医疗等场景有广泛的应用。

消费幂等

为了防止消息重复消费导致业务处理异常,消息队列RocketMQ版的消费者在接收到消息后,有必要根据业务上的唯一Key对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况时...

如何处理消息堆积

问题现象 在使用消息队列RocketMQ版实例时收到消息堆积告警,登录消息队列RocketMQ版控制台后发现了下列现象:在Group 详情页面,看到Group ID的实时消息堆积量的值高于预期。导航栏中选择消息轨迹,单击创建查询任务,选择按按 Message ID...

消息幂等

如果消息重复消费会影响您的业务处理,请对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 在数学与计算机学中,幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同。在消息领域,幂等是...

顺序消息1.0

如果业务出现增长,单物理节点的性能会出现瓶颈,如果强行扩容会影响消息路由策略和顺序,拆分业务也会造成额外的改造成本。因此顺序消息1.0适用于业务比较稳定,消息量波动比较小,后期不需要进行扩容的场景。如果考虑业务增长可能需要扩...

顺序消息2.0

高并发无限扩展在保持顺序的前提下,每个逻辑分区对应的物理分区可以无限水平扩展,极大提高消息处理的并发性,并且业务侧无感知,也不需额外的业务改造成本。故障秒级恢复单个物理分区故障,其他物理分区可继续处理消息,达到秒级切换,...

适用场景

本文为您介绍消息队列RocketMQ版的适用场景,以便您更好地判断如何在业务中使用消息队列RocketMQ版。例如,针对一家互联网电商企业,其业务涉及广泛,如注册、订单、库存、物流等;同时,也会涉及许多业务峰值时刻,如秒杀活动、周年庆、...

Exactly-Once投递语义

消息队列RocketMQ版的Exactly-Once语义就是解决业务中最常见的一条消息的消费结果(消息在消费端计算处理的结果)在数据库系统中有且仅生效一次的问题。典型使用场景 在电商系统中,上游实时计算模块发布商品价格变更的信息,异步通知到...

消息处理时长自适应

本文介绍如何使消息处理时长自适应。背景信息 消息服务MNS的规范中,每条消息都有个默认的VisibilityTimeout,Worker在接收到消息后,Timeout就开始计时了。如果Worker在Timeout时间内没能处理完消息,那么消息就有可能被其他Worker接收到...

查询消息轨迹

消息处理开始 消息开始消费时的客户端时间戳。消息处理结束 消息完成消费时的客户端时间戳。消息处理耗时 消息消费开始到结束的耗时。在消息轨迹的任务列表页,单击某任务操作列的查询结果会显示消息的发送状态和消费状态;而消息轨迹链路...

实例规格

消息队列RocketMQ版实例按照规格分为企业铂金版和标准版,您可以参照以下版本对比信息,选择所需实例规格。企业铂金版和标准版对比如下表所示。项目 企业铂金版 标准版 付费方式 包年包月(预付费)按量付费(开通服务,默认后付费)说明 ...

基于Flink的资讯场景实时数仓

本文介绍如何针对资讯聚合类业务场景搭建基于消息队列Kafka版和实时计算Flink的实时数仓。场景描述 本文首先介绍什么是实时数仓以及相关技术架构,接着介绍资讯聚合类业务的典型场景及其业务目标,并据此设计了相应的技术架构。然后介绍...

消息幂等

为了防止消息重复消费导致业务处理异常,SOFAStack 消息队列的消费者在接收到消息后,有必要根据业务上的唯一 Key 对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等当出现消费者对某条消息重复消费的情况...

应用场景

与传统架构不同,消息队列Kafka版以及Storm、Samza、Spark等流计算引擎的出现,就是为了更好地解决这类数据在处理过程中遇到的问题,流计算模型能实现在数据流动的过程中对数据进行实时地捕捉和处理,并根据业务需求进行计算分析,最终把...

实例数据统计

若您的业务出现异常,初步排查需要定位是否出现消息堆积。您无需进入每个Group的详情页面单独查看,通过实例数据统计可以一站式观测所有Group的消息堆积情况,帮助您快速定位异常Group位置,提高故障处理效率。快速巡检运维场景下,通过...

实例类型

本文介绍微消息队列MQTT版的实例类型。表 1.实例类型 项目 铂金版 基础版 轻量版 按量付费 实例类型 专享实例(物理隔离)。底层硬件资源独享,每个实例都是独立部署的集群,不会受到其他用户的业务高峰的影响,提供更高优先级的售后服务和...

集群消费和广播消费

本文介绍消息队列RocketMQ版的集群消费和广播消费的基本概念、适用场景以及注意事项。消息队列RocketMQ版是基于发布或订阅模型的消息系统。消费者,即消息的订阅方订阅关注的Topic,以获取并消费消息。由于消费者应用一般是分布式系统,以...

事务消息

半事务消息:暂不能投递的消息,发送方已经成功地将消息发送到了消息队列RocketMQ版服务端,但是服务端未收到生产者对该消息的二次确认,此时该消息被标记成“暂不能投递”状态,处于该种状态下的消息即半事务消息消息回查:由于网络闪断...

在线教育视频直播

解决直播中手机端互发消息消息内容的安全审核问题,同时低成本保存消息。部署架构图 选用的产品 消息队列RocketMQ版消息队列RocketMQ版是由阿里巴巴自研并捐赠给Apache基金会,并与开源社区共建的消息中间件,该产品服务于阿里巴巴集团已...

捷旅假期

本文以捷旅假期为例,介绍如何通过函数计算、消息队列RocketMQ版及对象存储等云服务,处理瞬时并发消息问题。客户介绍 深圳市捷旅国际旅行社有限公司(简称“深捷旅”),成立18年来专注于酒店行业的客房分销业务以及酒店预订信息化水平...

订阅者最佳实践

消费失败 消息队列Kafka版是按分区逐条消息顺序向前推进消费的,如果消费端拿到某条消息后执行消费逻辑失败,例如应用服务器出现了脏数据,导致某条消息处理失败,等待人工干预,那么有以下两种处理方式:失败后一直尝试再次执行消费逻辑。...

收发事务消息

本文提供使用TCP协议下的C/C++ SDK收发事务消息的示例代码供您参考。消息队列RocketMQ版提供类似XA或Open XA的分布式事务功能,通过消息队列RocketMQ版事务消息,能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图所示。更多...

名词解释

消息堆积 Producer已经将消息发送到消息队列RocketMQ版的服务端,但由于Consumer消费能力有限,未能在短时间内将所有消息正确消费掉,此时在消息队列RocketMQ版的服务端保存着未被消费的消息,该状态即消息堆积。消息过滤 Consumer可以根据...

音视频通信解决方案(MQTT)

具体流程如下所述:终端App的某个用户A发起会议请求,通过发送MQTT消息将请求传递到MQTT服务端,消息经过微消息队列MQTT版路由到消息队列RocketMQ版,业务方自行开发的音视频管控服务通过接收消息处理该会议请求,验证通过后调用音视频通信...

应用场景

其高性能的消息处理能力可以承接流量脉冲而不被击垮,在确保系统可用性的同时,通过快速有效的请求响应技术提升用户体验。其海量消息堆积能力确保下游业务在安全水位内平滑稳定的运行,避免流量高峰的冲击。分布式缓存同步 大量并发访问...

Topic与Tag最佳实践

消息队列RocketMQ版中,Topic与Tag都是业务上用来归类的标识,区分在于Topic是一级分类,而Tag可以理解为是二级分类。您可通过本文了解如何搭配使用Topic和Tag来实现消息过滤。背景信息 Topic和Tag的定义如下:Topic 消息主题,通过Topic...

收发事务消息

try { SendResult sendResult=producer.send(msg,new LocalTransactionExecuter(){@Override public TransactionStatus execute(Message msg,Object arg){/消息ID(有可能消息体一样,但消息ID不一样,当前消息属于半事务消息,所以消息ID...

消息状态显示“Consumed”但消费端业务日志显示没有...

public class MessageListenerImpl implements MessageListener {@Override public Action consume(Message message,ConsumeContext context){/消息处理逻辑抛异常,消息将重试。doConsumeMessage(message);如果在doConsumeMessage()方法...

常见问题

客户端报错 客户端常见的报错及解决方案 客户端出现“Not authorized to access group”的错误信息 网络问题 无法ping通消息队列Kafka版的接入点 不在同一可用区内的ECS实例如何访问消息队列Kafka版实例 能否通过公网访问消息队列Kafka版...

产品功能

说明 消息队列RabbitMQ版内部暂未实现消息优先级的处理逻辑,您的客户端通过可选队列参数x-max-priority声明的优先级队列实际是无效的。Exchange:支持将消息按照规则路由到一个或多个Queue,同时对不符合路由规则的消息进行丢弃。Vhost:...

直播互动解决方案

订阅了消息队列RocketMQ版Topic的后端应用消费该消息以实现业务处理,例如内容审核。后端应用将处理后的消息再次发送至消息队列RocketMQ版的Topic。消息队列RocketMQ版根据创建的数据流入规则将该消息转发至微消息队列MQTT版。微消息队列...

音视频通信解决方案(MQTT)

具体流程如下所述:终端App的某个用户A发起会议请求,通过发送MQTT消息将请求传递到MQTT服务端,消息经过微消息队列MQTT版路由到消息队列RocketMQ版,业务方自行开发的音视频管控服务通过接收消息处理该会议请求,验证通过后调用音视频通信...

直播互动解决方案

订阅了消息队列RocketMQ版Topic的后端应用消费该消息以实现业务处理,例如内容审核。后端应用将处理后的消息再次发送至消息队列RocketMQ版的Topic。消息队列RocketMQ版将该消息转发至微消息队列MQTT版。微消息队列MQTT版将该消息推送至所有...

死信队列

死信队列用于处理无法被正常消费的消息,即死信消息。本文介绍如何查询、导出和重新发送进入死信队列的死信消息,以便您按需管理死信消息,避免消息处理。背景信息 当一条消息初次消费失败,消息队列RocketMQ版会自动进行消息重试,达到...

事务消息

本文介绍如何使用消息服务MNS的延时消息功能,实现本地操作和消息发送的事务一致性。前提条件 您已创建以下队列,具体操作,请参见创建队列。事务消息队列 消息存活时间小于消息延时时间。当消息发送成功、事务操作成功时,生产者修改消息...

日志管理概述

应用场景 您在收发消息的过程中,是否遇到过以下问题消息成功发送到队列,但消费端收不到消息,消息去哪儿了?消息被谁消费了、消费了几次?消费端宕机了,消费失败的消息什么时候可以再次被消费?消息发布到主题,Endpoint却迟迟收不到...

功能与特性概述

消息类型对比 消息类型 是否支持可靠同步发送 是否支持可靠异步发送 是否支持Oneway发送 是否支持多线程发送 性能 普通消息 是 是 是 是 最高 事务消息 定时和延时消息 全局顺序消息 是 否 否 否 高 分区顺序消息 一般 消息特性 消息重试:...
< 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 物联网无线连接服务 商标 轻量应用服务器 SSL证书 对象存储
这些文档可能帮助您
文字识别介绍 什么是消息队列Kafka版? Java SDK 同时部署WAF和CDN Java SDK概述 获取客户端真实IP

新品推荐

你可能感兴趣

热门推荐

新人福利专场 阿里云试用中心 企业支持计划 飞天会员助力企业低成本上云 智能财税30天免费试用 云解析DNS新用户首购低至36元/年起 ECS限时升级特惠6.5折