队列(MessageQueue)

如果您在代码中自定义拼接队列名称并和其他操作进行绑定,一旦服务端版本升级,可能会出现队列名称无法解析的兼容性问题。使用建议 按照实际业务消耗设置队列数 云消息队列 RocketMQ 版 的应遵循少用够用原则,避免随意增加队列数量。主题...

消费者负载均衡

策略特点 相对于队列粒度负载均衡策略,消息粒度负载均衡策略有以下特点:消费分摊更均衡 传统队列级的负载均衡策略中,如果队列数量和消费者数量不均衡,则可能会出现部分消费者空闲,或部分消费者处理过多消息的情况。消息粒度负载均衡...

生产者负载均衡

在极端场景下,可能会出现大部分消息集中在少数队列中的情况,建议设计消息组时尽量将消息离散开,不要集中在少量消息组中。使用示例 MessageGroupHash模式不需要额外设置,对于顺序消息类型默认启用。顺序消息发送,默认采用...

消费进度管理

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

消息收发常见问题

本文介绍使用 云消息队列 MQTT 版 进行消息收发时的常见问题。为什么会出现一条消息同一时间重试多次?为什么消息会一直重试?消息发送时提示GroupID没有权限。使用RocketMQ数据流入MQTT功能时,为什么子级Topic后会多了一个“/”?消息发送...

常见问题

本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。产品功能常见问题 消息队列RocketMQ版5.x系列相比4.x系列实例有什么优势?消息队列RocketMQ版5.x系列实例兼容哪些版本客户端?消息队列RocketMQ版支持哪些语言客户端?消息队列...

计费常见问题

当多个资源包叠加时,系统会按照 资源包抵扣优先级 进行抵扣,前一个资源包抵扣完再抵扣下一个资源包,但是以下情况可能会出现同时抵扣两个资源包。包年包月资源包每个月会有固定的资源额度,每个月1号恢复至满额。若您当月的额度已经用完...

TCP协议客户端大版本发布

该策略可能会出现以下问题:消费者数量比和Queue数量多时,部分消费者获取不到消息的现象。部分消费者异常或者处理缓慢,其他消费者空闲却无法共同分担堆积压力的情况。以消息为粒度进行负载,负载策略更加均衡。避免了队列级负载策略可能...

常见问题

本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。产品功能常见问题 云消息队列 RocketMQ 版5.0系列相比4.0系列实例有什么优势?云消息队列 RocketMQ 版5.0系列实例兼容哪些版本客户端?云消息队列 RocketMQ 版支持哪些语言客户端?云...

如何快速测试云消息队列 Kafka 版服务端是否正常?

