消费进度管理

消费进度原理 消息位点(Offset)参考 云消息队列 RocketMQ 版 主题 队列 定义,消息是按到达服务端的先后顺序存储在指定主题的多个队列中,每条消息在队列中都有一个唯一的Long类型坐标,这个坐标被定义为消息位点。任意一个消息队列...

功能与特性概述

云消息队列 RocketMQ 版 的分布式特点和瞬变的网络条件,或者用户应用重启发布的情况下,可能导致消费者收到重复的消息。开发人员应将其应用程序设计为多次处理一条消息不会产生任何错误或不一致性。消息幂等最佳实践请参见 消费幂等。消息...

顺序消息

基于 云消息队列 RocketMQ 版 本身队列的属性,消费顺序和队列存储的顺序一致,但不保证和发送顺序一致。未设置消息组,消息乱序发送。并发消费 并发消费,尽可能按照时间顺序处理。顺序消息生命周期 初始化 消息被生产者构建并完成初始化...

队列(MessageQueue)

云消息队列 RocketMQ 版 的所有主题都是由多个队列组成,以此实现队列数量的水平拆分和队列内部的流式存储。队列的主要作用如下:存储顺序性 队列天然具备顺序性,即消息按照进入队列的顺序写入存储,同一队列间的消息天然存在顺序关系,...

生产者负载均衡

生产者发送消息到 云消息队列 RocketMQ 版 服务端时,云消息队列 RocketMQ 版 将根据生产者负载均衡策略将消息均匀的存储在多个队列中,避免产生热点队列和性能瓶颈。本文介绍 云消息队列 RocketMQ 版 生产者的负载均衡策略。背景信息 了解...

开源RabbitMQ迁移上云

创建Shovel任务,将Source配置为开源RabbitMQ集群的服务地址和队列名称,Destination配置为 云消息队列 RabbitMQ 版 的EndPoint和队列名称。EndPoint的查看方式,请参见 查看实例详情 修改开源RabbitMQ队列消费者的接入点、用户名、密码,...

消息存储清理机制

这种机制可以带来顺序读写、高吞吐、高性能等优势,但缺点是不支持按主题和队列单独管理。安全生产和容量保障风险要求:即使 云消息队列 RocketMQ 版 按照主题或者队列独立生成存储文件,但存储层本质还是共享存储介质。单独根据主题或队列...

基本概念

云消息队列 RocketMQ 版 的所有主题都是由多个队列组成,以此实现队列数量的水平拆分和队列内部的流式存储。队列通过QueueId来做唯一标识和区分。更多信息,请参见 队列(MessageQueue)。消息(Message)消息是 云消息队列 RocketMQ 版 中...

应用场景

异步解耦是 云消息队列 RocketMQ 版 的主要特点,主要目的是减少请求响应时间解耦。主要的适用场景就是将比较耗时而且不需要即时(同步)返回结果的操作作为消息放入消息队列。同时,由于使用了 云消息队列 RocketMQ 版,只要保证消息...

云存储网关利用MQTT服务实现统一管控

通过 云消息队列 MQTT 版 所提供的服务,可采用统一的框架,即云控制台,来管理不同部署模式的云存储网关CSG(Cloud Storage Gateway),并实现安全合规的公网私网穿透,以此提供一致的用户体验。名词解释 MQTT 一种物联网移动互联网...

消费者负载均衡

消息粒度负载均衡策略无需关注消费者和队列的相对数量,能够更均匀地分摊消息。对非对等消费者更友好 对于线上生产环境,由于网络机房分区延迟、消费者物理资源规格不一致等原因,消费者的处理能力可能会不一致,如果按照队列分配消息,则...

排他队列

什么是排他队列 排他性队列的特点如下:排他队列只对首次声明它的连接(Connection)可见,包括该连接下所有建立的Channel。其他连接无法声明相同名称的排他队列,且其他连接以及连接下的Channel都无法访问该排他队列。连接断开时排他性...

退款说明

根据计费方式的特点,云消息队列 Kafka 版 资源支持的退款情况如下:包年包月的 云消息队列 Kafka 版 资源如需退款,可在控制台上退订实例。详细信息,请参见 实例生命周期管理。按量计费的 云消息队列 Kafka 版 资源在使用后才支付费用,...

资源使用变更

