新功能发布记录

如何恢复实例 2022-08-01 功能名称 功能描述 功能类型 相关文档 云消息队列 Kafka Serverless正式商业化消息队列 Kafka Serverless实例正式商业化使用。调整购买限制:单账号能购买的Serverless实例数量从1调整到100。支持地域为...

网络异常自动恢复

设置Vhost名称,请确保已在消息队列AMQP版控制台上创建。factory.setVirtualHost("${VhostName}");默认端口,非加密端口5672,加密端口5671。factory.setPort(5672);基于网络环境设置合理的超时时间。factory.setConnectionTimeout(30*1000...

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

MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息,云消息队列 MQTT 支持将该条消息数据导出至其他阿里云产品,并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的 云消息队列 RocketMQ 数据互通...

MQTT客户端上下线事件数据流出

此场景中,MQTT客户端产生上下线等状态变更,云消息队列 MQTT 版 会根据您配置的客户端状态通知规则,将状态变更封装后转发到 云消息队列 RocketMQ 消息的方式来实现客户端状态数据的聚合和统计。说明 针对其他场景,推荐您使用同步查询...

什么是云消息队列 Kafka

消息队列 Kafka 是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。云消息队列 Kafka 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域,已成为大数据生态中不可或缺的部分。产品优势 云消息队列 ...

SDK列表

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

获取MQTT客户端在线状态

应用场景 云消息队列 MQTT 需结合后端存储消息队列产品,如 云消息队列 RocketMQ 等使用,来和部署在云端服务器上的应用(下文简称为业务应用)完成业务流程。获取客户端在线状态主要的应用场景如下:主业务流程中需要根据客户端是否...

消息(Message)

消息持久消息队列 RocketMQ 会默认对消息进行持久,即将接收到的消息存储到 云消息队列 RocketMQ 服务端的存储文件中,保证消息的可回溯性和系统故障场景下的可恢复性。模型关系 在整个 云消息队列 RocketMQ 的领域模型中...

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

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

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

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

客户端证书认证

消息队列 MQTT 支持基于X.509证书的双向认证,分别通过服务器证书和设备证书完成服务端和客户端的认证,保证客户端和服务端通信链路的安全性和可靠性。本文介绍客户端证书认证的原理和流程。使用限制 仅铂金、专业实例支持双向...

MQTT与RocketMQ的消息结构映射

消息队列 RocketMQ 和 云消息队列 MQTT 的消息负载(Payload)均是您的业务消息的数据序列结果,云消息队列 RocketMQ 和 云消息队列 MQTT 不会对业务消息再做进一步的编解码处理。属性字段映射 目前,云消息队列 MQTT ...

消息队列 RocketMQ

本文介绍如何在 云消息队列 RabbitMQ 控制台创建消息流出任务,将 云消息队列 RabbitMQ 的数据导出至 云消息队列 RocketMQ 。前提条件 您已购买 云消息队列 RabbitMQ 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源...

通过RAM角色实现跨云账号授权

STS Token配置示例 初始消息队列 RocketMQ 的客户端时,您只需将获取到的AccessKey ID、AccessKey Secret和SecurityToken填入到以下属性中即可:Properties properties=new Properties();请确保环境变量ALIBABA_CLOUD_ACCESS_KEY_...

消息队列RabbitMQ版

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

概述

使用说明 社区SDK仅在开源RocketMQ迁移上云且不希望修改代码时使用,其他场景推荐您使用阿里云 云消息队列 RocketMQ 提供的商业版SDK进行接入。和社区SDK相比,商业版SDK提供了更加丰富的功能特性并具有更高的稳定性保障。更多信息...

SDK概述

消息队列 RabbitMQ 支持通过AMQP 0-9-1协议与JMS客户端收发消息。AMQP 0-9-1协议支持多语言SDK,而JMS仅支持Java SDK。RabbitMQ Client SDK列表 开源SDK接入指南(主账号与RAM账号场景)开源SDK接入指南(RAM角色跨账号授权场景)AMQP...

基于事件流实现RabbitMQ消息路由

本文介绍如何应用 事件总线EventBridge 的事件流功能实现 云消息队列 RabbitMQ 的消息路由。前提条件 您已 开通事件总线EventBridge并授权。您已购买并部署 云消息队列 RabbitMQ 实例,且实例处于 服务中 状态。具体步骤,请参见 ...

概述

使用说明 社区SDK仅在开源RocketMQ迁移上云且不希望修改代码时使用,其他场景推荐您使用阿里云 云消息队列 RocketMQ 提供的商业版SDK进行接入。和社区SDK相比,商业版SDK提供了更加丰富的功能特性并具有更高的稳定性保障。更多信息...

数据转发到AMQP服务端订阅消费组

直接使用AMQP服务端订阅实时获取设备数据,只能从产品维度获取所有设备的数据,使用消息转发的云产品流转功能,可以将全部设备或指定设备发送到物联网平台的消息,先经过SQL表达式处理和过滤,再转发到AMQP服务端订阅消费组,通过AMQP客户...

数据转发到AMQP服务端订阅消费组消费

直接使用AMQP服务端订阅实时获取设备数据,只能从产品维度获取所有设备的数据,使用消息转发的云产品流转功能,可以将全部设备或指定设备发送到物联网平台的消息,先经过解析脚本处理和过滤,再转发到AMQP服务端订阅消费组,通过AMQP客户端...

函数计算

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

实例支持

资源隔离优化(实例支持)云消息队列 RocketMQ 开放实例功能,解决多租户之间的隔离问题,您可以在同一个地域(Region)内购买多个实例,每个实例之间逻辑隔离或者物理隔离。云消息队列 RocketMQ 实例分为以下两种类型:标准:...

消息队列 MQTT

本文介绍如何在 云消息队列 RabbitMQ 控制台创建消息流入任务,将 云消息队列 MQTT 中的数据快速导入至 云消息队列 RabbitMQ 。前提条件 您已购买 云消息队列 RabbitMQ 实例,且实例处于 服务中 状态。具体步骤,请参见 创建...

使用AMQProxy解决PHP等客户端Connection复用问题

AMQP_URL 云消息队列 RabbitMQ 实例的URL。格式为 {amqp|amqps}:/{endpoint}。amqpAMQP协议。不使用SSL连接时使用。amqps:AMQP/SSL协议。使用SSL连接时使用。endpoint:云消息队列 RabbitMQ 实例的接入点。您可以在 云消息队列 ...

消息队列 Kafka

本文介绍如何在 云消息队列 RabbitMQ 控制台创建消息流入任务,将 云消息队列 Kafka 中的数据快速导入 云消息队列 RabbitMQ 。前提条件 您已购买 云消息队列 RabbitMQ 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源...

消息收发流程变更

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

HTTP SDK错误码列表

本文介绍使用 云消息队列 RocketMQ 提供的商业版HTTP协议的SDK收发消息时可能遇到的错误码,以及建议的处理方式。错误码 错误描述 HTTP状态码 建议处理方式 AccessDenied The OwnerId that your Access Key Id associated to is ...

资源使用变更

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

概述

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

计费常见问题

若您使用 云消息队列 MQTT 的数据流入、数据流出规则和 云消息队列 RocketMQ 进行通信,云消息队列 RocketMQ 会根据调用的 云消息队列 RocketMQ 的消息收发API或Topic资源等进行计费。客户端上线下事件流出到消息队列RocketMQ...

默认配置映射关系

映射关系如下:消息服务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 权限管理是通过阿里云的访问控制RAM(Resource Access Management)实现的。使用RAM可以让您避免与其他用户共享云账号密钥,即AccessKey(包含AccessKey ID和AccessKey Secret),按需为用户分配最小权限。本文介绍 云...

RAM鉴权

您可在 云消息队列 MQTT 控制台的 实例详情 页面获取绑定的持久实例的ID。mq:MqttInstanceAccess mq:RevokeToken QueryToken mq:MqttInstanceAccess mq:QueryToken ApplyToken mq:MqttInstanceAccess mq:ApplyToken CreateGroupId mq:...

步骤三:调用SDK收发消息

本文以Java SDK为例,说明如何将开源SDK客户端接入 云消息队列 RabbitMQ 服务端,并完成消息收发。前提条件 创建资源 安装IDEA 您可以使用IntelliJ IDEA或者Eclipse,本文以IntelliJ IDEA Ultimate为例。安装JDK 安装Maven 安装Java依赖...

Topic使用变更

消息队列 MQTT 从V2.x.x升级至V3.x.x后,实现了独立存储,Topic资源不再依赖于 云消息队列 RocketMQ ,因此两个产品的Topic将完全彼此独立。本文介绍两个版本中Topic资源控制台操作的差异并提供相应控制台截图进行对比。变更说明 ...

视频专区

本文为您介绍 云消息队列 RocketMQ 的操作视频。云消息队列 RocketMQ 5.x系列 快速使用 云消息队列 RocketMQ 5.x系列的Java SDK收发消息 云消息队列 RocketMQ 4.x系列 快速使用云消息队列 RocketMQ 4.x系列的Java SDK收发消息

消费者分组(ConsumerGroup)

本文介绍 云消息队列 RocketMQ 中消费者分组(ConsumerGroup)的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 消费者分组是 云消息队列 RocketMQ 系统中承载多个消费行为一致的消费者的负载均衡分组。和消费者...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云消息队列 Kafka 版 阿里邮箱 云消息队列 RocketMQ 版 商标服务 弹性公网IP 短信服务
新人特惠 爆款特惠 最新活动 免费试用