领域模型概述

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

消息发送重试和流控机制

若某些场景例如业务上新等需要回溯到指定时刻前开始消费,此时队列的存储压力会瞬间飙升,触发消息流控。服务端请求任务排队溢出:若消费者消费能力不足,导致队列中有大量堆积消息,当堆积消息超过一定数量后会触发消息流控,减少下游消费...

Demo工程

mqtt.ssl.demo.ios Demo使用须知 如果搭配使用 云消息队列 MQTT 版 和其他后端消息存储产品,如 云消息队列 RocketMQ 版,您需理解消息结构和属性映射关系,详细信息,请参见 MQTT与RocketMQ的消息结构映射。说明 各种开发语言的Demo程序...

Demo工程

mqtt.ssl.demo.ios Demo使用须知 如果搭配使用 云消息队列 MQTT 版 和其他后端消息存储产品,如 云消息队列 RocketMQ 版,您需理解消息结构和属性映射关系,详细信息,请参见 MQTT与RocketMQ的消息结构映射。说明 各种开发语言的Demo程序...

将云消息队列 Kafka 版的数据迁移至MaxCompute

本文介绍如何使用DataWorks数据同步功能,将 云消息队列 Kafka 版 集群上的数据迁移至阿里云大数据计算服务MaxCompute,方便您对离线数据进行分析加工。前提条件 在开始本教程前,确保您在同一地域中已完成以下操作:云消息队列 Kafka 版 ...

获取MQTT客户端在线状态

下文以 云消息队列 RocketMQ 版 作为后端存储消息队列的情况为例说明。操作步骤 创建上下线事件对应的Topic。您需关注哪些Group ID分组的设备,就在 云消息队列 MQTT 版 控制台创建对应的Topic。创建Topic的步骤请参见 MQTT快速入门。例如...

表格存储

表格存储(Tablestore)是阿里云自研的结构化数据存储,提供海量结构化数据存储以及快速的查询和分析服务。表格存储提供兼容HBase的WideColumn模型、消息模型Timeline以及时空模型Timestream,实现PB级存储、千万TPS以及毫秒级延迟的服务...

常见问题

Go 对象存储OSS使用Go语言实现签名Header上传的示例 Go错误处理 C#对象存储OSS使用C#语言实现签名Header上传的示例 C C错误处理 Android OSS Android SDK断点续传失败之后无法进入onFailure回调的问题 Android异常处理 Android常见问题 iOS...

为什么限制Topic总数(分区总数)?

Topic总数(分区总数)太多会使集群性能和稳定性能急剧下降。云消息队列 Kafka 版 的存储和协调机制是以分区为粒度的,分区数太多,会导致存储碎片化严重,集群性能和稳定性都会急剧下降。

创建RabbitMQ Source Connector

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

存储费用

包年包月和按量付费计费方式下,存储费用为 云消息队列 RocketMQ 版 的必选计费项,系统会根据实例的存储空间占用量进行计费。计费说明 项目 说明 计费公式 存储费用=存储空间×存储单价×存储时长 存储空间的值取计费周期(1小时)内起始...

在线教育视频直播

表格存储 表格存储(Tablestore)是阿里云自研的面向海量结构化数据存储的Serverless NoSQL多模型数据库,被广泛用于社交、物联网、人工智能、元数据和大数据等业务场景。提供兼容HBase的WideColumn模型、消息模型Timeline以及时空模型...

查询消息轨迹

支持查询的时间范围 由于消息在 云消息队列 RocketMQ 版 中存储的时间默认为3天,即只能查询当前时间起3天内的消息轨迹。例如,当前时间是2023年11月30日15:09:48,那么能查询到的消息轨迹最早的时间点为2023年11月27日15:09:48。消费状态...

消息存储和清理机制

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

基本概念

主题(Topic)云消息队列 RocketMQ 版 中消息传输和存储的顶层容器,用于标识同一类业务逻辑的消息。主题通过TopicName来做唯一标识和区分。更多信息,请参见 主题(Topic)。消息类型(MessageType)云消息队列 RocketMQ 版 中按照消息...