云消息队列 MQTT 版 从V2.x.x升级至V3.x.x实现了自身数据存储的能力,同时还去除了对 云消息队列 RocketMQ 版 的消息依赖,因此,云消息队列 MQTT 版 的实例Topic使用有变更。资源 V2.x.x使用说明 V3.x.x使用说明 云消息队列 MQTT 版 ...

开发参考

本文介绍 云消息队列 RocketMQ 版 的SDKAPI的支持情况,供您进行对应的开发操作。云消息队列 RocketMQ 版 消息收发需要通过调用SDK完成,云消息队列 RocketMQ 版 的SDK支持Java、C++、.NET、Go等多语言开发。SDK参考提供了各语言的SDK的...

权限策略

云消息队列 MQTT 版 的ResourceAction的可选值对应规则可分为控制台、OpenAPI 云消息队列 MQTT 版 客户端三大类。针对控制台资源的相关操作,按资源类型又可分为实例、TopicGroup三类。说明 如需访问 云消息队列 MQTT 版 的资源...

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

注意事项 上述流程简要描述了如何使用 云消息队列 MQTT 版 云消息队列 RocketMQ 版 来搭建电子价签系统,具体的SDK说明,请参见 云消息队列 MQTT 版 以及 云消息队列 RocketMQ 版 文档。其中使用 云消息队列 MQTT 版 云消息队列 ...

删除队列消息

本文介绍如何删除某个队列的所有消息。您可以使用Java客户端库中 queuePurge 方法删除某个队列的所有消息。示例代码如下:channel.queuePurge("queue-name");

开发参考

本文介绍 云消息队列 Kafka 版 的SDKAPI及Terraform的支持情况,供您进行对应的开发操作。开发参考 API参考指南 SDK参考 Terraform

权限策略

云消息队列 MQTT 版 的ResourceAction的可选值对应规则可分为控制台、OpenAPI 云消息队列 MQTT 版 客户端三大类。针对控制台资源的相关操作,按资源类型又可分为实例、Topic、Group规则四类。说明 如需访问 云消息队列 MQTT 版 的...

使用限制

云消息队列 Kafka 版 对某些具体指标进行了约束规范,您在使用 云消息队列 Kafka 版 时注意不要超过相应的限制值,以免程序出现异常。重要 若由于您的实例配置超出使用限制导致的任何不稳定情况,不在SLA承诺赔偿范围内。云消息队列 ...

配置消息监控告警实现风险预警

监控进入死信队列的消息量可以帮助您及时预警当前业务出现的非预期且无法判断的异常问题。未配置风险:死信消息代表消费者无法正确处理消息,需要消费应用进行异常处理。如果没有配置监控忽略了死信消息,可能造成消费业务不完整。配置时机...

领域模型概述

本文为您介绍 云消息队列 RocketMQ 版 的领域模型。产品定位 云消息队列 RocketMQ 版 是一款典型的分布式架构下的中间件产品,使用异步通信方式...云消息队列 RocketMQ 版 使用的传输模型为发布订阅模型,因此也具有发布订阅模型的特点

配置消息监控告警实现风险预警

云消息队列 RocketMQ 版 支持通过云监控配置告警规则,以便您可以实时监控实例的运行状态关键的业务指标,并能够及时收到异常的告警通知,实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务,对于每个规格...

为什么限制Topic总数(分区总数)?

Topic总数(分区总数)太多会使集群性能稳定性能急剧下降。云消息队列 Kafka 版 的存储协调机制是以分区为粒度的,分区数太多,会导致存储碎片化严重,集群性能稳定性都会急剧下降。

MQTT与RocketMQ的消息结构映射

本文针对使用 云消息队列 RocketMQ 版 SDK与 云消息队列 MQTT 版 交互的场景,提供交互中所涉及的消息结构属性字段的映射关系,方便您更好的理解组合使用这两个产品。云消息队列 MQTT 版 是一款面向移动端的网关产品,可通过数据互通...

消息收发流程变更

云消息队列 MQTT 版 V2.x.x版本强依赖 云消息队列 RocketMQ 版 作为消息存储,因此 云消息队列 MQTT 版 消息 云消息队列 RocketMQ 版 天然打通,创建了Topic后即可天然使用 云消息队列 RocketMQ 版 云消息队列 MQTT 版 的SDK相互通信...

产品架构

