阿里通过消息队列实现-阿里通过消息队列实现文档介绍内容-阿里云

新零售电子价签解决方案（MQTT）

新零售电子价签解决方案由阿里云云消息队列 MQTT 版推出，通过MQTT以实现商场超市、公共场所电子标签、多媒体屏幕的数据更新管理。本文将以电子价签为例详细描述该解决方案的系统架构、数据流设计以及注意事项，其他类似行业可参考该方案...

收发事务消息

阿里云云消息队列 RocketMQ 版提供类似X/Open XA的分布式事务功能，通过阿里云云消息队列 RocketMQ 版事务消息，能达到分布式事务的最终一致。交互流程事务消息交互流程如下图所示。更多信息，请参见事务消息。前提条件安装CPP动态...

MQTT与RocketMQ的消息结构映射

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

消息收发功能

发送端和消费端的终端设备均通过开源的终端SDK接入云消息队列 MQTT 版 实现消息收发。典型场景示例即时通信：例如，两个安装有聊天App的移动手机直接通过云消息队列 MQTT 版服务端收发聊天信息。智能设备管理：例如，通过安装在手机上...

自动创建Topic

云消息队列 Kafka 版 通过阿里云控制台和OpenAPI管理Topic数据，目前不建议自动化创建Topic，主要原因如下：自动化创建Topic不能进行细粒度的权限管控、资源操作审计等，存在安全管控问题。自动化创建Topic会有资源远远超过限制、资源不能...

自动创建Topic

云消息队列 Kafka 版 通过阿里云控制台和OpenAPI管理Topic数据，不建议在生产环境中开启自动化创建Topic，主要原因如下：自动化创建Topic不能进行细粒度的权限管控、资源操作审计等，存在安全管控问题。自动化创建Topic会有资源远远超过...

自动化创建Topic相关问题

云消息队列 Kafka 版 通过阿里云控制台和OpenAPI管理Topic数据，目前不支持也不建议自动化创建Topic，主要原因如下：自动化创建Topic不能进行细粒度的权限管控、资源操作审计等，存在安全管控问题。自动化创建Topic会有资源远远超过限制、...

配置消息队列Kafka版实例的参数

本文为您介绍目标数据库实例为专线/VPN网关/智能网关方式接入的阿里云消息队列Kafka版时，部分特殊参数的配置方法和获取方式。注意事项使用此方案将阿里云消息队列Kafka版接入DTS，会将数据写入到您指定的节点中。若您的源库为MySQL...

消息查询

以方便您在无法正常收到消息情况下，可通过消息队列RocketMQ版控制台查询消息。不设置也不会影响消息正常收发。msg.setKey("TestKey"+System.currentTimeMillis());按 Topic 查询按Topic查询一般用在Message ID和Message Key都无法获得的...

开源对比

Group 创建方式云消息队列 Kafka 版控制台云消息队列 Kafka 版 OpenAPI 服务端自动创建（默认不开启）服务端自动创建云消息队列 Kafka 版默认通过阿里云控制台和OpenAPI管理 Group 数据，以实现细粒度的权限管控、资源操作审计、订阅...

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

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

权限策略

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

迁移上云概述

元数据迁移：通过读取源自建RocketMQ集群的元数据信息，并复制到目标阿里云云消息队列 RocketMQ 版集群中，实现元数据的创建和同步。消息迁移：通过云消息队列 RocketMQ 版自带的路由控制组件后台代理Topic路由信息，实现对客户端读写...

RAM鉴权

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

什么是云消息队列 MQTT 版

设备端通过云消息队列 MQTT 版可直接和云端的业务应用进行通信，也可和其他阿里云产品实现消息数据的跨产品互通。该模型的典型应用场景为智能设备的状态数据上报或云端控制应用的指令下发。终端与终端交互模型该模型适用于移动端App或者...

在线教育视频直播

场景描述适用于在线教育的视频直播场景，通过阿里云视频直播服务实现移动端的推拉流能力，同时移动端利用云消息队列 MQTT 版实现发送和接收消息，在消息转发时利用内容安全服务对消息内容进行审核。发送的消息可以存储在表格存储中。...

概述

请按需参见以下文档实现社区版SDK访问阿里云云消息队列 RocketMQ 版：社区版TCP协议Java SDK接入说明社区版TCP协议C++ SDK接入说明暂不支持通过社区版TCP协议的Go SDK和Python SDK访问阿里云云消息队列 RocketMQ 版，推荐您使用商业版...

消息收发流程变更

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

权限策略

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

ACL授权

ACL授权主要有两种方式：通过云消息队列 Confluent 版控制台实现ACL授权。本文详细介绍这一授权方式。使用Confluent CLI实现ACL授权。操作步骤，请参见使用Confluent CLI进行管理ACL。ACL授权登录云消息队列 Kafka 版控制台，在左侧...

正式商用公告

如果您有共享服务需求，可考虑阿里云 消息队列RocketMQ 或消息服务MNS 提供的按量付费共享服务。公测期间在所有地域（包括公网）创建的共享实例在2019年4月1日开始下线，于2019年5月底完成，届时共享实例将停止服务。请及时购买商用实例 ...

跨云产品的数据流出

云消息队列 RocketMQ 版实例版本仅4.0系列实例支持云消息队列 MQTT 版和云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时，云消息队列 RocketMQ 版仅4.0系列实例支持消息流入或流出规则，5.0系列实例不支持。...