SDK概览

本文介绍表格存储包含的主流语言SDK。使用表格存储SDK前,您需要:了解并开通 阿里云表格存储服务。已获取AccessKey(包括AccessKey ID和AccessKey Secret)。具体操作,请参见 获取AccessKey。表格存储支持如下主流语言的SDK包。语言 参考...

功能概述

表格存储 面向海量结构化数据提供Serverless表存储服务,适用于海量账单、IM消息、物联网、车联网、风控、推荐等场景中的结构化数据存储,提供海量数据低成本存储、毫秒级的在线数据查询和检索以及灵活的数据分析能力。基本概念 在使用 ...

现代IM系统中的消息系统—模型

为了满足同步库和存储库对存储的不同要求,也提供了一些灵活的自定义配置,主要包括:配置 说明 Time to live(数据生命周期)可自定义数据生命周期,例如永久保存,或者保存N天。Storage type(存储类型)自定义存储类型,对存储库来说,...

Terraform

Terraform通过Provider支持新的基础架构,让您在阿里云上能够轻松使用简单模板语言来定义、预览和部署云基础结构。Terraform可以创建、修改和删除多种阿里云产品的相关资源,例如ECS、VPC、RDS和SLB等。关于阿里云与Terraform集成的更多...

MNS回调事件通知