本文介绍 云消息队列 Kafka 版 的系统架构发布/订阅模型。云消息队列 Kafka 版 系统架构 如 云消息队列 Kafka 版的系统架构 所示,一个 云消息队列 Kafka 版 集群包括Producer、Kafka Broker、Group、ZooKeeper。图 1.云消息队列 Kafka ...

数据流入规则管理

云消息队列 RocketMQ 版 实例版本 仅4.0系列实例支持 云消息队列 MQTT 版 云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时,云消息队列 RocketMQ 版 仅4.0系列实例支持消息流入或流出规则,5.0系列实例不支持。...

跨云产品数据流入

注意事项 云消息队列 MQTT 版 通过配置的流入规则 云消息队列 RocketMQ 版 进行跨云产品的消息交互时,若 云消息队列 RocketMQ 版 的服务端进行升级,则在升级期间,可能会造成 云消息队列 MQTT 版 客户端消费消息延迟。产品升级动态,请...

产品优势

简单易用,在代码上只需要设置一个参数即可完成,解决开源RabbitMQ无延时队列的痛点。高精度支持,最短可精确到秒级,最长可持续1天。高性能,性能与普通消息一致。多副本数据冗余,确保消息可恢复。消息重试 重试一次一分钟,最多16次重试...

数据流出规则管理

云消息队列 RocketMQ 版 实例版本 仅4.0系列实例支持 云消息队列 MQTT 版 云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时,云消息队列 RocketMQ 版 仅4.0系列实例支持消息流入或流出规则,5.0系列实例不支持。...

什么是云消息队列 MQTT 版

如果说传统的消息队列中间件一般应用于微服务之间,那么适用于物联网的 云消息队列 MQTT 版 则实现了端与云之间的消息传递真正意义上的万物互联。本文介绍 云消息队列 MQTT 版 的消息收发模型、产品优势应用场景。核心概念 Topic:消息...

Topic使用变更

云消息队列 MQTT 版 从V2.x.x升级至V3.x.x后,实现了独立存储,Topic资源不再依赖于 云消息队列 RocketMQ 版,因此两个产品的Topic将完全彼此独立。本文介绍两个版本中Topic资源控制台操作的差异并提供相应控制台截图进行对比。变更说明 ...

迁移概述

重要 消息队列的特点是,数据一旦被消费,则已经完成使命。因此,除了需要将自建Kafka集群的数据备份 云消息队列 Kafka 版 实例的情况外,一般情况下不推荐您迁移数据。查看迁移进度:查看自建Kafka集群迁移到 云消息队列 Kafka 版 的进度...

上下线通知规则管理

云消息队列 RocketMQ 版 实例版本 仅4.0系列实例支持 云消息队列 MQTT 版 云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时,云消息队列 RocketMQ 版 仅4.0系列实例支持消息流入或流出规则,5.0系列实例不支持。...

主题(Topic)

定义 主题是 云消息队列 RocketMQ 版 中消息传输存储的顶层容器,用于标识同一类业务逻辑的消息。主题的作用主要如下:定义数据的分类隔离 在 云消息队列 RocketMQ 版 的方案设计中,建议将不同业务类型的数据拆分到不同的主题中管理,...

ConnectionChannel

本文介绍 云消息队列 RabbitMQ 版 中ConnectionChannel的概念及其使用建议。Connection Connection是物理TCP连接。Connection将应用与 云消息队列 RabbitMQ 版 连接在一起。Connection会执行认证、IP解析、路由等底层网络任务。应用与 云...

V2.x.x到V3.x.x的升级公告

V3.x.x版本除了独立存储之外,还对V2.x.x版本实现的 云消息队列 MQTT 版 云消息队列 RocketMQ 版 互通的功能进行抽象,使得 云消息队列 MQTT 版 的数据可以根据您配置相应规则转发到其他阿里云产品,也可以配置规则从其他阿里云产品导入...

使用AMQProxy解决PHP等客户端Connection复用问题

前提条件 如果您要使用SSL连接AMQProxy 云消息队列 RabbitMQ 版,请确保您的客户端服务器已安装OpenSSL。更多信息,请参见 Downloads。重要 VPC环境下不支持使用SSL连接 云消息队列 RabbitMQ 版。背景信息 部分语言的客户端,例如PHP客户...
共有144条 < 1 2 3 4 ... 144 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云消息队列 Kafka 版 云消息队列 RocketMQ 版 物联网平台 应用实时监控服务 企业级分布式应用服务 弹性公网IP
新人特惠 爆款特惠 最新活动 免费试用