使用Canal和RocketMQ实现数据库变更订阅处理

本文以MySQL数据库为例介绍如何使用Canal入 云消息队列 RocketMQ 版,实现MySQL数据库Binlog数据的变更处理。背景信息 CDC(Change Data Capture)是一种监测并捕获数据库变更的典型技术方案,常应用于异构数据源之间的数据同步。Canal...

使用Canal和RocketMQ实现数据库变更订阅处理

本文以MySQL数据库为例介绍如何使用Canal入 云消息队列 RocketMQ 版,实现MySQL数据库Binlog数据的变更处理。背景信息 CDC(Change Data Capture)是一种监测并捕获数据库变更的典型技术方案,常应用于异构数据源之间的数据同步。Canal...

签名机制

MQVersion:表示 云消息队列 RocketMQ 版 接口的版本号,当前版本即为2015-06-06。CanonicalizedResource:表示HTTP所请求资源的URI(统一资源标识符),如消费请求的URI/topics/abc/messages?consumer=GID_abc。说明 用来签名的字符串为...

SDK参考概述

SDK兼容性说明 云消息队列 RocketMQ 版 服务端版本和客户端SDK版本的兼容情况如下,为了获得更完善的产品功能和更高的性能,建议您使用5.x版本实例,并优先通过RocketMQ 5.x系列SDK入服务端。服务端版本 客户端版本 兼容性 约束限制 5.x...

使用须知

请参见:Java SDK版本说明 Go SDK版本说明 Python SDK版本说明 Node.js SDK版本说明 PHP SDK版本说明 C#SDK版本说明 C++ SDK版本说明 注意事项 支持HTTP协议SDK入为 云消息队列 RocketMQ 版 商业版的增强功能,开源自建RocketMQ集群不...

功能与特性概述

本文列举 云消息队列 RocketMQ 版 所支持的所有功能与特性。概览 云消息队列 RocketMQ 版 在阿里云多个地域(Region)提供了高可用消息云服务。单个地域内采用多机房部署,可用性极高,即使整个机房都不可用,仍然可以为应用提供消息发布...

SDK参考概述

SDK兼容性说明 云消息队列 RocketMQ 版 服务端版本和客户端SDK版本的兼容情况如下:服务端版本 客户端版本 兼容性 约束限制 5.x版本实例 RocketMQ 5.x SDK 兼容 云消息队列 RocketMQ 版 5.x版本实例的所有功能完全支持。RocketMQ 4.x/3.x ...

4.x和5.x版本差异及兼容性说明

云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布,阿里云 云消息队列 RocketMQ 版 将为您提供更加稳定可靠的服务端5...

4.x和5.x版本差异及兼容性说明

云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布,阿里云 云消息队列 RocketMQ 版 将为您提供更加稳定可靠的服务端5...

快速入门概述

本文为您介绍如何快速使用 云消息队列 RocketMQ 版 实现消息收发。使用流程 快速使用 云消息队列 RocketMQ 版 收发消息的流程如下图所示。使用说明 权限说明 若您的账号为RAM用户,则必须先为该RAM用户进行授权,才能访问 云消息队列 ...

云消息队列 RocketMQ

RocketMQ_RocketMQ_Transform_Customized_1688540172662 函数模版 选择函数模板。当 消息体(body)选择 数据清洗 且选择 新建函数模板 时,需要配置该参数。内容分割:根据正则表达式对消息内容进行分割,将分割后的消息逐条发送至目标。...

公网流量定价详情

云消息队列 RocketMQ 版 提供公网入点和VPC入点用于客户端入 云消息队列 RocketMQ 版 实例。使用公网入点入 云消息队列 RocketMQ 版 服务时需要收取公网流量费用。本文介绍公网流量费用的计费规则。支持地域 仅如下地域支持使用...

收发普通消息

普通消息是指 云消息队列 RocketMQ 版 中无特性的消息,区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的PHP SDK收发普通消息的示例代码。前提条件 您已完成以下操作:安装PHP SDK。更多信息,请参见 准备环境...

消息队列RocketMQ版

数据清洗 服务及函数名称 默认创建名称为 RocketMQ_RocketMQ_Transform_<TemplateName>_的服务和函数。当 消息体(body)选择 数据清洗 且选择 新建函数模板 时,需要配置该参数。RocketMQ_RocketMQ_Transform_Customized_1688540172662 ...

消息队列RocketMQ版

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

收发顺序消息

顺序消息(FIFO消息)是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的PHP SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类:全局顺序:对于指定的一个Topic,所有消息按照严格...

收发定时消息和延时消息

背景信息 延时消息:Producer将消息发送到 云消息队列 RocketMQ 版 服务端,但并不期望立马投递这条消息,而是延迟一定时间后才投递到Consumer进行消费,该消息即延时消息。定时消息:Producer将消息发送到 云消息队列 RocketMQ 版 服务端...

云消息队列 RocketMQ

RocketMQ_RocketMQ_Transform_Customized_1688540172662 函数模版 选择函数模板。当 消息体(body)选择 数据清洗 且选择 新建函数模板 时,需要配置该参数。内容分割:根据正则表达式对消息内容进行分割,将分割后的消息逐条发送至目标。...

迁移上云概述

和开源Apache RocketMQ相比,阿里云 云消息队列 RocketMQ 版 具有更高的稳定性、安全性及更完善的运维体系。您可以将开源RocketMQ集群迁移到 云消息队列 RocketMQ 版 上以获得更好的业务体验,本文为您介绍开源RocketMQ集群迁移上云的方案...

