查看接入点

背景信息消息队列 Kafka 版 提供以下类型的接入点:默认接入点:适用于在VPC环境收发消息,但不支持SASL校验。SSL接入点:适用于在公网环境收发消息,且支持SASL校验。关于以上接入点的差异,请参见 接入点对比。注意事项 云消息队列 ...

步骤二:创建资源

在调用SDK收发消息前,您需要提前创建 云消息队列 RocketMQ 版 的相关资源,包括创建 云消息队列 RocketMQ 版 实例、获取实例的接入点、创建Topic、创建ConsumerGroup。调用SDK时,需要将这些资源信息填写到SDK代码中。前提条件 创建专有...

消息收发功能

消息收发为 云消息队列 MQTT 版 最基本的功能,云消息队列 MQTT 版 支持终端和云端服务接入 云消息队列 MQTT 版 服务器,实现终端和终端、终端和云端的消息通信。本文介绍消息收发功能的基本场景和示例代码。背景信息消息队列 MQTT 版 ...

正式商用公告

购买须知 在购买 云消息队列 Kafka 版 实例前,您需要了解以下信息:云消息队列 Kafka 版 公测的共享实例的处理 您无需释放公测期间申请的共享实例。如果您没有购买商用实例,云消息队列 Kafka 版 不会收取您任何费用。云消息队列 Kafka 版...

消息轨迹

消息轨迹是指一条消息从生产者发送到 云消息队列 RabbitMQ 版 服务端,再到消费者消费,整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息。如果消息收发不符合预期,您可以通过查询消息轨迹,快速分析和定位问题,及时...

基本概念

本文主要对 云消息队列 RocketMQ 版 涉及的专有名词及术语进行定义和解析,方便您更好地理解相关概念并使用 云消息队列 RocketMQ 版。Topic 消息主题,一级消息类型,通过Topic对消息进行分类。更多信息,请参见 Topic与Tag最佳实践。消息...

续费说明

包年包月 云消息队列 RocketMQ 版 实例到期后会影响服务及资源的正常使用,如果您需要继续使用 云消息队列 RocketMQ 版,需要在指定时间内为实例及时续费,否则 云消息队列 RocketMQ 版 实例及相关资源会被自动释放且不可恢复。本文介绍...

开源MQTT迁移至云消息队列 MQTT 版

背景信息消息队列 MQTT 版 拥有多协议、多语言平台的开发能力,并支持设备级权限控制以及SSL/TLS传输加密,您可以不变更开源客户端,仅通过变更接入点和权限配置,将客户端从开源MQTT服务端迁移至 云消息队列 MQTT 版 上以获取更高的...

产品架构

本文介绍 云消息队列 RocketMQ 版 的系统部署架构,方便您更好地理解 云消息队列 RocketMQ 版 的高可用性。云消息队列 RocketMQ 版 在任何一个环境都是可扩展的,生产者必须是一个集群,消息服务器必须是一个集群,消费者也同样。集群级别...

消费进度管理

消息队列 RocketMQ 版 通过消费位点管理消费进度,本文为您介绍 云消息队列 RocketMQ 版 的消费进度管理机制。背景信息消息队列 RocketMQ 版 的生产者和消费者在进行消息收发时,必然会涉及以下场景,消息先生产后订阅或先订阅后生产...

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

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

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

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

查看接入点

如需使用客户端连接 云消息队列 Kafka 版 收发消息,您需要根据客户端的网络环境类型及传输的安全需要来配置接入点。默认接入点适用于在保密性较高的VPC环境收发消息;SASL接入点适用于无需对传输链路加密但需对消息收发鉴权;同时需要链路...

从自建MySQL同步至云消息队列 Kafka 版

背景信息消息队列 Kafka 版 是阿里云提供的分布式、高吞吐、可扩展的消息队列服务,针对开源的Apache Kafka提供全托管服务,彻底解决开源产品长期以来的痛点,您只需专注于业务开发,无需部署运维。云消息队列 Kafka 版 广泛用于日志...

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

