收发事务消息
} else {/什么都不做，下次再检查。Console.WriteLine("Id:"+message.Id+",unkonwn");} } catch(Exception ackError){ ProcessAckError(ackError);} } } catch(Exception ex){ Console.WriteLine(ex);Thread.Sleep(2000);} } } static void...
收发事务消息
self.trans_producer.rollback(half_msg.receipt_handle)self.count+1 print("->rollback")else:#什么都不做，下次再检查。print("->unknown")except MQExceptionBase as rec_commit_roll_e:process_trans_error(rec_commit_roll_e)except ...
收发事务消息
} else {/什么都不做，下次再检查。System.out.println(String.format("MessageId:%s,unknown",message.getMessageId()));} } catch(Throwable e){/如果提交或回滚消息时超过了TransCheckImmunityTime（针对发送事务消息的句柄）或者超过10...
MQTT与RocketMQ的消息结构映射
云消息队列 MQTT 版 的详细介绍，请参见 什么是微消息队列MQTT版 和 名词解释。消息结构映射 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 都是基于发布/订阅（Pub/Sub）模型的消息系统，两者概念上存在很多相似之处，下图列举了关键概念...
开源SDK接入（跨云账号授权）
企业A希望可以授权企业B来操作部分业务，例如：云消息队列 RabbitMQ 版 的运维、监控以及管理等。企业A希望当企业B的员工加入或离职时，无需做任何权限变更。企业B可以进一步将企业A的资源访问权限分配给企业B的RAM用户（员工或应用），并...
直播互动解决方案
同一直播间的客户端发送和订阅消息的Topic需分开创建和使用，以免 云消息队列 RocketMQ 版 形成消费死循环。具体示例如下。场景一：直播互动消息 例如，一个在线教育直播间中有三名成员，一名老师和两名学生。学生A在直播间发文字消息，...
什么是云消息队列 Confluent 版？
HouseKeeping（健康巡检组件）：用于 云消息队列 Confluent 版 核心链路的运行时巡检，每分钟会对集群做一次全面扫描诊断，并能针对不健康的状态进行告警。同时，每天还会为阿里云运维人员出具整体巡检报告，方便监控 云消息队列 Confluent...
什么是云消息队列 RocketMQ 版？
为什么选择云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 基于阿里云云原生优质的基础设施实现，兼容Apache RocketMQ的核心API和功能。相对于自建RocketMQ集群，云消息队列 RocketMQ 版 具有如下优势：架构先进性 全面采用存储和计算分离...
死信消息
SendDLQMessageCountPerGidTopic 指标应用 云消息队列 RocketMQ 版 支持配置死信消息相关告警，可以帮助您在业务反馈前及时发现异常，并结合Dashboard指标结果可以进一步排查异常来源。场景一：查看每分钟转成死信状态的消息量 您可以在 ...
发送普通消息（三种方式）
TagA",/Message Body可以是任何二进制形式的数据，消息队列RocketMQ版不做任何干预。需要Producer与Consumer协商好一致的序列化和反序列化方式。Hello MQ".getBytes());设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法...
消息堆积和延迟问题
消费逻辑中的复杂耗时的操作是否可以做异步化处理，如果可以是否会造成逻辑错乱（消费完成但异步操作未完成）。设置消息的消费并发度 逐步调大线程的单个节点的线程数，并观测节点的系统指标，得到单个节点最优的消费线程数和消息吞吐量。...
创建FC Sink Connector
函数计算能做什么？利用函数实现业务消息的处理，通过函数计算平台开发、运行业务消息处理逻辑，订单处理，任务执行。利用函数对消息进行快速加工处理，ETL清洗。利用函数计算灵活扩展将消息转储到指定VPC中的其他下游系统。利用函数连接...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图所示。更多信息，请参见 事务消息。前提条件 您已完成以下操作：下载C...
消费者负载均衡
使用建议 针对消费逻辑做消息幂等 无论是消息粒度负载均衡策略还是队列粒度负载均衡策略，在消费者上线或下线、服务端扩缩容等场景下，都会触发短暂的重新负载均衡动作。此时可能会存在短暂的负载不一致情况，出现少量消息重复的现象。因此...
示例代码
云消息队列 RocketMQ 版 5.x版本实例可兼容Java ONS 1.x SDK客户端接入，您可以使用ONS 1.x SDK的接入5.x实例进行消息收发。本文为您介绍Java ONS 1.x SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力...
普通消息
每条消息都是一段日志数据，云消息队列 RocketMQ 版 不做任何处理，只需要将日志数据可靠投递到下游的存储系统和分析系统即可，后续功能由后端应用完成。功能原理 什么是普通消息 定义：普通消息是 云消息队列 RocketMQ 版 基本消息功能，...
顺序消息
功能原理 什么是顺序消息 顺序消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型，支持消费者按照发送消息的先后顺序获取消息，从而实现业务场景中的顺序处理。相比其他类型消息，顺序消息在发送、存储和投递的处理过程中，更多强调多...
发布者最佳实践
在消息没有指定Key的情况下，云消息队列 Kafka 版 2.4版本之前的默认策略是循环使用主题的所有分区，将消息以轮询的方式发送到每一个分区上。但是，这种默认策略Batch的效果会比较差，在实际使用中，可能会产生大量的小Batch，从而使得实际...
顺序消息
顺序消息可以保证消息的消费顺序和发送的顺序一致，即先发送的先消费，后发送的后消费，常用于金融证券、电商业务等对消息指令顺序有严格要求的场景。本文介绍 云消息队列 RocketMQ 版 顺序消息的概念、适用场景、实现原理以及使用过程中的...
收发事务消息
Check被回调时，业务逻辑都需要做些什么？事务消息的Check方法里面，应该写一些检查事务一致性的逻辑。云消息队列 RocketMQ 版 发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求；因此...
收发事务消息
Check被回调时，业务逻辑都需要做些什么？事务消息的Check方法里面，应该写一些检查事务一致性的逻辑。云消息队列 RocketMQ 版 发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求；因此...
订阅者最佳实践
负载均衡 每个 Group 可以包含多个消费实例，即可以启动多个 云消息队列 Kafka 版 Consumer，并把参数 group.id 设置成相同的值。属于同一个 Group 的消费实例会负载消费订阅的Topic。例如 Group A订阅了Topic A，并开启三个消费实例C1、C2...
消费幂等
为了防止消息重复消费导致业务处理异常，消息队列RocketMQ版 的消费者在接收到消息后，有必要根据业务上的唯一Key对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况...
收发事务消息
comRollErr=(*mqTransProducer).Rollback(v.ReceiptHandle)fmt.Println("Rollback->")} else {/什么都不做，下次再检查。fmt.Println("Unknown->")} ProcessError(comRollErr)} endChan中没有消息可消费。if strings.Contains(err.(errors....
事务消息
功能原理 什么是事务消息 事务消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型，支持在分布式场景下保障消息生产和本地事务的最终一致性。事务消息处理流程 事务消息交互流程如下图所示。生产者将消息发送至 云消息队列 RocketMQ 版...
产品概述
本文介绍 云消息队列 Kafka 版 的产品动态、产品简介及产品计费。云消息队列 Kafka 版 动态与公告 产品简介 产品计费 云消息队列 Confluent 版 什么是云消息队列 Confluent 版？产品计费
收发延时消息
tag",/Message Body可以是任何二进制形式的数据，消息队列RocketMQ版不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式。Hello MQ".getBytes());设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常...
发送消息（多线程）
TagA",/Message Body可以是任何二进制形式的数据，消息队列RocketMQ版不做任何干预。需要Producer与Consumer协商好一致的序列化和反序列化方式。Hello MQ".getBytes());SendResult sendResult=producer.send(msg);同步发送消息，只要不抛...
收发定时消息
tag",/Message Body可以是任何二进制形式的数据，消息队列RocketMQ版不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式。Hello MQ".getBytes());设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常...
收发顺序消息
TagA",/Message Body，可以是任何二进制形式的数据，消息队列RocketMQ版不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式。send order global msg".getBytes());设置代表消息的业务关键属性，请尽可能全局唯一。以...
怎样让Consumer不立即消费消息并使消息重入队列？
您可以通过basicReject或basicNack方法否定应答消息，使消息重入队列，从而是其他Consumer可以消费消息。使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。...
怎样让Consumer不立即消费消息并使消息重入队列？
您可以通过basicReject或basicNack方法否定应答消息，使消息重入队列，从而是其他Consumer可以消费消息。使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。...
基本概念
消息标签（MessageTag）消息标签是 云消息队列 RocketMQ 版 提供的细粒度消息分类属性，可以在主题层级之下做消息类型的细分。消费者通过订阅特定的标签来实现细粒度过滤。更多信息，请参见 消息过滤。消息位点（MessageQueueOffset）消息...
队列（MessageQueue）
常见队列增加场景 需要增加队列实现物理节点负载均衡 云消息队列 RocketMQ 版 每个主题的多个队列可以分布在不同的服务节点上，在集群水平扩容增加节点后，为了保证集群流量的负载均衡，建议在新的服务节点上新增队列，或将旧的队列迁移到...
排他队列
如果您想创建一个只有自己可见的队列，不允许其他用户访问，您可以使用 云消息队列 RabbitMQ 版 的排他性队列特性，将指定的队列声明为排他性。什么是排他队列 排他性队列的特点如下：排他队列只对首次声明它的连接（Connection）可见，...
MQTT快速入门
云消息队列 MQTT 版 实例和存储实例之间会建立一一绑定关系，因此，创建的Topic其实是创建到存储实例上，在 云消息队列 MQTT 版 控制台仅仅做一层映射关系，所有的Topic操作都可以同时使用存储实例的操作习惯完成。如果之前在使用 云消息...
MQTT和RocketMQ进行数据互通（跨产品数据流入）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
MQTT和RocketMQ进行数据互通（跨产品数据流出）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
计费FAQ
本文汇总了 云消息队列 RabbitMQ 版 计费的常见问题。向10个Queue发送同一条消息，为什么收10次API调用费？将1条消息发送给10个Queue，实际上是10次API调用。为什么删除的Vhost、Exchange、Queue会被自动重建并重新开始计费？虽然删除了...
计费FAQ
本文汇总了 云消息队列 RabbitMQ 版 计费的常见问题。向10个Queue发送同一条消息，为什么收10次API调用费？将1条消息发送给10个Queue，实际上是10次API调用。为什么删除的Vhost、Exchange、Queue会被自动重建并重新开始计费？虽然删除了...
- 产品推荐
- 这些文档可能帮助您