但是会出现部分分区发送消息失败,等到分区恢复后即可恢复正常。当 存储引擎 选择 Local 存储 时,默认选择 分区顺序消息。普通消息 日志清理策略 Topic日志的清理策略。当 存储引擎 选择 Local 存储(当前仅专业版实例支持选择存储引擎...

消息存储和清理机制

背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义,消息按照达到服务器的先后顺序被存储到队列中,理论上每个队列都支持无限存储。但是在实际部署场景中,服务端节点的物理存储空间有限,消息无法做到永久存储。因此,在实际使用中...

计费概述

因此,您的 阿里云产品消费汇总 中,会出现 云消息队列 RocketMQ 版 的产品消费明细。实例类型和计费模式 云消息队列 MQTT 版 提供的实例类型及其计费方式如下,如需了解实例类型间的功能差异,请参见 实例类型。实例类型 计费模式 说明 ...

消费者分类

顺序性保障 基于 云消息队列 RocketMQ 版 顺序消息 的定义,如果消费者分组设置了顺序消费模式,则PushConsumer在触发消费监听器时,严格遵循消息的先后顺序。业务处理逻辑无感知即可保证消息的消费顺序。说明 消息消费按照顺序处理的前提...

开源对比

通过镜像队列或仲裁队列实现,容易出现脑裂问题。消息堆积能力 在海量消息堆积的情况下,始终保持高性能,不影响集群的正常服务。大量消息堆积容易引起内存问题,可能导致服务宕机。弹性能力 通过增减集群节点数量实现扩缩容。Serverless...

MQTT快速入门

在以下使用情况中出现问题 云消息队列 MQTT 版 产品方概不负责:客户端不使用域名接入而是使用IP地址接入,产品方更新了域名解析导致原有IP地址失效。客户端网络对IP地址设置网络防火墙策略,产品方更新了域名解析后新IP地址被您的防火墙...

RocketMQ全链路追踪解决方案

在分布式应用系统中,多个服务间的交互涉及复杂的网络通信和数据传输,往往一次请求需要多个内部服务间的相互调用才能完成,任何一个环节出现问题都可能导致外部服务任务执行失败或延时,且很难快速定位问题根源。链路追踪功能可在多个服务...

消息堆积和延迟问题

本文主要介绍 云消息队列 RocketMQ 版 TCP协议的Java客户端使用过程中,经常会出现的消息堆积和消息延迟的问题。通过了解 云消息队列 RocketMQ 版 客户端的消费原理和消息堆积的主要原因,帮助您可以在业务部署前更好的规划资源和配置,或...

版本说明

说明 本次修复只针对使用RAM角色授权的场景,若您自己更新三元组,还会出现问题。ons-client-1.8.8.5.Final 1.8.8.3.Final 发布时间 发布内容 下载 2022-01-18 功能优化 修复服务端异常导致消费位点跳过的问题。修复客户端消费超时时间...

订阅者最佳实践

云消息队列 Kafka 版 Consumer顺序依次消费分区内的每条消息,记录已经消费了的消息条数,称为消费位点ConsumerOffset。剩余的未消费的条数(也称为消息堆积量)=MaxOffset-ConsumerOffset。消费位点提交 云消息队列 Kafka 版 消费者有...

快速使用MQTT的Java SDK收发消息(终端和终端消息收发...

在以下使用情况中出现问题 云消息队列 MQTT 版 产品方概不负责:终端或云端不使用域名接入而是使用IP地址接入,产品方更新了域名解析导致原有IP地址失效。终端或云端网络侧对IP地址设置网络防火墙策略,产品方更新了域名解析后新IP地址被...

消费重试

系统异常时处理中的消息状态如何恢复:帮助您了解当系统出现异常(宕机故障)等场景时,处理中的消息状态如何恢复,是否会出现状态不一致。消费重试策略 消费重试策略指消费者在消费某条消息失败后,消息重试的间隔时间和最大重试次数。...

集群消费和广播消费

集群消费和广播消费是 云消息队列 RocketMQ 版 的基本消费模式,您可以在消费者客户端将消费模式设置为集群消费或者广播消费,用于控制同一条消息只能被集群内一个消费者消费到,还是被集群内每个消费者都消费到。背景信息 云消息队列 ...

消息过滤

可能原因:若多个消费者是通过同一个消费者分组(Group ID)订阅的指定Topic,则所有消费者的过滤条件即订阅的Tag要一致,否则会出现订阅关系不一致,导致部分消息丢失。消费者设置了过滤条件,消息消费数量是按照过滤前还是过滤后计算呢?...

快速使用MQTT的Java SDK收发消息(终端和云端消息收发...

在以下使用情况中出现问题 云消息队列 MQTT 版 产品方概不负责:终端或云端不使用域名接入而是使用IP地址接入,产品方更新了域名解析导致原有IP地址失效。终端或云端网络侧对IP地址设置网络防火墙策略,产品方更新了域名解析后新IP地址被...

MQTT和RocketMQ进行数据互通(客户端上下线通知)

在以下使用情况中出现问题 云消息队列 MQTT 版 产品方概不负责:客户端不使用域名接入而是使用IP地址接入,产品方更新了域名解析导致原有IP地址失效。客户端网络对IP地址设置网络防火墙策略,产品方更新了域名解析后新IP地址被您的防火墙...

MQTT和RocketMQ进行数据互通(跨产品数据流入)

如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能,例如顺序消息特性、事务消息特性等,您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...

MQTT和RocketMQ进行数据互通(跨产品数据流出)

如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能,例如顺序消息特性、事务消息特性等,您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...

发布者最佳实践

本文介绍 云消息队列 Kafka 版 发布者的最佳实践,帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端,其基本概念与思想是相通的,但实现细节可能存在差异。发送消息 发送消息的示例代码如下:Future...

环境准备(v1.x.x)

此外使用如上方式会出现一些警告信息如下。warning:Using 'gethostbyaddr' in statically linked applications requires at runtime the shared libraries from the glibc version used for linking 建议最佳的方式,不要使用完全的静态...

环境准备(v1.x.x)

此外使用如上方式会出现一些警告信息如下。warning:Using 'gethostbyaddr' in statically linked applications requires at runtime the shared libraries from the glibc version used for linking 建议最佳的方式,不要使用完全的静态...

资源包说明

当多个资源包叠加时,系统会按照 资源包抵扣优先级 进行抵扣,前一个资源包抵扣完再抵扣下一个资源包,但是以下情况可能会出现同时抵扣两个资源包。包年包月资源包每个月会有固定的资源额度,每个月1号恢复至满额。若您当月的额度已经用完...

死信消息

不支持将生产原消息的Topic作为死信Topic(避免出现循环雪崩的问题)。在死信消息转存流程中,若系统发现死信Topic和生产消息的原Topic相同,则该条消息将被丢弃。不同Topic的死信消息可以保存到同一个死信Topic中。删除某个ConsumerGroup...

配额与限制

云消息队列 RocketMQ 版 对实例的资源配额、实例规格和相关参数进行了约束和规范,您在使用 云消息队列 RocketMQ 版 时不要超过对应的限制值,避免应用出现异常。参数限制 以下参数中各资源的命名及备注等限制值不支持调整,请严格按照规范...

使用Canal和RocketMQ实现数据库变更订阅处理

false 链路轨迹追踪设置 使用Canal发送变更事件到 云消息队列 RocketMQ 版 时,可以选择开启 云消息队列 RocketMQ 版 的云上消息轨迹功能,以便出现异常时可以快速定位链路问题。开启链路轨迹追踪功能,需要设置如下参数:rocketmq.enable....

使用Canal和RocketMQ实现数据库变更订阅处理

false 链路轨迹追踪设置 使用Canal发送变更事件到 云消息队列 RocketMQ 版 时,可以选择开启 云消息队列 RocketMQ 版 的云上消息轨迹功能,以便出现异常时可以快速定位链路问题。开启链路轨迹追踪功能,需要设置如下参数:rocketmq.enable....

QueryMqttTraceDevice-查询设备轨迹

分页查询微消息队列MQTT版客户端的设备轨迹。当设备的状态出现异常时,您可以通过该接口查询指定设备的连接历史,帮助您快速定位异常原因。接口说明 每成功调用一次 QueryMqttTraceDevice 接口,都会计算为一次消息 TPS,从而影响您的计费...

CreateConsumerGroup-创建消费者分组

创建云消息队列 RocketMQ 版的消费者分组(ConsumerGroup)。消费者分组是云消息队列 RocketMQ 版系统中承载多个消费行为一致的消费者的负载均衡分组。消费者需要通过指定消费者分组订阅相关的主题来实现消息订阅。接口说明 注意 阿里云...

排他队列

即使客户端已声明该排他队列为持久性的(durable 为 true),只要该排他性队列的连接断开,队列会被自动删除,且队列中的数据也会被删除。适用场景 排他队列适用于生产者和消费者在同一进程中,且对数据丢失不敏感的场景。使用风险 因为...

使用云消息队列 Kafka 版时出现“Not authorized to ...

问题描述 使用云消息队列 Kafka 版时出现“Not authorized to access group”的错误信息。问题原因 没有创建Consumer Group时遇到此报错信息。解决方案 您可以选择如下任意一种方式创建Consumer Group。在云消息队列 Kafka 版的控制台...

客户端首次接入云消息队列 Kafka 版时出现异常的排查...

客户端版本问题:客户端版本太低可能会出现异常,建议升级到与服务端匹配的客户端版本。关于客户端Demo,请参见 云消息队列 Kafka 版Demo库。说明 云消息队列 Kafka 版对客户端版本有限制。例如,如果服务端版本为0.10.2.2,建议客户端版本...
共有172条 < 1 2 3 4 ... 172 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云消息队列 Kafka 版 云消息队列 RocketMQ 版 云工作流 全局事务服务 (文档停止维护) 弹性公网IP 短信服务
新人特惠 爆款特惠 最新活动 免费试用