RAM鉴权

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

跨云产品数据流入

云消息队列 RocketMQ 版实例版本仅4.0系列实例支持云消息队列 MQTT 版和云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时，云消息队列 RocketMQ 版仅4.0系列实例支持消息流入或流出规则，5.0系列实例不支持。...

数据流入规则管理

云消息队列 RocketMQ 版实例版本仅4.0系列实例支持云消息队列 MQTT 版和云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时，云消息队列 RocketMQ 版仅4.0系列实例支持消息流入或流出规则，5.0系列实例不支持。...

SDK列表

云消息队列 RabbitMQ 版 SDK（RAM角色跨账号授权场景）如果您是RAM STS角色授权的使用场景，需要通过云消息队列 RabbitMQ 版 SDK收发消息，该SDK只比开源SDK多一个加签依赖。云消息队列 RabbitMQ 版支持的多语言或框架SDK如云消息队列 ...

服务关联角色

AliyunServiceRoleForRMQMigration AliyunServiceRolePolicyForRMQMigration 云消息队列 RocketMQ 版通过扮演该RAM角色，获取访问专有网络VPC 的权限，以实现自建RocketMQ集群迁移上云的功能。策略内容 AliyunServiceRoleForOns 服务...

应用场景

本文为您介绍云消息队列 RabbitMQ 版的应用场景，以便您更好地判断如何在业务中使用云消息队列 RabbitMQ 版。异步解耦云消息队列 RabbitMQ 版可用于单体应用被拆解为微服务后不同微服务间的通信。应用解耦的好处是不同应用的迭代不再...

服务关联角色

云消息队列 RabbitMQ 版提供以下服务关联角色：AliyunServiceRoleForAmqpMonitoring：云消息队列 RabbitMQ 版通过扮演该RAM角色，获取云监控和阿里云应用实时监控服务ARMS的权限，以实现自身的监控报警和Dashboard功能。您在云消息队列 ...

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

部署架构图选用的产品云消息队列 Kafka 版云消息队列 Kafka 版是阿里云基于Apache Kafka构建的高吞吐量、高可扩展性的分布式消息队列服务，广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等，是大数据生态中不可或缺的...

队列（MessageQueue）

本文介绍云消息队列 RocketMQ 版中队列（MessageQueue）的定义、模型关系、内部属性、版本兼容性及使用建议。定义队列是云消息队列 RocketMQ 版中消息存储和传输的实际容器，也是云消息队列 RocketMQ 版消息的最小存储单元。云消息...

消息存活时间

设置方式云消息队列 RabbitMQ 版支持您通过以下方式设置消息存活时间：云消息队列 RabbitMQ 版控制台您可以通过云消息队列 RabbitMQ 版控制台为指定Queue设置消息存活时间。具体操作，请参见 Queue管理。OpenAPI Explorer 您可以通过...

延时消息

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

音视频通信解决方案（MQTT）

方案架构如方案架构所示，音视频管控服务和终端App之间通过阿里云消息队列产品完成信令传输，通过阿里云音视频通信RTC产品完成业务数据交互。详情可参见下文中的数据交互部分。方案优势音视频通信解决方案的优势如下所述：服务能力...

资源使用变更

云消息队列 MQTT 版从V2.x.x升级至V3.x.x实现了自身数据存储的能力，同时还去除了对云消息队列 RocketMQ 版的消息依赖，因此，云消息队列 MQTT 版的实例和Topic使用有变更。资源 V2.x.x使用说明 V3.x.x使用说明云消息队列 MQTT 版 ...

自由使用Group

注意事项在生产环境，长期开启自由使用Group的功能，可能会由于客户端使用不当出现资源随意使用，导致运维成本增加，并且极易造成系统不稳定，建议您通过云消息队列 Kafka 版控制台或者调用OpenAPI手动创建Group，进行统一管理。...

SDK FAQ

您需要通过Maven配置依赖库才能接入云消息队列 RabbitMQ 版收发消息。如何通过Maven配置依赖库来收发消息，请参见 JMS概述。JMS标准有哪些接口不支持？云消息队列 RabbitMQ 版支持 JMS 1.1。具体兼容的接口信息，请参见 JMS接口兼容性。...

DeleteCaCertificate-删除CA证书

云消息队列 MQTT 版支持X.509证书认证，客户端可通过设备证书完成接入认证。CA证书用于为客户端签发设备证书，并验证设备证书的正确性。使用CA证书需要先将证书注册到云消息队列 MQTT 版服务端，若您不再需要使用某个CA证书，您可以调用...

收发定时消息和延时消息

重要社区版的Apache RocketMQ和阿里云云消息队列 RocketMQ 版配置方式不同，实现效果也有所差异。社区版的Apache RocketMQ支持延时消息，但不支持定时消息，因此没有专门的定时消息接口。阿里云云消息队列 RocketMQ 版不仅同时支持...

云消息队列 Kafka 版服务等级协议

云消息队列 Kafka 版规定了阿里云向客户提供的阿里云云消息队列 Kafka 版的服务可用性等级指标及赔偿方案。如需查看云消息队列 Kafka 版的服务可用性等级指标及赔偿方案，请参见云消息队列 Kafka 版服务等级协议。

阿里通过消息队列实现

新品推荐