EDI许可证

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

媒体处理

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

自然语言处理

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

消费幂等

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

消息幂等

负载均衡时消息重复(包括但不限于网络抖动、服务端重启以及Consumer应用重启)当消息队列RabbitMQ版的服务端或客户端重启、扩容或缩容时,会触发Rebalance,此时Consumer可能会收到重复消息处理方法 以Message ID为幂等键对消息进行幂等...

消息堆积和延迟问题

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

消息处理时长自适应

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

消息幂等

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

顺序消息1.0

顺序消息可以保证消息的消费顺序和发送的顺序一致,即先发送的先消费,后发送的后消费,常用于金融证券、电商业务等对消息指令顺序有严格要求的场景。本文介绍消息队列RocketMQ版顺序消息1.0的概念、适用场景、实现原理以及使用过程中的...

顺序消息2.0

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

适用场景

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

如何处理消息堆积

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

事务消息

消息回查:由于网络闪断、生产者应用重启等原因,导致某条事务消息的二次确认丢失,消息队列RocketMQ版服务端通过扫描发现某条消息长期处于“半事务消息”时,需要主动向消息生产者询问该消息的最终状态(Commit或是Rollback),该询问过程...

Exactly-Once投递语义

本文主要介绍消息队列RocketMQ版的Exactly-Once投递语义的概念和典型使用场景,以便您理解如何使得消息只被消费端处理且仅处理一次。什么是Exactly-Once投递语义 Exactly-Once是指发送到消息系统的消息只能被消费端处理且仅处理一次,即使...

集群消费和广播消费

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

管理消息业务

本文为您介绍如何管理消息业务方。新建消息业务方 登录BizWorks,单击左侧导航栏下部的图标。在企业设置导航栏中,选择消息中心>消息业务方管理。在消息业务方管理页面,单击新建消息业务方。在新建消息业务方面板,填写消息业务方名称...

实例类型

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

实例规格

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

事务消息

消费者异常(例如进程重启)消息服务MNS提供至少保证消费一次的特性,如果当前消费者没有成功消费并删除消息消息在不可见时间后将继续可见,被当前消费者或者其他消费者处理。消息服务MNS服务不可达(例如断网)消息发送和接收处理状态及...

查询消息轨迹

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

应用场景

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

Topic与Tag最佳实践

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

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

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

消息重试

本文介绍消息队列RabbitMQ版服务端默认的消息重试机制,帮助您理解消费失败后的消息处理逻辑,并选择合适的消息处理策略。重试机制 消息队列RabbitMQ版服务端有默认的消息重试机制,不支持您在Consumer客户端重新配置消息重试机制和关闭...

功能与特性概述

消息类型列表 普通消息 消息队列RocketMQ版中无特性的消息,区别于有特性的定时和延时消息、顺序消息和事务消息。定时和延时消息 允许消息生产者对指定消息进行定时(延时)投递,最长支持40天。顺序消息 允许消息消费者按照消息发送的顺序...

订阅者最佳实践

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

应用场景

通过消息队列Kafka版的发布/订阅模型,您可以实时收集网站活动数据(例如注册、登录、充值、支付、购买),根据业务数据类型将消息发布到不同的Topic,然后利用订阅消息的实时投递,将消息流用于实时处理、实时监控或者加载到Hadoop、...

名词解释

Message Key 消息业务标识,由消息生产者(Producer)设置,唯一标识某个业务逻辑。Tag 消息标签,二级消息类型,用来进一步区分某个Topic下的消息分类。更多信息,请参见Topic与Tag最佳实践。Producer 消息生产者,也称为消息发布者,...

收发事务消息

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

收发事务消息

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

直播互动解决方案

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

直播互动解决方案

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

实例数据统计

您可使用消息队列RocketMQ版提供的实例数据统计功能,一站式、全方位、多维度地统计和观测实例的消息收发数据,以便您快速了解业务运行状态。此外,还可根据异常数据定位问题、降低运维成本和提高维护效率。本文介绍实例数据统计的核心功能...

名词解释

消息变成死信消息的可能原因如下:requeue参数被设置为 false,消费者使用basic.reject或basic.nack否定应答(NACK)消息消息重试次数超过16次,消息重试失败。详情请参见消息重试。注意 过期消息或超过队列最大长度被丢弃的消息不会成为...

应用场景

本文为您介绍 SOFAStack 消息队列的适用场景,以便您更好地判断如何在业务中使用消息队列。在互联网金融场景里,其业务涉及广泛,如支付交易、收费计息、商户结算、业务营销、会员积分、风险核查等;同时,也会涉及许多业务峰值时刻,如双 ...

MQTT与RocketMQ的应用场景对比

消息队列RocketMQ版 面向服务端的消息引擎,主要用于服务组件之间的解耦、异步通知、削峰填谷等,服务器规模较小(极少企业服务器规模过万),但需要大量的消息处理,吞吐量要求高。因此,消息队列RocketMQ版适用于服务端进行大批量的数据...

日志管理概述

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

包年包月(预付费)

确保连接数上限大于等于业务实际在线连接数,以免业务在连接峰值脉冲时触发微消息队列MQTT版服务限流,导致部分客户端无法连接。instance_a在10:00的同时在线连接数是1000个,10:01的同时在线连接数是2000个,则instance_a需要超过2000个...

应用场景

事务型业务流程编排 复杂的业务场景如电商网站、酒店、机票预定等应用通常要访问多个远程服务,并且对操作事务性语义(即所有步骤全部成功或全部失败,不存在中间状态)有较高要求。在流量较小、数据存储集中的应用中,事务性可以通过关系...

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

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

新品推荐

你可能感兴趣

热门推荐

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