使用Spring Cloud框架收发消息

本文介绍如何使用Spring Cloud框架接入 云消息队列 Kafka 版 并收发消息。前提条件 安装1.8或以上版本JDK。安装2.5或以上版本Maven。下载 kafka-spring-stream-demo,并将其上传在准备好的Linux操作系统。确保您的 云消息队列 Kafka 版 ...

示例代码

重要 推荐您使用最新的RocketMQ 5.x系列SDK,5.x系列SDK作为主力研发版本,和 云消息队列 RocketMQ 版 5.x服务端完全兼容,提供了更全面的功能并支持更多增强特性。更多信息,请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...

原子计数器

原子计数操作只能作用在列值的最新版本,不支持对列值的特定版本做原子计数操作。更新完成后,原子计数操作会插入一个新的数据版本。接口 rowUpdateChange类中新增了原子计数器的操作接口,操作接口说明请参见下表。接口 说明 ...

原子计数器

原子计数操作只能作用在列值的最新版本,不支持对列值的特定版本做原子计数操作。更新完成后,原子计数操作会插入一个新的数据版本。接口 updateRow接口新增了原子计数器的相关操作,操作说明请参见下表。操作 说明 ...

授权信息

rocketmq:{#regionId}:{#accountId}:instance/{#InstanceId}/topic/{#TopicName} 无 无 资源(Resource)下表是 消息队列 MQ(RocketMQ)定义的资源,这些资源可以在RAM权限策略语句的 Resource 元素中使用,用来授予该资源执行具体操作...

节点分组

消息队列MQ):数据流转到MQ的Topic。调试转发 当 数据出口 为 阿里云物联网平台 时,出现此参数。用于控制调试开关。开:数据流转至基础Topic和物模型Topic。关:数据仅流转至物模型Topic。数据目的地 当 数据出口 为 阿里云物联网平台 ...

原子计数器

原子计数操作只能作用在列值的最新版本,不支持对列值的特定版本做原子计数操作。更新完成后,原子计数操作会插入一个新的数据版本。接口 rowUpdateChange类中新增了原子计数器的操作接口,操作接口说明请参见下表。接口 说明 ...

原子计数器

原子计数操作只能作用在列值的最新版本,不支持对列值的特定版本做原子计数操作。更新完成后,原子计数操作会插入一个新的数据版本。接口 updateRowChange类中新增了原子计数器的操作接口,操作接口说明请参见下表。接口 说明 ...

原子计数器

原子计数操作只能作用在列值的最新版本,不支持对列值的特定版本做原子计数操作。更新完成后,原子计数操作会插入一个新的数据版本。接口/*更新一行数据。api*@param[]$request 请求参数。return[]请求返回。throws OTSClientException 当...

消息队列MQTT版推送事件到函数计算

您可以通过 云消息队列 MQTT 版 的数据流出功能,将数据流转到 云消息队列 RocketMQ 版 的Topic中,并通过添加 事件总线EventBridge 的自定义事件源 云消息队列 RocketMQ 版,实现 云消息队列 MQTT 版 与 事件总线EventBridge 的集成。...

查询消息轨迹

消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数,例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等,并支持可视化查询。当消息收发结果不符合预期...

查看应用拓扑图

MQ消息队列),代表当前节点为 MQ 应用,不支持查看节点的监控概览信息。DB(数据库),代表当前节点为 DB 应用,不支持查看节点的监控概览信息。Cache(缓存),代表当前节点为缓存应用,不支持查看节点的监控概览信息。应用节点连线,...

消息队列RabbitMQ版

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

消息队列RocketMQ版

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

消息队列 MQTT 版

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

消息队列 RocketMQ 版

本文介绍如何在 云消息队列 RocketMQ 版 控制台创建消息流出任务,以实现将 云消息队列 RocketMQ 版 指定实例的数据流出至另外的 云消息队列 RocketMQ 版 实例中。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态...

消息队列 RabbitMQ 版

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

同步 OceanBase 数据库的数据至 RocketMQ

背景信息 消息队列 RocketMQ 是阿里云基于 Apache RocketMQ 构建的低延迟、高并发、高可靠的分布式消息中间件。数据传输的数据同步功能可以帮助您实现 OceanBase 数据库的物理表和 RocketMQ 数据源之间的数据实时同步,扩展消息处理能力。...

消息队列 RocketMQ 版

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

MetaQ数据源

DataWorks数据集成支持使用MetaQ Reader读取消息队列Message Queue(简称MQ)的数据,本文为您介绍DataWorks的MetaQ数据读取能力。支持的版本 MetaQ Reader通过消息队列服务的Java SDK订阅MetaQ中的实时消息数据,使用的Java SDK版本如下所...

同步 OceanBase 数据库的数据至 Kafka

分片的主要作用如下:负载均衡:在目标端可以进行并发写入的情况下,通过分片区分发送消息需要使用的特定线程。有序性:由于存在并发写入可能导致的无序问题,数据传输确保在分片的值相同的情况下,用户接收到的消息是有序的。此处的...

数据出口

Link WAN支持通过阿里云物联网平台流转数据,也支持用户自建云服务流转数据。数据出口至 物联网平台控制台,...节点分组N:1映射到产品设备列表 节点分组N:1映射到MQ消息队列的Topic 说明 N:1汇聚到消息队列MQ的Topic,数据流转至自建云服务

消息队列 RabbitMQ 版

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

消息队列 Kafka 版

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

队列(MessageQueue)

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

报警管理

如果您选择的 Group ID 在消费对应的 Topic 时产生了消息堆积,并且堆积超过了报警阈值,消息队列 MQ 就会给报警接收人发送短信通知。消费延迟阈值:消费延迟的值是指该 Group ID 最近一次消费该 Topic 消息的时间和该 Topic 最近一次投递...

消息队列Kafka版

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

同步 OceanBase 数据库的数据至 DataHub

分片的主要作用如下:负载均衡:在目标端可以进行并发写入的情况下,通过分片区分发送消息需要使用的特定线程。有序性:由于存在并发写入可能导致的无序问题,数据传输确保在分片的值相同的情况下,用户接收到的消息是有序的。此处的...

消息服务MNS

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

消息服务MNS

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

数据传输服务DTS

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

消息服务MNS

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

消息队列 RocketMQ 版

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

数据传输服务DTS

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

商业化服务条款

本服务条款是阿里云计算有限公司(以下简称“阿里云”)与您就消息队列服务(Message Queue,简称MQ)的相关事项所订立的有效合约。您通过盖章、网络页面单击确认或以其他方式选择接受本服务条款,包括但不限于未单击确认本服务条款而事实...

函数计算

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

函数计算

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

TagResources-为资源绑定标签

本接口一般在需要消息队列 RocketMQ 版的资源进行归类时使用,便于搜索和资源聚合。调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表...

创建FC Sink Connector

MQ_INST_115964845466*_ByBeUp3p Topic 选择生产 云消息队列 Kafka 版 消息的Topic。topic Group ID 选择源实例的消费组名称。请使用独立的消费组来创建事件源,不要和已有的业务混用消费组,以免影响已有的消息收发。GID_http_1 并发配额...

消息查询

消息队列 RocketMQ 版 提供了三种消息查询的方式,分别是按Message ID、Message Key以及Topic查询。您可以通过消息查询验证消息是否发送成功、验证消息发送的内容是否正确、以及进一步查看消息的轨迹信息。查询方式说明 由于消息在 云...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云消息队列 Kafka 版 云消息队列 RocketMQ 版 消息服务 云数据库 ClickHouse 全局事务服务 弹性公网IP
新人特惠 爆款特惠 最新活动 免费试用