基于消息队列RocketMQ版实现全链路灰度

通过消息队列这类异步场景下的流量控制,您可以在不需要修改任何业务代码的情况下,实现全链路灰度。本文介绍MSE基于消息队列RocketMQ版实现全链路灰度。前提条件 开通MSE微服务治理。创建Kubernetes托管版集群。Demo架构 本文以容器服务...

开发场景:基于消息队列RocketMQ版实现环境隔离

本文介绍如何在 Serverless应用引擎SAE(Serverless App Engine)上基于阿里云 消息队列RocketMQ版 实现环境隔离,您可以在不修改任何业务代码的情况下,实现异步场景下的流量控制。背景信息 支持RocketMQ版本:4.2.0及以上版本。支持Pull...

产品概述

本文介绍 云消息队列 Kafka 版 的产品动态、产品简介及产品计费。云消息队列 Kafka 版 动态与公告 产品简介 产品计费 云消息队列 Confluent 版 什么是消息队列 Confluent 版?产品计费

领域模型概述

消息存储 主题(Topic):云消息队列 RocketMQ 版 消息传输和存储的分组容器,主题内部由多个队列组成,消息的存储和水平扩展实际是通过主题内的队列实现的。队列(MessageQueue):云消息队列 RocketMQ 版 消息传输和存储的实际单元容器,...

MQTT与RocketMQ的消息结构映射

消息队列 MQTT 版 是一款面向移动端的网关产品,可通过数据互通规则实现与其他阿里云产品,例如 云消息队列 RocketMQ 版 的交互。规则的详细信息,请参见 规则管理。如果单独使用 云消息队列 MQTT 版,则无需关注本文提供的映射关系,...

消息收发功能

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

计费常见问题

本文汇总了 云消息队列 RocketMQ 版 计费的常见问题。每天扣除2元,这是什么费用?我昨天删除了Topic,为什么今天会收到账单并被扣费?我没有使用 云消息队列 RocketMQ 版 服务,为什么会扣费?我在控制台上看到没有开通 云消息队列 ...

查看订阅关系

什么是订阅关系 云消息队列 RocketMQ 版 里的一个Group ID代表一个Consumer实例群组。对于大多数分布式应用来说,一个Group ID下通常会挂载多个Consumer实例。云消息队列 RocketMQ 版 的订阅关系主要由Topic+Tag共同组成,即一个Group ID下...

收发定时消息

以方便您在无法正常收到消息情况下,可通过消息队列RocketMQ版控制台查询消息并补发。注意:不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");deliver time单位ms,指定一个时刻,在这个时刻之后消息才能被消费,这个例子表示3s后...

定时/延时消息

功能原理 什么是定时消息 定时消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型,消息被发送至服务端后,在指定时间后才能被消费者消费。通过设置一定的定时时间可以实现分布式场景的延时调度触发效果。定时时间设置原则 云消息队列 ...

RAM主子账号授权

仅限有权限的RAM用户在 云消息队列 RocketMQ 版 的控制台上管理资源,以及通过SDK/API发布与订阅消息。应用场景 企业A购买了 云消息队列 RocketMQ 版 服务,企业A的员工需要操作这些服务所涉及的资源,例如实例、Topic或Group资源,有的...

收发定时消息

以方便您在无法正常收到消息情况下,可通过消息队列RocketMQ版控制台查询消息并补发。注意:不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");deliver time,单位:ms。指定一个时刻,在这个时刻之后消息才能被消费,这个例子表示...

基于Flink的资讯场景实时数仓

解决的问题 通过消息队列 Kafka 版 和实时计算Flink实现实时数据处理和数据流。通过消息队列 Kafka 版 和实时计算Flink实现实时数据分析。通过消息队列 Kafka 版 和实时计算Flink实现事件触发。部署架构图 选用的产品 云消息队列 ...

直播互动解决方案

背景信息 在直播互动的场景下,您需创建相应的数据互通规则实现消息队列 MQTT 版 与 云消息队列 RocketMQ 版 的数据互通,包含 数据流入规则、数据流出规则 以及 客户端上下线通知规则。使用 云消息队列 MQTT 版 的客户端收发消息时,...

顺序消息

功能原理 什么是顺序消息 顺序消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型,支持消费者按照发送消息的先后顺序获取消息,从而实现业务场景中的顺序处理。相比其他类型消息,顺序消息在发送、存储和投递的处理过程中,更多强调多...

什么是消息队列 Confluent 版?

本文介绍 云消息队列 Confluent 版 的定义。什么是Confluent Platform Confluent Platform是一个全面的数据流企业级平台,使您能够以连续、实时的流形式轻松访问、存储和管理数据。Confluent由Apache Kafka的原始创建者构建,通过企业级...

RAM鉴权

消息队列MQTT版权限管理是通过阿里云的访问控制RAM(Resource Access Management)产品实现的。使用RAM可以让您避免与其他用户共享云账号密钥,即AccessKey(包含AccessKeyId和AccessKeySecret),按需为用户分配最小权限。在使用RAM账号...

基本概念

本文介绍 云消息队列 RocketMQ 版 的基本概念,以便您更好地理解和使用 云消息队列 RocketMQ 版。主题(Topic)云消息队列 RocketMQ 版 中消息传输和存储的顶层容器,用于标识同一类业务逻辑的消息。主题通过TopicName来做唯一标识和区分。...

权限策略

消息队列 MQTT 版 权限管理是通过阿里云的访问控制RAM(Resource Access Management)实现的。使用RAM可以让您避免与其他用户共享云账号密钥,即AccessKey(包含AccessKey ID和AccessKey Secret),按需为用户分配最小权限。本文介绍 云...

基本概念