背景信息消息队列 MQTT 版 支持云端SDK,云上应用可直接通过云端SDK接入 云消息队列 MQTT 版 服务端进行消息收发并获取客户端的上下线状态。更多信息,请参见 获取MQTT客户端在线状态。同时 云消息队列 MQTT 版 支持和其他云产品进行...

Spring集成

背景信息消息队列 RocketMQ 版 支持以下消息类型的生产者和消费者与Spring集成:普通消息的生产者和消费者 事务消息的生产者和消费者 顺序消息的生产者和消费者 说明 云消息队列 RocketMQ 版 暂不支持Spring框架下定时消息和延时消息的...

实例管理

实例是用于 云消息队列 RocketMQ 版 服务的虚拟机资源,会存储消息主题(Topic)和客户端ID(Group ID)信息。使用 云消息队列 RocketMQ 版 进行消息收发,必须先创建 云消息队列 RocketMQ 版 实例。本文介绍如何在 云消息队列 RocketMQ 版...

消息检索

当 云消息队列 Kafka 版 控制台提供的按位点查询和按时间查询消息的功能无法满足您搜索消息的需求时,您可以使用 云消息队列 Kafka 版 消息检索功能。消息检索支持按Topic分区、位点范围、时间范围以及消息Key和Value关键字检索。本文介绍...

快速入门概述

背景信息消息队列 RocketMQ 版 提供了四种消息类型,更多信息,请参见 消息类型列表。本文以收发普通消息为例进行说明,因此,您按照本文提供的步骤创建的普通消息的Topic,不能用于收发其他类型的消息。换言之,不同消息类型的Topic不...

如何通过代理访问云消息队列 Kafka 版实例

概述 暂不支持通过代理访问云消息队列 Kafka 版实例,具体请查看 详细信息。详细信息消息队列 Kafka 版的客户端访问服务端的原理如下。通过 bootstrap.servers 随机访问服务器获取Metadata。通过Metadata里的IP地址进行后续的消息收发。...

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

背景信息消息队列 RocketMQ 版 提供全托管的消息服务,对于每个规格的实例都有明确的 SLA保障,您购买实例后即可保证消息收发TPS、消息存储、网络吞吐等指标达到规格规定的能力。您无需担心实例性能问题,但实际生产环境中仍需要关注...

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

背景信息消息队列 RocketMQ 版 提供全托管的消息服务,对于每个规格的实例都有明确的 SLA保障,您购买实例后即可保证消息收发TPS、消息存储等指标达到规格规定的能力。您无需担心实例性能问题,但实际生产环境中仍需要关注实际的业务...

权益分发

在电商和新零售领域,权益分发适用于对特定的用户进行指定运营活动的场景。技术层面上,此种场景的DB和缓存的数据强一致性较难保证。...更多信息消息队列 RocketMQ 版 的功能与特性详情,请参见以下文档:功能与特性概述 消息重试

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

接入点说明 终端和云端服务与 云消息队列 MQTT 版 通信时,需要在各自的SDK代码中设置 云消息队列 MQTT 版 实例的接入点信息,通过接入点和 云消息队列 MQTT 版 服务端连接。终端SDK接入点格式 使用终端SDK接入 云消息队列 MQTT 版 时,...

Topic导入/导出

消息队列 RocketMQ 版 支持将指定实例的Topic列表信息导出,再导入至其他的 云消息队列 RocketMQ 版 实例,实现Topic的跨实例迁移。您可以在更换实例或者克隆实例时,使用Topic导入/导出功能快速批量创建出相同的Topic。背景信息消息...

Topic导入/导出

消息队列 RocketMQ 版 支持将指定实例的Topic列表信息导出,再导入至其他的 云消息队列 RocketMQ 版 实例,实现Topic的跨实例迁移。您可以在更换实例或者克隆实例时,使用Topic导入/导出功能快速批量创建出相同的Topic。背景信息消息...

订阅消息

本文介绍如何通过 云消息队列 RocketMQ 版 的Java SDK订阅消息。订阅方式 云消息队列 RocketMQ 版 支持以下两种订阅方式:集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息,一个Group ID有3个...

接口和参数说明

