消息队列 MQ
MQ 产品生态丰富,多个子产品线联合打造金融级高可用消息服务以及对物联网的原生支持,覆盖金融保险、(新)零售、物联网、移动互联网、传媒泛娱乐、教育、物流、能源、交通等行业。

适用场景

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

Exactly-Once投递语义

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

消息服务MNS

阿里云消息服务MNS(MessageService)是一种高效、可靠、安全、便捷、可弹性扩展的分布式消息服务。MNS能够帮助应用开发者在他们应用的分布式组件上自由的传递数据、通知消息,构建松耦合系统

阿里云试用中心,为您提供0门槛上云实践机会!

100+款试用云产品,最长免费试用12个月!拨打95187-1,咨询专业上云建议!
广告

常见问题

您在使用消息服务产品时,如果收到系统提示的错误信息,可查阅错误代码汇总匹配错误信息。对于其他问题,您可根据下列分类匹配问题场景和解决方案。说明:本页面列举的文档较多,您可以通过搜索框搜索相关文档或者在本页面按 Ctrl+F搜索...

消息服务MNS中删除消息时报“message not exist”的...

问题描述消息服务MNS中删除消息时报如下...如果VisibilityTimeout设置得太大,当消息处理失败时,将不能在短时间内再次处理该条消息。适用于消息服务MNS如果您的问题仍未解决,您可以在阿里云社区免费咨询,或提交工单联系阿里云技术支持。

应用场景

您可以实时收集网站活动数据(例如注册、登录、充值、支付、购买),根据业务数据类型将消息发布到不同的Topic,然后利用订阅消息的实时投递,将消息流用于实时处理、实时监控或者加载到Hadoop、MaxCompute等离线数据仓库系统进行离线处理...

消息堆积和延迟问题

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

消息处理时长自适应

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

消息队列RabbitMQ版

消息队列RabbitMQ版是阿里云消息队列(MQ)团队基于AMQP0-9-1协议研发的分布式、高吞吐、低延迟、高可扩展的云消息队列服务。消息队列RabbitMQ版完全兼容开源RabbitMQ社区、开箱即、无需部署、免运维,帮助您快速上云。

消息队列RocketMQ版

消息队列RocketMQ版(原名开放消息服务,简称ONS)是阿里云基于ApacheRocketMQ构建的低延迟、高并发、高可用、高可靠的分布式消息中间件。

媒体处理

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

消息队列Kafka版

消息队列Kafka版(MQforApacheKafka)秉持开放的原则拥抱开源,全面融合Kafka开源生态,做到无缝迁移,打造更安全、更可靠、更易运维的Kafka企业级消息服务。

自然语言处理

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

MQTT与RocketMQ的应用场景对比

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

消费幂等

处理方法因为不同的MessageID对应的消息内容可能相同,有可能出现冲突(重复)的情况,所以真正安全的幂等处理,不建议以MessageID作为处理依据。最好的方式是以业务唯一标识作为幂等处理的关键依据,而业务的唯一标识可以通过消息Key设置...

应用场景

本文为您介绍消息队列RabbitMQ版的应用场景,以便您更好地判断如何在业务中使用消息队列RabbitMQ版。异步解耦消息队列RabbitMQ版可用于单体应用被拆解为微服务后不同微服务间的通信。应用解耦的好处是不同应用的迭代不再相互依赖,而异步...

MQTT与RocketMQ的应用场景对比

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

事务消息

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

集群消费和广播消费

集群消费:当使用集群消费模式时,消息队列RocketMQ版认为任意一条消息只需要被集群内的任意一个消费者处理即可。广播消费:当使用广播消费模式时,消息队列RocketMQ版会将每条消息推送给集群内所有注册过的消费者,保证消息至少被每个消费...

消息重试

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

消息队列MQTT版

消息队列MQTT版广泛应用移动互联网以及物联网领域,覆盖互动直播、车联网、金融支付、智能餐饮、即时聊天、移动App等多种应用场景。

消息幂等

处理方法以MessageID为幂等键对消息进行幂等处理的步骤如下:在数据库中创建一张uniquekey索引为唯一MessageID的表。在Producer客户端为每条消息设置唯一MessageID。设置唯一MessageID的示例代码如下:AMQP.BasicPropertiesprops=newAMQP....

消费端挂载NFS云盘是否会影响消费端处理速度?

如果您需要把最终的处理结果集中到同一个NFS上保存,仍然可以通过一个异步的工具或者线程,把云盘上的结果再转发到NFS上,而不要让同步存储NFS阻塞消息处理。总之,对于资源访问造成的处理低效,总是可以异步处理的方式解决。

终端访问控制系统

终端访问控制系统UEM(UnifiedEndpointManagement)是基于阿里巴巴数字办公最佳实践输出的办公终端管理系统,通过对移动端和PC端办公设备(Windows、macOS、Android、iOS)的统一管理,为企业员工提供随时、随地、高效、安全的办公体验。

批量消费

