将云消息队列 Kafka 版接入阿里云Elasticsearch
当您需要查看并分析庞杂的日志数据时，可通过阿里云Logstash将 云消息队列 Kafka 版 中的日志数据导入阿里云Elasticsearch，然后通过Kibana进行可视化展示与分析。本文介绍将 云消息队列 Kafka 版 接入阿里云Elasticsearch的操作方法。前提...
产品概述
本文介绍 云消息队列 Kafka 版 的产品动态、产品简介及产品计费。云消息队列 Kafka 版 动态与公告 产品简介 产品计费 云消息队列 Confluent 版 什么是云消息队列 Confluent 版？产品计费
什么是云消息队列 Kafka 版？
云消息队列 Kafka 版 是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。云消息队列 Kafka 版 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，已成为大数据生态中不可或缺的部分。产品优势 云消息队列 ...
什么是云消息队列 MQTT 版
云消息队列 MQTT 版 是阿里云推出的一款面向移动互联网以及物联网领域的轻量级消息中间件。如果说传统的消息队列中间件一般应用于微服务之间，那么适用于物联网的 云消息队列 MQTT 版 则实现了端与云之间的消息传递和真正意义上的万物互联...
配置消息队列Kafka版实例的参数
本文为您介绍目标数据库实例为 专线/VPN网关/智能网关 方式接入的 阿里云消息队列Kafka版 时，部分特殊参数的配置方法和获取方式。注意事项 使用此方案将 阿里云消息队列Kafka版 接入DTS，会将数据写入到您指定的节点中。若您的源库为MySQL...
开源RabbitMQ迁移上云
迁移前须知 云消息队列 RabbitMQ 版 是阿里云基于专有的分布式消息存储技术开发的高级消息队列服务。它严格遵循AMQP 0-9-1协议，但并不是开源RabbitMQ的简单托管版本。云消息队列 RabbitMQ 版 采用了独创的架构设计，有效避免了因消息积压...
4.x和5.x版本差异及兼容性说明
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云 云消息队列 RocketMQ 版 将为您提供更加稳定可靠的服务端5...
4.x和5.x版本差异及兼容性说明
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云 云消息队列 RocketMQ 版 将为您提供更加稳定可靠的服务端5...
从自建MySQL同步至云消息队列 Kafka 版
背景信息 云消息队列 Kafka 版 是阿里云提供的分布式、高吞吐、可扩展的消息队列服务，针对开源的Apache Kafka提供全托管服务，彻底解决开源产品长期以来的痛点，您只需专注于业务开发，无需部署运维。云消息队列 Kafka 版 广泛用于日志...
消息检索
当 云消息队列 Kafka 版 控制台提供的按位点查询和按时间查询消息的功能无法满足您搜索消息的需求时，您可以使用 云消息队列 Kafka 版 消息检索功能。消息检索支持按Topic分区、位点范围、时间范围以及消息Key和Value关键字检索。本文介绍...
音视频通信解决方案（MQTT）
音视频通信解决方案是由阿里云 云消息队列 MQTT 版 和音视频通信RTC联合推出的有助于快速搭建各种实时通信场景产品，譬如在线音视频会议、1对1语音通话应用的解决方案。本文将详细描述该解决方案的系统架构、数据流设计以及相关注意事项。...
查看订阅关系
什么是订阅关系 云消息队列 RocketMQ 版 里的一个Group ID代表一个Consumer实例群组。对于大多数分布式应用来说，一个Group ID下通常会挂载多个Consumer实例。云消息队列 RocketMQ 版 的订阅关系主要由Topic+Tag共同组成，即一个Group ID下...
RAM鉴权
微消息队列MQTT版权限管理是通过阿里云的访问控制RAM（Resource Access Management）产品实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKeyId和AccessKeySecret），按需为用户分配最小权限。在使用RAM账号...
概述
请按需参见以下文档实现社区版SDK访问阿里云 云消息队列 RocketMQ 版：社区版TCP协议Java SDK接入说明 社区版TCP协议C++ SDK接入说明 暂不支持通过社区版TCP协议的Go SDK和Python SDK访问阿里云 云消息队列 RocketMQ 版，推荐您使用商业版...
概述
本文主要介绍如何使用开源社区发布的rocketmq-client-cpp二进制包进行部署和连接阿里云 云消息队列 RocketMQ 版 的过程。如需源码编译，请您自行前往开源社区下载。使用说明 社区版SDK仅在开源RocketMQ迁移上云且不希望修改代码时使用，...
顺序消息
什么是顺序消息 顺序消息是 云消息队列 RocketMQ 版 提供的一种对消息发送和消费顺序有严格要求的消息。对于一个指定的Topic，消息严格按照先进先出（FIFO）的原则进行消息发布和消费，即先发布的消息先消费，后发布的消息后消费。顺序消息...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图所示。更多信息，请参见 事务消息。前提条件 您已完成以下操作：下载C...
开发参考
OpenAPI是阿里云产品提供的开放应用程序接口，是除控制台之外，云消息队列 RocketMQ 版 管理资源的主要方式之一。API参考汇总了 云消息队列 RocketMQ 版 所有对外公开的API接口。云消息队列 RocketMQ 版5.x系列 5.x系列SDK参考 5.x系列API...
基本概念
本文介绍 云消息队列 RocketMQ 版 的基本概念，以便您更好地理解和使用 云消息队列 RocketMQ 版。主题（Topic）云消息队列 RocketMQ 版 中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题通过TopicName来做唯一标识和区分。...
MQTT与RocketMQ的消息结构映射
云消息队列 MQTT 版 的详细介绍，请参见 什么是微消息队列MQTT版 和 名词解释。消息结构映射 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 都是基于发布/订阅（Pub/Sub）模型的消息系统，两者概念上存在很多相似之处，下图列举了关键概念...
消息存活时间
什么是消息存活时间 在 云消息队列 RabbitMQ 版 中，消息存活时间用于限制消息在Queue中可以存在的时间，如果消息在Queue中存在的时间超过了设置的消息存活时间，消息将会被进行如下处理：若您未给Queue设置死信Exchange，消息将被Queue...
查询消息轨迹
云消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数，例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等，并支持可视化查询。当消息收发结果不符合预期...
队列（MessageQueue）
定义 队列是 云消息队列 RocketMQ 版 中消息存储和传输的实际容器，也是 云消息队列 RocketMQ 版 消息的最小存储单元。云消息队列 RocketMQ 版 的所有主题都是由多个队列组成，以此实现队列数量的水平拆分和队列内部的流式存储。队列的主要...
收发定时消息和延时消息
重要 社区版的Apache RocketMQ和阿里云 云消息队列 RocketMQ 版 配置方式不同，实现效果也有所差异。社区版的Apache RocketMQ支持延时消息，但不支持定时消息，因此没有专门的定时消息接口。阿里云 云消息队列 RocketMQ 版 不仅同时支持...
开通服务并授权
在阿里云官方网站开通消息队列服务后方可开始使用 云消息队列 MQTT 版。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的 云消息队列 MQTT 版 资源，并使用SDK收发消息。前提条件 您已注册阿里云账号并完成...
收发顺序消息
顺序消息（FIFO消息）是阿里云 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的社区版C++ SDK收发顺序消息的示例代码供您参考。顺序消息分为两类：全局顺序：对于指定的一个Topic，所有...
应用场景
本文为您介绍 云消息队列 RocketMQ 版 的应用场景，以便您更好地判断如何在业务中使用 云消息队列 RocketMQ 版。例如，针对一家互联网电商企业，其业务涉及广泛，如注册、订单、库存、物流等；同时，也会涉及许多业务峰值时刻，如秒杀活动...
消费者分组（ConsumerGroup）
本文介绍 云消息队列 RocketMQ 版 中消费者分组（ConsumerGroup）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 消费者分组是 云消息队列 RocketMQ 版 系统中承载多个消费行为一致的消费者的负载均衡分组。和消费者...
常见问题
云消息队列 RocketMQ 版集群消费和广播消费的区别是什么？多个Group订阅同一个Topic消息如何消费？云消息队列 RocketMQ 版的消息体最大是多少？消息在云消息队列 RocketMQ 版中能保存多久？消息的负载均衡策略是什么？消息消费失败是否会...
RAM鉴权
云消息队列 MQTT 版 权限管理是通过阿里云的访问控制RAM（Resource Access Management）产品实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKey ID和AccessKey Secret），按需为用户分配最小权限。在使用...
基本概念
更多信息，请参见 什么是云消息队列 Kafka 版？ZooKeeper 一款开源的分布式应用程序协调服务。在 云消息队列 Kafka 版 中，ZooKeeper主要用于集群管理、配置管理、Leader选举。ZooKeeper是 云消息队列 Kafka 版 的一部分，您无需感知...
使用Canal和RocketMQ实现数据库变更订阅处理
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版，实现MySQL数据库Binlog数据的变更处理。背景信息 CDC（Change Data Capture）是一种监测并捕获数据库变更的典型技术方案，常应用于异构数据源之间的数据同步。Canal...
全球消息路由
什么是全球消息路由 云消息队列 RocketMQ 版 的全球消息路由功能依托阿里云优质基础设施实现的高速通道专线（高速通道无需另行开通），高效地实现不同地域之间的消息同步复制。具体实现如下图所示。计费影响 全球消息路由为 云消息队列 ...
消息（Message）
本文介绍 云消息队列 RocketMQ 版 中消息（Message）的定义、模型关系、内部属性、行为约束及使用建议。定义 消息是 云消息队列 RocketMQ 版 中的最小数据传输单元。生产者将业务数据的负载和拓展属性包装成消息发送到 云消息队列 RocketMQ...
产品架构
本文介绍 云消息队列 RocketMQ 版 的系统部署架构，方便您更好地理解 云消息队列 RocketMQ 版 的高可用性。云消息队列 RocketMQ 版 在任何一个环境都是可扩展的，生产者必须是一个集群，消息服务器必须是一个集群，消费者也同样。集群级别...
参数说明
本文介绍您在使用社区版C++ SDK接入阿里云 云消息队列 RocketMQ 版 时，需要配置的参数。通用参数 参数名 说明 NameServer 设置TCP协议接入点，从 控制台 的 实例详情 页面获取。GroupID 您在 控制台 上创建的Group ID，更多信息，请参见 ...
JMS概述
云消息队列 RabbitMQ 版 提供JMS库供JMS客户端接入 云消息队列 RabbitMQ 版。本文介绍 云消息队列 RabbitMQ 版 JMS库的相关概念、获取方式、使用限制和使用教程。背景信息 JMS是一种消息传递标准，允许基于Java EE（Java平台企业版）的应用...
生产者（Producer）
本文介绍 云消息队列 RocketMQ 版 中生产者（Producer）的定义、模型关系、内部属性、版本兼容性及使用建议。定义 生产者是 云消息队列 RocketMQ 版 系统中用来构建并传输消息到服务端的运行实体。生产者通常被集成在业务系统中，将业务...
主题（Topic）
本文介绍 云消息队列 RocketMQ 版 中主题（Topic）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 主题是 云消息队列 RocketMQ 版 中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题的作用主要如下：...
收发普通消息
普通消息是指阿里云 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时消息、顺序消息和事务消息。本文提供使用TCP协议下的社区版C++ SDK收发普通消息的示例代码供您参考。前提条件 安装CPP动态库 获取阿里云访问密钥AccessKey ...
- 产品推荐
- 这些文档可能帮助您