消息队列 RocketMQ 版 提供Java SDK实现消息发送与订阅,订阅方可通过Push或Pull的方式从 云消息队列 RocketMQ 版 获取消息。本文介绍消息发送和订阅的接口和参数说明。背景信息消息队列 RocketMQ 版 支持以下两种消息获取方式:Push...

企业铂金版和标准版实例相互转换

消息队列 RocketMQ 版 支持标准版和企业铂金版实例,实例类型可以相互转换。标准版实例计费方式为按量付费,适合消息量少或者波峰谷差异明显的业务场景;企业铂金版实例计费方式为包年包月适合高SLA要求或业务量较大且稳定的场景。当您的...

迁移消费者程序

背景信息消息队列 Kafka 版 控制台提供迁移实例功能,您可以使用该功能将自建Kafka集群或其他云Kafka集群的元数据(Topic和Group配置信息)和消息数据同步到目标集群,迁移完成后目标集群的元数据与源集群的元数据保持一致并且持续更新...

重置消费位点

背景信息消息队列 RocketMQ 版 通过消费位点管理消息的消费进度。每条消息被某个消费者消费完成后不会立即在队列中删除,云消息队列 RocketMQ 版 会基于每个Group维护一份消费记录,该记录指定了Group下的消费者消费指定Topic时,消费过...

消费者分类

背景信息消息队列 RocketMQ 版 面向不同的业务场景提供了不同消费者类型,每种消费者类型的集成方式和控制方式都不一样。了解如下问题,可以帮助您选择更匹配业务场景的消费者类型。如何实现并发消费:消费者如何使用并发的多线程机制...

订阅消息

本文介绍如何通过 云消息队列 RocketMQ 版 的C/C++ SDK订阅消息。订阅方式 云消息队列 RocketMQ 版 支持以下两种订阅方式:集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息,一个Group ID有3个...

重置消费位点

背景信息消息队列 Kafka 版 支持以下重置消费位点方式:从最新位点开始消费:不再消费Broker上堆积的消息,将消费位点重置到最新的位置。说明 堆积的消息本身并不会因此被删除,改变的只是消费位点。指定时间点开始消费:将消费位点重置...

MQTT与RocketMQ的消息结构映射

消息队列 RocketMQ 版 协议中的消息(Message)可以拥有自定义属性(Properties),而MQTT协议目前的版本不支持属性,但为了方便溯源MQTT协议中的Header信息和设备信息,云消息队列 MQTT 版 的部分信息将被映射到 云消息队列 RocketMQ 版...

集群消费和广播消费

背景信息消息队列 RocketMQ 版 是基于发布和订阅模式的消息系统。消费者,即消息的订阅方,从订阅的Topic中接收消息并消费。使用相同Group ID的多个消费者属于同一个消费者集群。同一个集群下的消费者消费逻辑必须完全一致(包括Tag的...

产品计费

本文为您介绍 云消息队列 RocketMQ 版 的实例类型、计费方式、计费组成等信息。云消息队列 RocketMQ 版5.x系列 5.x系列计费概述 云消息队列 RocketMQ 版4.x系列 4.x系列计费概述

API概览

当设备与云消息队列 MQTT 版建立连接时,需要将设备访问凭证中的信息按照约定的形式设置到Username和Password中,向云消息队列 MQTT 版发起认证请求,云消息队列 MQTT 版认证通过后激活设备,设备与云消息队列 MQTT 版间才可传输数据。...

消息存储和清理机制

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

名词解释

本文主要对 云消息队列 RabbitMQ 版 涉及的专有名词及术语进行定义和解析,方便您更好地理解相关概念并使用 云消息队列 RabbitMQ 版。A Alternate Exchange 备份Exchange,简称AE,用于接收配置了备份Exchange的Exchange路由失败的消息。...
共有189条 < 1 2 3 4 ... 189 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云消息队列 RocketMQ 版 云消息队列 Kafka 版 全局事务服务 (文档停止维护) 云数据库 RDS 弹性公网IP 短信服务
新人特惠 爆款特惠 最新活动 免费试用