批量消息处理。returnAction.CommitMessage;}});启动batchConsumer。batchConsumer.start();System.out.println("Consumerstartsuccess.");等待固定时间防止进程退出。try{Thread.sleep(200000);}catch(InterruptedExceptione){e....

消息负载均衡策略

如果其中一台机器处理变慢,可能是机器硬件、系统、远程RPC调用或JavaGC等原因导致分配至此机器上的Queue的消息不能及时处理;此外,消息队列RocketMQ版的消息负载是按Queue为粒度维护,所以,整个Queue上的消息都会堆积。

短信告警提示离线消息存储数量超过系统限制

问题描述在使用消息队列MQTT版时,短信告警提示离线消息存储数量超过系统限制。问题原因微消息队列MQTT版对于每个实例中存储的离线消息数量是有限制的。具体的限制值,请参见使用限制中的相关说明。如果客户端订阅关系设置不当,产生大量...
来自: 首页

使用消息队列Kafka版时出现消息堆积

概述使用消息队列Kafka版时,可能会发现ConsumerGroup中出现消息堆积。该情况是否属于正常情况,以及如何处理,请参见以下内容。详细信息客户端消费流程了解客户端消费流程,有助于理解消息是否堆积。一般情况下,客户端消费流程大致如下:...
来自: 首页

如何处理JAVA进程的消息堆积

问题描述在消息队列RocketMQ版控制台的消费者状态页面,GroupID的实时消息堆积量的值高于预期,且性能明显下降。问题原因由于JAVA进程的消息堆积过多,导致GroupID的实时消息堆积量的值高于预期。解决方法若JAVA进程消息堆积,且性能有下降...

其它问题

如果您需要把最终的处理结果集中到同一个NFS上保存,仍然可以通过一个异步的工具或者线程,把云盘上的结果再转发到NFS上,而不要让同步存储NFS阻塞消息处理。总之,对于资源访问造成的处理低效,总是可以异步处理的方式解决。为什么Topic...

AHAS为消息队列Apache RocketMQ版消费端削峰填谷

AHAS应用防护功能与消息队列RocketMQ组合,可以让MQ消费端负载保持在消息处理水位之下,同时尽可能处理更多消息,达到削峰填谷的效果。本文以AHAS应用防护的匀速处理请求的能力为例,说明如何对RocketMQ消费端进行限流。背景信息在消息队列...

应用场景

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

直播互动解决方案

本文以单直播间、一名老师、两名学生的场景为例,说明如何使用消息队列MQTT版实现直播互动消息、禁言、成员上下线通知以及系统消息通知,其中,老师和学生的客户端以HTML网页为例,后端应用以Java为例。背景信息使用消息队列MQTT版需与...

新零售电子价签解决方案(MQTT)

电子价签管控服务通过接收消息队列RocketMQ版消息处理分析当前系统中在线的价签节点的状态,并将数据记录到SLS。更新屏显电子价签管控服务发送改价的消息队列RocketMQ版消息,触发改价操作。MQTT服务端会路由该消息队列RocketMQ版消息,...

新零售电子价签解决方案(MQTT)

电子价签管控服务通过接收消息队列RocketMQ版消息处理分析当前系统中在线的价签节点的状态,并将数据记录到SLS。更新屏显电子价签管控服务发送改价的消息队列RocketMQ版消息,触发改价操作。MQTT服务端会路由该消息队列RocketMQ版消息,...

什么是消息队列RocketMQ版?

顺序收发细数日常中需要保证顺序的应用场景非常多,例如证券交易过程时间优先原则,交易系统中的订单创建、支付、退款等流程,航班中的旅客登机消息处理等等。与先进先出FIFO(FirstInFirstOut)原理类似,消息队列RocketMQ版提供的顺序...

常见问题

客户端发送问题使用客户端发送消息后,如何确定是否发送成功?Java客户端设置回调是否会影响消息发送的速度?生产者会建立多少个到Broker的连接?如何进行发送消息的测试?为什么PHP发送延时比较长?实例问题实例支持哪些开源版本?如何...

函数计算实现弹性音视频处理系统

使用函数计算搭建音视频处理应用,快速构建高可用高弹性音视频处理系统。直达最佳实践点击查看最佳实践详情更多最佳实践点击查看更多阿里云最佳实践场景描述本示例通过函数计算部署一个高弹性高可用的音视频处理系统。尤其适合视频网站使用...

实时计算Flink版

阿里云实时计算Flink版(AlibabaCloudRealtimeComputeforApacheFlink,PoweredbyVerverica)是阿里云基于ApacheFlink构建的企业级、高性能实时大数据处理系统

直播互动解决方案

本文以单直播间、一名老师、两名学生的场景为例,说明如何使用消息队列MQTT版实现直播互动消息、禁言、成员上下线通知以及系统消息通知,其中,老师和学生的客户端以HTML网页为例,后端应用以Java为例。背景信息在直播互动的场景下,您需...
< 1 2 3 4 ... 200 >
共有200页 跳转至: GO
产品推荐
消息队列MQ 消息服务 云服务器 商标 物联网无线连接服务 SSL证书 短信服务
这些文档可能帮助您
获取视频上传地址和凭证 消息服务MNS-Endpoint 快速入门概述 使用阿里云播放器 主题使用手册 什么是视图计算

新品推荐

你可能感兴趣

热门推荐

切换为移动版

新人福利专场 阿里云试用中心 企业支持计划 飞天会员助力企业低成本上云 智能财税30天免费试用 云解析DNS新用户首购低至36元/年起 ECS限时升级特惠6.5折
消息队列 MQ
MQ 产品生态丰富,多个子产品线联合打造金融级高可用消息服务以及对物联网的原生支持,覆盖金融保险、(新)零售、物联网、移动互联网、传媒泛娱乐、教育、物流、能源、交通等行业。