消费幂等

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

消息幂等

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

云数据库 RDS

阿里云(Gartner全球数据库魔力象限领导者)提供稳定可靠、可弹性伸缩的关系云数据库RDS,支持MySQL、SQL Server、PostgreSQL、MariaDB和PPAS引擎,具备容灾、备份、恢复、迁移等方面的全套解决方案。

消息堆积和延迟问题

通过了解消息队列RocketMQ版客户端的消费原理和消息堆积的主要原因,帮助您可以在业务部署前更好的规划资源和配置,或在运维过程中及时调整业务逻辑,避免因消息堆积和延迟影响业务运行。背景信息 消息处理流程中,如果客户端的消费速度跟...

顺序消息1.0

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

顺序消息2.0

消息消费即使同一逻辑分区的消息被存储在不同的物理分区中且没有保持消息的顺序,但是基于顺序消息2.0的保序协议,消息队列RocketMQ版服务端在投递消息时,最终还是会按照消息在逻辑队列中存储的顺序投递给Consumer,Consumer消费消息时,...

Topic与Tag最佳实践

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

消息业务方管理

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

如何处理消息堆积

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

实例类型

适用于业务规模与整体消息量大,消息可靠性要求不高且业务连续性不受单条消息发送失败而影响的场景。主要使用消息的发布/订阅能力。消息非持久化,无规则绑定。业务规模变化。消息收发量、连接数、订阅关系数变化。能够存储消息数据。服务...

事务消息

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

事务消息

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

收发事务消息

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

步骤二:迁移评估

