如何计算和购买消息包
生活物联网平台提供辅助计算器，本文介绍如何使用辅助计算器，并合理购买消息包。背景介绍 消息通信收费方案全面更新升级，为方便开发者合理购买消息包，平台提供辅助计算器，计算建议购买消息包个数，该数据仅供参考。辅助计算器使用 在...
JMS概述
背景信息 JMS是一种消息传递标准，允许基于Java EE（Java平台企业版）的应用程序组件创建、发送、接收、读取消息。JMS使分布式应用能够以松耦合、可靠、异步的方式进行通信。云消息队列 RabbitMQ 版 JMS库支持 JMS 1.1。云消息队列 ...
使用Spring Cloud框架收发消息
Spring Cloud是用于构建消息驱动的微服务应用程序的框架，提供服务发现、配置管理、消息传递、负载均衡等微服务相关的解决方案，可以更容易地构建分布式系统和进行服务间通信。本文介绍如何使用Spring Cloud框架接入 云消息队列 Kafka 版 ...
购买消息提醒资源
本文介绍消息提醒计费说明以及如何购买消息提醒资源。计费概述 自定义消息提醒服务根据您购买的消息提醒数量以及选择的套餐规格收取费用。下表为您展示消息提醒售卖规格以及价格。实际售价，请以 自定义消息提醒购买页 显示为准。售卖规格 ...
控制台使用相关问题
本文介绍 云消息队列 MQTT 版 控制台使用时的常见问题。云监控的最大查询范围是多少？云消息队列 MQTT 版 云监控支持...可能原因：服务端推送消息时，客户端刚好不在线，且未设置离线消息，因此当客户端重新上线时这部分消息也消费不到了。
迁移上云操作
如果部分消费者应用未更换接入点，则会导致消息堆积部分消息消费不到。接入点修改示例 Apache RocketMQ Remoting协议SDK 变更前：producer.setNamesrvAddr(“192.168.XX.XX:9876”);consumer.setNamesrvAddr(“192.168.XX.XX:9876”);变更...
重置消费位点
若这部分堆积消息可以丢弃，您可以通过重置消费位点快速将消费位点更新到指定位置，绕过这部分堆积的消息，减少下游处理压力。业务回溯，纠正处理：由于业务消费逻辑出现异常，消息被错误处理。若您希望重新消费这些已被处理的消息，可以...
SDK列表
云消息队列 RabbitMQ 版 SDK（RAM角色跨账号授权场景）如果您是RAM STS角色授权的使用场景，需要通过 云消息队列 RabbitMQ 版 SDK收发消息，该SDK只比开源SDK多一个加签依赖。云消息队列 RabbitMQ 版 支持的多语言或框架SDK如 云消息队列 ...
消费进度管理
云消息队列 RocketMQ 版 通过消费位点管理消费进度，本文为您介绍 云消息队列 RocketMQ 版 的消费进度管理机制。背景信息 云消息队列 RocketMQ 版 的生产者和消费者在进行消息收发时，必然会涉及以下场景，消息先生产后订阅或先订阅后生产...
如何处理消息堆积
问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警，登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象：在 Group 详情 页面，看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹，单击 创建查询任务，...
消息过滤
场景示例 以下图电商交易场景为例，从客户下单到收到商品这一过程会生产一系列消息，按照类型将消息分为订单消息和物流消息，其中给物流消息定义地域属性，按照地域分为杭州和上海：订单消息 物流消息 物流消息且地域为杭州 物流消息且地域...
消息堆积和延迟问题
背景信息 消息处理流程中，如果客户端的消费速度跟不上服务端的发送速度，未处理的消息会越来越多，这部分消息就被称为堆积消息。消息出现堆积进而会造成消息消费延迟。以下场景需要重点关注消息堆积和延迟的问题：业务系统上下游能力不...
【已恢复】WhatsApp 消息发送异常公告
由于与 WhatsApp 的通信出现异常，出现部分消息发送失败，我们正在与合作伙伴沟通尽快解决问题并第一时间恢复。2024 年 4 月 4 日【更新】针对影响消息发送的故障的修复程序已部署完毕，截至新加坡标准时间 2024 年 4 月 4 日上午 4:45此...
生产者负载均衡
在极端场景下，可能会出现大部分消息集中在少数队列中的情况，建议设计消息组时尽量将消息离散开，不要集中在少量消息组中。使用示例 MessageGroupHash模式不需要额外设置，对于顺序消息类型默认启用。顺序消息发送，默认采用...
集群消费和广播消费
集群消费和广播消费是 云消息队列 RocketMQ 版 的基本消费模式，您可以在消费者客户端将消费模式设置为集群消费或者广播消费，用于控制同一条消息只能被集群内一个消费者消费到，还是会被集群内每个消费者都消费到。背景信息 云消息队列 ...
订阅关系（Subscription）
行为约束 订阅关系一致 云消息队列 RocketMQ 版 是按照消费者分组粒度管理订阅关系，因此，同一消费者分组内的消费者在消费逻辑上必须保持一致，否则会出现消费冲突，导致部分消息消费异常。正确示例/Consumer c1 Consumer c1=...
消费重试
了解 云消息队列 RocketMQ 版 的消息确认机制以及消费重试策略可以帮助您分析如下问题：如何保证业务完整处理消息：了解消费重试策略，可以在设计实现消费者逻辑时保证每条消息处理的完整性，避免部分消息出现异常时被忽略，导致业务状态不...
消息过滤
若消费者只需要关注部分消息，可通过设置过滤条件在 云消息队列 RocketMQ 版 服务端完成消息过滤，只消费需要关注的消息。本文介绍消息过滤的功能描述、应用场景、使用限制、配置方式及示例代码。功能描述 消息过滤功能指消息生产者向Topic...
OnsConsumerResetOffset-重置Group ID消费位点
对于程序返回"reconsumeLater"，即走重试流程的这部分消息来说，清除无效。1：清理到指定时间。请指定一个时间点，这个时间点之后发送的消息才会被消费。可选时间范围中的起始和终止时间分别是该 Topic 中储存的最早的和最晚的一条消息的...
版本说明
修复批量消费未设置最大等待时间从而导致部分消息消费失败的问题。ons-client-1.8.8.7.Final 1.8.8.5.Final 发布时间 发布内容 下载 2022-05-16 问题修复 修复RAM角色实现跨云账号STS授权场景下，updateCredential方法调用频率较高时，三元...
版本说明
本文介绍Java SDK的版本信息，包含使用限制、下载链接、发布时间、更新点等，以便您按需获取适用的Java SDK收发消息。使用限制 JDK 1.8适用于所有Java ons-client版本，JDK 1.6仅支持ons-client v1.8.4.Final及之前的版本使用。为避免升级...
功能发布列表
本文介绍了 云消息队列 RocketMQ 版 每次发布涉及的新增功能、功能优化、重要问题修复及对应的文档，帮助您了解 云消息队列 RocketMQ 版 的发布动态。2023-10-24 实例系列 功能名称 功能描述 变更类型 相关文档 5.x系列实例 Serverless实例...
GetSubscriptionAttributes
Request 请求消息由以下几个部分组成：请求行 GET/topics/$TopicName/subscriptions/$SubscriptionName HTTP/1.1 特有Request Header 无，请参见 公共参数。Request Body 无。Response 返回消息由返回状态行、HTTP头和消息三部分组成：...
为什么发送给Topic的消息在分区中分布不均衡
问题现象 发送消息到某个Topic后，该Topic下部分分区消息比较多，部分分区消息少，甚至没有。分区中消息量可以在 Topic详情 页面的 分区状态 页签查看，位点数即是消息数。以下图为例，分区 2 消息比较多，其他分区消息少甚至没有，消息...
常见问题
如何传递文本消息 Linux-SDK 提供了两种文本消息的传递模式：P2P 场景：推荐 DataChannel 传递，调用 Session->SendData 方法（高频消息，能保证按顺序收发）。其他场景：使用 Room 中转的模式，调用 Session->SendText 方法（低频消息可能...
消息队列
更正文档 概述 消息队列是一种任务间传递数据的有效方式。消息队列使用环形缓冲池（ring buffer）来管理消息的队列缓冲区，并使用类似信号量的机制进行任务间的同步。任务通过消息队列可以发送消息，也可以通过它接收消息，从而实现数据的...
默认配置映射关系
映射关系如下：消息服务MNS 默认入参 目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 云消息队列 RocketMQ 版 部分事件$.data.body 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$.data.body ...
默认配置映射关系
映射关系如下：消息服务MNS 默认入参 目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 云消息队列 RocketMQ 版 部分事件$.data.body 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$.data.body ...
默认配置映射关系
映射关系如下：消息服务MNS 默认入参 目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 云消息队列 RocketMQ 版 部分事件$.data.body 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$.data.body ...
MQTT快速入门
注意事项 云消息队列 MQTT 版 需搭配后端消息存储队列一起使用，具体说明如下：云消息队列 MQTT 版 实例是一个无状态网关类型实例，用来完成IoT移动场景下的客户端连接维持和消息转发，本身并不提供消息数据持久化功能，具体的消息存储和...
消息队列Kafka版
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已购买并部署 云消息队列 ...
正式商用公告
购买须知 在购买 云消息队列 Kafka 版 实例前，您需要了解以下信息：云消息队列 Kafka 版 公测的共享实例的处理 您无需释放公测期间申请的共享实例。如果您没有购买商用实例，云消息队列 Kafka 版 不会收取您任何费用。云消息队列 Kafka 版...
查看分区状态
分区用于存储消息，每个Topic由一个或多个分区组成，分区状态展示了...如果您的部分分区消息数量相差过大，请参见 为什么发送给Topic的消息在分区中分布不均衡？如果 最近更新时间 显示有异常，请参见 为什么Topic有分区时间显示1970或“-”？
非对称密钥概述
相比对称加密，非对称密钥通常用于在信任程度不对等的系统之间，实现数字签名验签或者加密传递敏感信息。非对称密钥由一对公钥和私钥组成，他们在密码学上互相关联，其中的公钥可以被分发给任何人，而私钥必须被安全的保护起来，只有受信任...
消息服务MNS
前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已创建 消息服务MNS 队列。具体步骤，请参见 开通消息服务MNS并授权。开服地域 在消息集成中创建消息流出任务时，支持将 消息服务...
默认配置映射关系
映射关系如下：消息服务MNS 默认入参 源端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 云消息队列 RocketMQ 版 部分事件$.data.body 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$.data.body 数据...
变更消息配置
前提条件 您已购买 云消息队列 Kafka 版 实例，且实例处于服务中状态。操作步骤 登录 云消息队列 Kafka 版 控制台，在 概览 页面的 资源分布 区域，选择地域。在 实例列表 页面，单击目标实例名称。在 实例详情 页面的 配置信息 区域，选择...
消息服务MNS
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流出任务，以实现将 云消息队列 RocketMQ 版 的消息流出至 消息服务MNS。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已...
消息服务MNS
前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已创建 消息服务MNS 队列。具体步骤，请参见 开通消息服务MNS并授权。开通事件总线EventBridge并授权。开服地域 在消息集成中创建...
云消息队列RabbitMQ版
前提条件 您已购买 云消息队列 RabbitMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。开通事件总线EventBridge并授权。创建消息流出任务 登录 云消息队列 RabbitMQ 版 控制台，然后左侧导航栏选择 消息集成>消息流出。在...
- 产品推荐
- 这些文档可能帮助您