更多信息,请参见 什么是消息队列 Kafka 版?ZooKeeper 一款开源的分布式应用程序协调服务。在 云消息队列 Kafka 版 中,ZooKeeper主要用于集群管理、配置管理、Leader选举。ZooKeeper是 云消息队列 Kafka 版 的一部分,您无需感知...

什么是消息队列 RocketMQ 版?

什么选择云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 基于阿里云云原生优质的基础设施实现,兼容Apache RocketMQ的核心API和功能。相对于自建RocketMQ集群,云消息队列 RocketMQ 版 具有如下优势:架构先进性 全面采用存储和计算分离...

授权信息

本文为您介绍 消息队列Kafka版(AliKafka)为RAM权限策略定义的操作(Action)、资源(Resource)和条件(Condition)。消息队列Kafka版(AliKafka)的RAM代码(RamCode)为 alikafka,支持的授权粒度为 RESOURCE。权限策略通用结构 权限...

授权信息

本文为您介绍 消息队列 MQ(Ons)为RAM权限策略定义的操作(Action)、资源(Resource)和条件(Condition)。消息队列 MQ(Ons)的RAM代码(RamCode)为 mq,支持的授权粒度为 RESOURCE。权限策略通用结构 权限策略支持JSON格式,其通用...

消息收发流程变更

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

顺序消息

什么是顺序消息 顺序消息是 云消息队列 RocketMQ 版 提供的一种对消息发送和消费顺序有严格要求的消息。对于一个指定的Topic,消息严格按照先进先出(FIFO)的原则进行消息发布和消费,即先发布的消息先消费,后发布的消息后消费。顺序消息...

函数计算

本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已开通函数计算服务,具体...

是否支持优先级队列

消息队列 RabbitMQ 版 不支持优先级队列。云消息队列 RabbitMQ 版 内部暂未实现消息优先级的处理逻辑,您的客户端通过可选队列参数 x-max-priority 声明的优先级队列实际是无效的。

是否支持优先级队列

消息队列 RabbitMQ 版 不支持优先级队列。云消息队列 RabbitMQ 版 内部暂未实现消息优先级的处理逻辑,您的客户端通过可选队列参数 x-max-priority 声明的优先级队列实际是无效的。

发布者最佳实践

消息队列 Kafka 版 Producer允许通过设置Partitioner的实现类来选择适合自己业务的分区。在消息指定Key的情况下,云消息队列 Kafka 版 Producer的默认策略是对消息的Key进行哈希,然后根据哈希结果选择分区,保证相同Key的消息会发送到同...

延时消息

如果您希望消息被投递后延迟一段时间被消费者消费,您可以使用 云消息队列 RabbitMQ 版 的延时消息。云消息队列 RabbitMQ 版 原生支持延时消息,使用方式比开源RabbitMQ更简单。什么是延时消息 延时消息是指在指定时间段之后才被消费者消费...

函数计算

本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已开通函数计算服务,具体...

产品功能

说明 云消息队列 RabbitMQ 版 内部暂未实现消息优先级的处理逻辑,您的客户端通过可选队列参数 x-max-priority 声明的优先级队列实际是无效的。Exchange:支持将消息按照规则路由到一个或多个Queue,同时对不符合路由规则的消息进行丢弃。...

收发事务消息

以方便您在无法正常收到消息情况下,可通过消息队列RocketMQ版控制台查询消息并补发。注意:不设置也不会影响消息正常收发。msg.setKey("ORDERID_100");发送消息,只要不抛出异常,就代表发送成功。try {/消息队列RocketMQ版不负责...

创建FC Sink Connector

本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为函数计算的消息流出任务。前提条件 您已购买并部署 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:购买和部署实例。您已开通函数计算服务,...

主题(Topic)

本文介绍 云消息队列 RocketMQ 版 中主题(Topic)的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 主题是 云消息队列 RocketMQ 版 中消息传输和存储的顶层容器,用于标识同一类业务逻辑的消息。主题的作用主要如下:...

队列(MessageQueue)

在 云消息队列 RocketMQ 版 消息收发模型中,队列属于主题的一部分,虽然所有的消息资源以主题粒度管理,但实际的操作实现是面向队列。例如,生产者指定某个主题,向主题内发送消息,但实际消息发送到该主题下的某个队列中。云消息队列 ...

迁移概述

借助工具迁移 迁移工具 迁移工具 说明 参考文档 kafka-migration-assessment.jar 您可以使用该工具将自建Kafka集群元数据通过控制台任务导出为JSON格式文件,然后上传该文件至 云消息队列 Kafka 版 迁移任务并运行任务,实现元数据迁移。...

将云消息队列 Kafka 版接入阿里云Elasticsearch

当您需要查看并分析庞杂的日志数据时,可通过阿里云Logstash将 云消息队列 Kafka 版 中的日志数据导入阿里云Elasticsearch,然后通过Kibana进行可视化展示与分析。本文介绍将 云消息队列 Kafka 版 接入阿里云Elasticsearch的操作方法。前提...

权限策略

消息队列 MQTT 版 权限管理是通过阿里云的访问控制RAM(Resource Access Management)实现的。使用RAM可以让您避免与其他用户共享云账号密钥,即AccessKey(包含AccessKey ID和AccessKey Secret),按需为用户分配最小权限。本文介绍 云...

开源RabbitMQ迁移上云概述

迁移原理 对于消息队列来说,如果要实现集群迁移,只需消费完旧集群的消息即可。由于Producer和Consumer都是集群化的,您可以通过一台一台操作的方式实现上层业务无感知。迁移流程(双读模式)创建 云消息队列 RabbitMQ 版 实例。更多信息...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云消息队列 Kafka 版 云消息队列 RocketMQ 版 阿里邮箱 弹性公网IP 商标服务 短信服务
新人特惠 爆款特惠 最新活动 免费试用