收发事务消息
长轮询表示如果Topic没有消息，则客户端请求会在服务端挂起3s，3s内如果有消息可以消费则立即返回响应。res=await consumer.consumeMessage(3,/一次最多消费3条（最多可设置为16条）。3/长轮询时间3秒（最多可设置为30秒）。if(res.code=...
JMS Pub/Sub（主账号与RAM账号）
前提条件 创建实例 创建Vhost 创建Exchange 创建Queue 创建绑定关系 背景信息 一条消息可以被多个订阅者消费。当某个发布者向某个Topic（消息主题）发布某条消息后，订阅了该Topic的所有订阅者都可以消费该条消息。发布者和订阅者之间存在...
消息过滤
消费者订阅了某个Topic后，云消息队列 RocketMQ 版 会将该Topic中的所有消息投递给消费端进行消费。若消费者只需要关注部分消息，可通过设置过滤条件...合理使用Topic和Tag来过滤消息可以让业务更清晰，更多信息，请参见 Topic与Tag最佳实践。
JMS Pub/Sub（RAM角色跨账号授权场景）
前提条件 创建实例 创建Vhost 创建Exchange 创建Queue 创建绑定关系 背景信息 一条消息可以被多个订阅者消费。当某个发布者向某个Topic（消息主题）发布某条消息后，订阅了该Topic的所有订阅者都可以消费该条消息。发布者和订阅者之间存在...
超大消息传输
当消息内容大于64 KB以至于无法直接存入MNS队列时，不做消息切片，使用 消息服务MNS 和 对象存储OSS 来传递大于64 KB的消息。背景信息 消息服务MNS 的队列的消息大小最大限制是64 KB，这个限制基本能够满足在正常情况下消息作为控制流信息...
顺序消息
顺序消息可以保证消息的消费顺序和发送的顺序一致，即先发送的先消费，后发送的后消费，常用于金融证券、电商业务等对消息指令顺序有严格要求的场景。本文介绍 云消息队列 RocketMQ 版 顺序消息的概念、适用场景、实现原理以及使用过程中的...
基本概念
消息标签（MessageTag）消息标签是 云消息队列 RocketMQ 版 提供的细粒度消息分类属性，可以在主题层级之下做消息类型的细分。消费者通过订阅特定的标签来实现细粒度过滤。更多信息，请参见 消息过滤。消息位点（MessageQueueOffset）消息...
现代IM系统中的消息系统—实现
会话的消息可以选择在客户端持久化，然后在感知到新消息之后更新本地消息，增加缓存减少网络IO。存储库的消息需要永久保存，是整个应用的全量消息存储。存储库的数据过期时间（TTL）需要设置为-1。核心代码 public List<AppMessage>...
顺序消息
在这类场景下使用 云消息队列 RocketMQ 版 的顺序消息可以有效保证数据传输的顺序性。典型场景一：撮合交易 以证券、股票交易撮合场景为例，对于出价相同的交易单，坚持按照先出价先交易的原则，下游处理订单的系统需要严格按照出价顺序来...
函数计算
函数计算能做什么？利用函数实现业务消息的处理，通过函数计算平台开发、运行业务消息处理逻辑，订单处理，任务执行。利用函数对消息进行快速加工处理，ETL清洗。利用函数计算灵活扩展将消息转储到指定VPC中的其它下游系统。利用函数链接...
函数计算
函数计算能做什么？利用函数实现业务消息的处理，通过函数计算平台开发、运行业务消息处理逻辑，订单处理，任务执行。利用函数对消息进行快速加工处理，ETL清洗。利用函数计算灵活扩展将消息转储到指定VPC中的其它下游系统。利用函数链接...
消费幂等
为了防止消息重复消费导致业务处理异常，消息队列RocketMQ版 的消费者在接收到消息后，有必要根据业务上的唯一Key对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况...
消息处理时长自适应
MessageTimeout是Message在Manager里面的超时时间，例如某个Worker卡住了，消息在5个小时之后依然没有处理完毕（假设5个小时远远超出消息的正常处理时间），那么Manager就不会再为消息做ChangeVisibility了，会放任消息的Visibility超时。...
QueueMessage
消息发送到队列中，MNS会生成一个MessageId，该编号一旦生成就不会变化，可以用来做数据校对。NextVisibleTime 消息下次可被消费的时间，从1970-01-01 00:00:00 000开始的毫秒数。（batch）receive message和change message visibility操作...
应用场景
本文为您介绍 云消息队列 RocketMQ 版 的应用场景，以便您更好地判断如何在业务中使用 云消息队列 RocketMQ 版。例如，针对一家互联网电商企业，其业务涉及广泛，如注册、订单、库存、物流等；同时，也会涉及许多业务峰值时刻，如秒杀活动...
收发事务消息
本文提供使用TCP协议下的C/C++ SDK收发事务消息的示例代码供您参考。云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图...
收发事务消息
comRollErr=(*mqTransProducer).Rollback(v.ReceiptHandle)fmt.Println("Rollback->")} else {/什么都不做，下次再检查。fmt.Println("Unknown->")} ProcessError(comRollErr)} endChan中没有消息可消费。if strings.Contains(err.(errors....
收发事务消息
当步骤1半事务消息发送完成，但本地事务返回状态为 TransactionStatus.Unknow 时，亦或是应用退出导致本地事务未提交任何状态时，从Broker的角度看，这条半状态的消息的状态是未知的，因此Broker会定期向消息发送方即消息生产者集群中的...
创建FC Sink Connector
函数计算能做什么？利用函数实现业务消息的处理，通过函数计算平台开发、运行业务消息处理逻辑，订单处理，任务执行。利用函数对消息进行快速加工处理，ETL清洗。利用函数计算灵活扩展将消息转储到指定VPC中的其他下游系统。利用函数连接...
消费者负载均衡
重要 消息粒度负载均衡策略保证同一个队列的消息可以被多个消费者共同处理，但是该策略使用的消息分配算法结果是随机的，并不能指定消息被哪一个特定的消费者处理。消息粒度的负载均衡机制，是基于内部的单条消息确认语义实现的。消费者...
收发事务消息
长轮询表示如果Topic没有消息,则请求会在服务端挂起3s，3s内如果有消息可以消费则立即返回客户端。List<Message>messages=null;try { messages=consumer.ConsumeMessage(3,/一次最多消费3条（最多可设置为16条）。3/长轮询时间3秒（最多可...
收发事务消息
Check被回调时，业务逻辑都需要做些什么？事务消息的Check方法里面，应该写一些检查事务一致性的逻辑。云消息队列 RocketMQ 版 发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求；因此...
收发事务消息
长轮询表示如果Topic没有消息,则请求会在服务端挂起3s，3s内如果有消息可以消费则立即返回客户端。messages=consumer.consumeMessage(3,/一次最多消费3条消息（最多可设置为16条）。3/长轮询时间3秒（最多可设置为30秒）。} catch...
收发事务消息
instance_id="${INSTANCE_ID}"consumer=mq_client.get_consumer(instance_id,topic_name,group_id)#长轮询表示如果Topic没有消息，则客户端请求会在服务端挂起3秒，3秒内如果有消息可以消费则立即返回响应。长轮询时间3秒（最多可设置为30...
资源包说明
云消息队列 RocketMQ 版 的标准版实例按照按量付费方式对API请求资源和Topic资源进行计费，针对这两个计费项，云消息队列 RocketMQ 版 分别推出API请求次数和Topic次数资源包，帮助您以更优惠的价格享受等量资源。使用的资源在资源包规格内...
Token客户端接口
本文介绍 云消息队列 MQTT 版 客户端在Token模式下如何上传Token、更新Token、监听Token失效信息和监听Token非法信息。Token模式MQTT客户端连接参数设置 MQTT支持三种模式的Token，每个客户端每个类型至多申请一个Token，根据实际需要可能...
Token客户端接口
本文介绍 云消息队列 MQTT 版 客户端在Token模式下如何上传Token、更新Token、监听Token失效信息以及监听Token非法信息。Token模式MQTT客户端连接参数设置 MQTT支持三种模式的Token，每个客户端每个类型至多申请一个Token，根据实际需要可...
普通消息
普通消息为 云消息队列 RocketMQ 版 中最基础的消息，区别于有特性的顺序消息、定时/延时消息和事务消息。本文为您介绍普通消息的应用场景、功能原理、使用方法和使用建议。应用场景 普通消息一般应用于微服务解耦、事件驱动、数据集成等...
什么是云消息队列 RocketMQ 版？
为什么选择云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 基于阿里云云原生优质的基础设施实现，兼容Apache RocketMQ的核心API和功能。相对于自建RocketMQ集群，云消息队列 RocketMQ 版 具有如下优势：架构先进性 全面采用存储和计算分离...
什么是云消息队列 Confluent 版？
HouseKeeping（健康巡检组件）：用于 云消息队列 Confluent 版 核心链路的运行时巡检，每分钟会对集群做一次全面扫描诊断，并能针对不健康的状态进行告警。同时，每天还会为阿里云运维人员出具整体巡检报告，方便监控 云消息队列 Confluent...
订阅者最佳实践
负载均衡 每个 Group 可以包含多个消费实例，即可以启动多个 云消息队列 Kafka 版 Consumer，并把参数 group.id 设置成相同的值。属于同一个 Group 的消费实例会负载消费订阅的Topic。例如 Group A订阅了Topic A，并开启三个消费实例C1、C2...
事务消息
功能原理 什么是事务消息 事务消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型，支持在分布式场景下保障消息生产和本地事务的最终一致性。事务消息处理流程 事务消息交互流程如下图所示。生产者将消息发送至 云消息队列 RocketMQ 版...
计费常见问题
本文汇总了 云消息队列 RocketMQ 版 计费的常见问题。每天扣除2元，这是什么费用？我昨天删除了Topic，为什么今天会收到账单并被扣费？我没有使用 云消息队列 RocketMQ 版 服务，为什么会扣费？我在控制台上看到没有开通 云消息队列 ...
基于Flink的资讯场景实时数仓
分析型数据库MySQL版 分析型数据库MySQL版（AnalyticDB for MySQL）是一种高并发低延时的PB级实时数据仓库，兼容MySQL协议以及SQL:2003语法标准，可以毫秒级针对万亿级数据进行即时的多维分析透视和业务探索。更多关于分析型数据库MySQL版...
常见问题
使用云消息队列 Kafka 版时客户端的报错及解决方案 无法ping通云消息队列 Kafka 版的接入点 客户端消费问题 订阅者最佳实践 客户端首次接入云消息队列 Kafka 版时出现异常的排查方法 使用云消息队列 Kafka 版时出现消息堆积 为什么消费客户...
云端SDK常见问题
终端SDK发送消息，可以使用终端SDK消费，也可以使用云端SDK消费。云端SDK发送消息后，为什么在控制台查询不到？暂不支持查询云端SDK发送的消息。云端SDK无法运行，返回连接超时错误。可能原因：检查实例接入点是否填写正确。云端SDK需要...
收发定时消息
背景信息 定时消息可以做到在指定时间戳之后才可被消费者消费，适用于对消息生产和消费有时间窗口要求，或者利用消息触发定时任务的场景。定时消息的概念介绍及使用过程中的注意事项，请参见 定时和延时消息。说明 对于新手用户，建议在...
鉴权常见问题
云端鉴权 为什么给Group配置拒绝发布权限，依然可以发布消息？自定义权限策略是否支持多级Topic？Token鉴权和一机一密鉴权如何选择？Token模式 如果业务上需要对每个MQTT客户端的权限进行细致划分，或者仅需要对客户端授予临时的有时间期限...
队列模型基本概念
当消息发送到 消息服务MNS 的队列，消息服务MNS 会生成一个Message ID，此ID一旦产生就不会改变，并在请求响应中返回，您主要可以使用此Message ID来做数据校对，但是删除消息必须使用ReceiptHandle。临时句柄（ReceiptHandle）由 消息服务...
产品简介
平台提供通讯录管理、即时通讯、音视频、消息触达、应用接入能力，支持专有云部署。助力解决三融五跨组织数字化协同、沟通和统一工作门户的问题。客户群体 金融行业：助力监管机构、银行、证券、保险行业企业构建专有的移动数字化协同体系...
- 产品推荐
- 这些文档可能帮助您