功能发布列表

本文介绍了 云消息队列 RocketMQ 版 每次发布涉及的新增功能、功能优化、重要问题修复及对应的文档,帮助您了解 云消息队列 RocketMQ 版 的发布动态。2023-10-24 实例系列 功能名称 功能描述 变更类型 相关文档 5.x系列实例 Serverless实例...

微消息队列MQTT版

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

顺序消息

本文介绍 云消息队列 RocketMQ 版 顺序消息的概念、适用场景、实现原理以及使用过程中的注意事项。什么是顺序消息 顺序消息是 云消息队列 RocketMQ 版 提供的一种对消息发送和消费顺序有严格要求的消息。对于一个指定的Topic,消息严格按照...

快速入门

如果您是首次使用 云消息队列 RocketMQ 版,您可以参考快速入门文档,了解如何购买实例并入 云消息队列 RocketMQ 版 服务端完成基本的消息收发流程。使用流程 快速使用 云消息队列 RocketMQ 版 收发消息的流程如下图所示。详细操作,请...

收发事务消息

云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。本文提供使用HTTP协议下的PHP SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示。更...

消息队列Kafka版

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

云消息队列 MQTT 版

RocketMQ_RocketMQ_Transform_Customized_1688540172662 函数模版 选择函数模板。当 消息体(body)选择 数据清洗 且选择 新建函数模板 时,需要配置该参数。内容分割:根据正则表达式对消息内容进行分割,将分割后的消息逐条发送至目标。...

云消息队列 RabbitMQ 版

RocketMQ_RocketMQ_Transform_Customized_1688540172662 函数模版 选择函数模板。当 消息体(body)选择 数据清洗 且选择 新建函数模板 时,需要配置该参数。内容分割:根据正则表达式对消息内容进行分割,将分割后的消息逐条发送至目标。...

基本概念

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

应用场景

本文为您介绍 云消息队列 RocketMQ 版 的应用场景,以便您更好地判断如何在业务中使用 云消息队列 RocketMQ 版。例如,针对一家互联网电商企业,其业务涉及广泛,如注册、订单、库存、物流等;同时,也会涉及许多业务峰值时刻,如秒杀活动...

数据传输服务DTS

RocketMQ_RocketMQ_Transform_Customized_1688540172662 函数模版 选择函数模板。当 消息体(body)选择 数据清洗 且选择 新建函数模板 时,需要配置该参数。内容分割:根据正则表达式对消息内容进行分割,将分割后的消息逐条发送至目标。...

消息服务MNS

RocketMQ_RocketMQ_Transform_Customized_1688540172662 函数模版 选择函数模板。当 消息体(body)选择 数据清洗 且选择 新建函数模板 时,需要配置该参数。内容分割:根据正则表达式对消息内容进行分割,将分割后的消息逐条发送至目标。...

消息队列RabbitMQ版

数据清洗 服务及函数名称 默认创建名称为 RocketMQ_RocketMQ_Transform_<TemplateName>_的服务和函数。当 消息体(body)选择 数据清洗 且选择 新建函数模板 时,需要配置该参数。RocketMQ_RocketMQ_Transform_Customized_1688540172662 ...

开发参考

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

云消息队列 Kafka 版

RocketMQ_RocketMQ_Transform_Customized_1688540172662 函数模版 选择函数模板。当 消息体(body)选择 数据清洗 且选择 新建函数模板 时,需要配置该参数。内容分割:根据正则表达式对消息内容进行分割,将分割后的消息逐条发送至目标。...

消息服务MNS

RocketMQ_RocketMQ_Transform_Customized_1688540172662 函数模版 选择函数模板。当 消息体(body)选择 数据清洗 且选择 新建函数模板 时,需要配置该参数。内容分割:根据正则表达式对消息内容进行分割,将分割后的消息逐条发送至目标。...

OnsInstanceDelete-删除实例

调用OnsInstanceDelete接口删除云消息队列 RocketMQ 版实例。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API,用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成,消息收发的核心数据链路中严禁依赖 OpenAPI 实现,否则可能...

Demo工程

public static final String NAMESRV_ADDR="您的阿里云RocketMQ实例的TCP入点,在控制台实例详情页面的入点页签获取;说明 创建AccessKey(包括AccessKeyId和AccessKeySecret)的具体步骤,请参见 创建AccessKey。如果RAM子账号拥有该...

数据传输服务DTS

RocketMQ_RocketMQ_Transform_Customized_1688540172662 函数模版 选择函数模板。当 消息体(body)选择 数据清洗 且选择 新建函数模板 时,需要配置该参数。内容分割:根据正则表达式对消息内容进行分割,将分割后的消息逐条发送至目标。...

收发事务消息

设置为阿里云消息队列RocketMQ版实例的入点。consumer.setNamesrvAddr("http://xxxx.mq-internet.aliyuncs.com:80");阿里云上消息轨迹需要设置为CLOUD方式,在使用云上消息轨迹的时候,需要设置此项,如果不开启消息轨迹功能,则运行不...

消费者(Consumer)

本文介绍 云消息队列 RocketMQ 版 中消费者(Consumer)的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 消费者是 云消息队列 RocketMQ 版 中用来接收并处理消息的运行实体。消费者通常被集成在业务系统中,从 云消息...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
视频直播 智能接入网关 云数据库 RDS 物联网无线连接服务 高速通道 弹性公网IP
新人特惠 爆款特惠 最新活动 免费试用