进行元数据迁移操作前,...消息存储空间 消息生产总量/天:100万条(普通消息消息消费总量/天:100万条(普通消息消息生产TPS:2000条/秒 消息消费TPS:2000条/秒 平均消息大小:4 KB 消息持续峰值:250分钟 后续步骤 步骤三:迁移元数据

步骤四:迁移消息服务

本文介绍如何消息收发服务从开源RocketMQ迁移到阿里云的消息队列RocketMQ版上,实现业务上云的平滑迁移。背景信息 迁移消息服务指的是在元数据迁移完成后,通过手动修改生产者集群和消费者集群的接入信息,将生产者集群和消费者集群从...

适用场景

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

实例数据统计

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

包年包月(预付费)

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

设置实例参数

说明 如果修改的参数需要重启实例才生效,系统会提示您是否重启,建议您在业务低峰期操作,并确保应用程序具有重连机制。参数的修改未提交时,如果想取消修改,请单击撤销。修改单个参数 在可修改参数页签内找到需要修改的参数,单击运行...

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

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

实例规格

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

计费概述

本文介绍消息队列Kafka版的计费项目和计费模式,帮助您快速了解计费详情,按需选择计费方式。注意 消息队列Kafka版的Connector组件处于公测阶段,且独立于消息队列Kafka版实例,因此不会在消息队列Kafka版侧产生费用。同时,阿里云不承诺...

收发事务消息

在发送消息前,必须调用start方法来启动Producer,只需调用一次即可,启动之后可以多线程并发发送消息。pProducer.start();Message msg=new Message(/Message Topic factoryInfo.getPublishTopics(),/Message Tag"TagA",/Message Body ...

发送普通消息(三种方式)

消息队列RocketMQ版提供三种方式来发送普通消息:同步(Sync)发送、异步(Async)发送和单向(Oneway)发送。本文介绍了每种发送方式的原理、应用场景、示例代码,以及三种发送方式的对比。前提条件 通过Java SDK发送普通消息前,您已完成...

产品优势

死信Exchange 增强死信Exchange,不仅支持被否定应答的消息,还支持重试失败的消息自动进入死信Exchange,确保消息不丢失。超强性能 平台性能上限 支持百万级队列,横向扩容带来性能的线性增长,性能上无并发限制。单队列扩容 解决...

使用限制

消息队列RocketMQ版对某些具体指标进行了约束和规范,您在使用消息队列RocketMQ版时注意不要超过相应的限制值,以免程序出现异常。具体的限制项和限制值请参见下表。限制项 限制值 说明 单个地域(Region)内的消息队列RocketMQ版实例数 ...

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

业务方设计用于消息收发的Topic时,需要遵循以下原则:上行消息(终端App发给管控服务的消息)和下行消息(管控服务发给终端App的消息)使用不同的父级Topic。不同优先级或者消息量级差别比较大的消息使用不同的父级Topic。对于上文描述的...

收发事务消息

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

升级实例配置

本文介绍如何消息队列Kafka版控制台完成实例升配,升级的配置项包括规格类型、流量规格、磁盘容量及Topic规格等。应用场景 消息队列Kafka版实例的磁盘使用率偏高,即将影响正常业务进行。消息队列Kafka版实例的流量规格持续超过已购买的...

实例规格

本文说明消息队列Kafka版支持的规格类型,以便您根据实际业务需求选择合适的实例规格。规格类型 消息队列Kafka版的规格类型如下:项目 标准版(高写版)专业版(高写版)专业版(高读版)版本 支持部署0.10.x版本~2.x版本。如需升级实例为...

查询消息轨迹

消息轨迹是指一条消息从生产者发送到消息队列RocketMQ版服务端,再到消费者消费处理,整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息。该轨迹可作为生产环境中排查问题强有力的数据支持。本文介绍消息轨迹的使用场景、...

Exactly-Once投递语义

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

消息查询

注意 若按Topic查询消息,请注意以下几点:按Topic查询属于范围查询,获取Topic下符合时间条件的所有消息消息量大,建议尽量缩短查询区间。按Topic查询数据量大,采用分页展示。查询结果说明 您可以在控制台的消息查询页面看到查询到的...

使用异常

业务代码在接收到消息后,不立即打印消息收到消息后,如果直接进入业务逻辑,一旦代码遗漏某个逻辑分支,就会导致消息信息没有被留在业务日志里,造成没有收到消息的假象。建议您收到消息后,立即打印消息信息留存 messageId,timestamp,...

MQTT与RocketMQ的消息结构映射

消息队列RocketMQ版和微消息队列MQTT版的消息负载(Payload)均是您的业务消息的数据序列化结果,消息队列RocketMQ版和微消息队列MQTT版不会对业务消息再做进一步的编解码处理。属性字段映射 目前,微消息队列MQTT版和消息队列RocketMQ版...

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

业务方设计用于消息收发的Topic时,需要遵循以下原则:上行消息(终端App发给管控服务的消息)和下行消息(管控服务发给终端App的消息)使用不同的父级Topic。不同优先级或者消息量级差别比较大的消息使用不同的父级Topic。对于上文描述的...

名词解释

死信消息 被重新发送到死信Exchange的消息消息变成死信消息的可能原因如下:requeue参数被设置为 false,消费者使用basic.reject或basic.nack否定应答(NACK)消息消息重试次数超过16次,消息重试失败。详情请参见消息重试。注意 过期...

名词解释

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

开源RocketMQ迁移上云概述

丰富的消息类型:提供丰富的消息类型,满足各种严苛场景下的高级特性需求,当前支持的消息类型涵盖普通消息、顺序消息(全局顺序和分区顺序)、分布式事务消息、定时消息、延时消息。完善的运维体系:消息队列RocketMQ版支持消息查询、全...

MQTT与RocketMQ的消息结构映射

消息队列RocketMQ版和微消息队列MQTT版的消息负载(Payload)均是您的业务消息的数据序列化结果,消息队列RocketMQ版和微消息队列MQTT版不会对业务消息再做进一步的编解码处理。属性字段映射 目前,微消息队列MQTT版和消息队列RocketMQ版...
< 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 轻量应用服务器 块存储 SSL证书 商标 对象存储 短信服务
这些文档可能帮助您
什么是云数据库Redis版 通过redis-cli连接Redis 什么是云服务器ECS Redis命令支持概览 同时部署WAF和CDN 什么是Web应用防火墙

新品推荐

你可能感兴趣

热门推荐

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