推荐您按下述建议配置MNS消息队列的回调地域:如果视频保存在中国内地地域(如华北2、华东2等),建议使用 华东2(上海)地域的队列,推送消息到非 华东2(上海)地域的队列会存在较短时间的延迟。如果视频保存在其他地域(如新加坡、日本...

GetInstance-获取指定实例的详情

消息队列 RocketMQ 版的消息存储完全实现 Serverless 弹性,按照实际存储空间收取费用,您可以通过调整消息保存时长来控制消息的存储容量。更多信息,请参见 存储费用。72 supportAutoScaling boolean 实例是否支持开启规格外突发弹性能力...

作为Input接入

云消息队列 Kafka 版 可以作为Input接入Filebeat。本文说明如何在VPC环境下通过Filebeat从 云消息队列 Kafka 版 消费消息。背景信息 在开始本教程前,请确保您已完成以下操作:购买并部署 云消息队列 Kafka 版 实例。具体操作,请参见 VPC...

作为Input接入

云消息队列 Kafka 版 可以作为Input接入Filebeat。本文说明如何在公网环境下通过Filebeat从 云消息队列 Kafka 版 消费消息。背景信息 在开始本教程前,请确保您已完成以下操作:购买并部署 云消息队列 Kafka 版 实例。具体操作,请参见 ...

SDK列表

云消息队列 RabbitMQ 版 支持的多语言或框架SDK如 云消息队列 RabbitMQ 版支持的多语言或框架SDK 所示。表 2.云消息队列 RabbitMQ 版 支持的多语言或框架SDK 语言或框架 SDK C++ amqp-cpp-demo....

使用限制

云消息队列 Kafka 版 对某些具体指标进行了约束和规范,您在使用 云消息队列 Kafka 版 时注意不要超过相应的限制值,以免程序出现异常。重要 若由于您的实例配置超出使用限制导致的任何不稳定情况,不在SLA承诺和赔偿范围内。云消息队列 ...

控制台看到的最近消费时间是什么意思?

消息发布到 云消息队列 Kafka 版 服务器的存储时间。控制台看到的 最近消费时间 是指消息发布到 云消息队列 Kafka 版 服务器的存储时间。如果消费没有堆积,那么这个时间接近发送时间。

使用云消息队列 Kafka 版时客户端的报错及解决方案

报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权(sasl.mechanisms)失败 说明 该报错仅出现在 云消息队列 Kafka 版 的公网实例中。确保servers配置正确。通过 telnet 命令排除网络问题。如果网络...

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

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

概述

表格存储 表格存储(Tablestore)是阿里云自研的结构化数据存储,提供海量结构化数据存储以及快速的查询和分析服务,具备PB级存储、千万TPS以及毫秒级延迟的服务能力。云存储网关 云存储网关(Cloud Storage Gateway)是一款可以部署在用户...

创建资源

在调用TCP协议的SDK收发消息前,您需在 云消息队列 RocketMQ 版 控制台创建相关资源。您在调用SDK时需填写这些资源信息。前提条件 开通消息队列服务并授权 背景信息 针对TCP和HTTP两种通信协议,云消息队列 RocketMQ 版 分别提供了多语言...

创建资源

创建实例 实例是用于 云消息队列 RocketMQ 版 服务的虚拟机资源,会存储消息主题(Topic)和客户端ID(Group ID)信息。登录 云消息队列 RocketMQ 版 控制台。在左侧导航栏,单击 实例列表。在顶部菜单栏,选择地域,如 华东1(杭州)。在 ...

实例升降配

存储规格 不涉及 云消息队列 RocketMQ 版 的存储空间根据实际使用量按量付费,您可以随时调整消息存储时长来控制占用的存储空间。公网访问类型 支持 支持升配和降配。升配:开启公网访问。降配:关闭公网访问。公网流量带宽 支持 支持升配...

AMQP协议返回码

本文说明 云消息队列 RabbitMQ 版 客户端调用AMQP 0-9-1协议时的返回码,您可以根据返回信息与解决方案自助排查错误。返回码列表 返回码(reply-code)返回信息(reply-text)描述 解决方案 200 no route has mandatory 调用 basicPublish ...

在Knative上实现Kafka消息推送

Knative已支持Kafka事件源,您可将Knative与 云消息队列 Kafka 版 对接,在Knative上实现Kafka消息推送。前提条件 部署Knative 购买并部署 云消息队列 Kafka 版 实例 重要 云消息队列 Kafka 版 实例和Knative必须处于同一VPC内。云消息队列...

功能特性

表操作 Meta管理 Timeline管理 Queue管理 物联网存储 时序模型 表格存储的时序模型是针对时间序列数据的特点进行设计,适用于物联网设备监控、设备采集数据、机器监控数据等场景,支持自动构建时序元数据索引、丰富的时序查询能力等功能。...

DeleteTimeseriesAnalyticalStore

调用DeleteTimeseriesAnalyticalStore接口删除一个时序分析存储。...响应消息结构 message DeleteTimeseriesAnalyticalStoreResponse { } 使用SDK 您可以使用如下语言的SDK删除时序分析存储。Java SDK:删除分析存储 Go SDK:删除分析存储

配额与限制

云消息队列 RocketMQ 版 对实例的资源配额、实例规格和相关参数进行了约束和规范,您在使用 云消息队列 RocketMQ 版 时不要超过对应的限制值,避免应用出现异常。参数限制 以下参数中各资源的命名及备注等限制值不支持调整,请严格按照规范...

队列(MessageQueue)

队列的主要作用如下:存储顺序性 队列天然具备顺序性,即消息按照进入队列的顺序写入存储,同一队列间的消息天然存在顺序关系,队列头部为最早写入的消息,队列尾部为最新写入的消息。消息在队列中的位置和消息之间的顺序通过位点(Offset...

开发参考

本文介绍 云消息队列 RocketMQ 版 的SDK和API的支持情况,供您进行对应的开发操作。云消息队列 RocketMQ 版 消息收发需要通过调用SDK完成,云消息队列 RocketMQ 版 的SDK支持Java、C++、.NET、Go等多语言开发。SDK参考提供了各语言的SDK的...

OnsTopicStatus-查询Topic状态

427EE49D-D762-41FB-8F3D-9BAC96C3*Data object 查询到的 Topic 的信息存储数据结构。Perm integer 所有关系编号。取值说明如下:2:可以发布 4:可以订阅 6:可以发布和订阅 6 LastTimeStamp long 当前 Topic 内最新一条消息的就绪时间,...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
对象存储 云消息队列 RocketMQ 版 文件存储 CPFS 云消息队列 Kafka 版 弹性公网IP 短信服务
新人特惠 爆款特惠 最新活动 免费试用