全部产品
存储与CDN 数据库 域名与网站(万网) 应用服务 数加·人工智能 数加·大数据基础服务 互联网中间件 视频服务 开发者工具 解决方案 物联网 钉钉智能硬件
数据传输服务DTS

数据订阅 SDK 示例代码运行简介

更新时间:2017-11-29 17:28:19

本小节简单介绍如何运行 数据传输 DTS(以下简称 DTS)提供的多种数据变化订阅示例代码。

使用 Maven 依赖形式的 SDK

本小节简单介绍如何使用 DTS 提供的 Maven 依赖形式的 Demo。

下载 Demo

  1. 首先,需要先下载 使用 Maven 依赖 Demo
  2. 使用解压工具,解压下载到本地的 Demo。

运行 Demo

本小节以使用 Eclipse 为例,简单介绍如何运行 DTS 订阅 SDK Demo。

1. 在 Eclipse 中导入 Demo

在 Eclipse 中,点击菜单 File -> Import 操作入口。在弹出的窗口中,选择 Maven 下的 Existing Maven Projects,点击 Next。在 Import Maven Projects 窗口中,选择并导入上面解压后的 Demo。

2. 修改配置

DTS 提供的 demo 为上面项目中文件:src/main/java/com.aliyuncs.dts.demo/Main.java ,配置 Demo 中的下面三个参数:accessKey, accessSecret, subscribeInstanceID。其中:
accessKey、accessSecret 为订阅实例所属阿里云账号的 AccessKey 及 AccessSecret。(AccessKey/AccessSecret 的获取方式可以参考本文“如何获取 Access Key”章节)
subscribeInstanceID 为需要订阅数据的数据订阅实例 ID,需要到 数据传输 DTS 控制台 中获取。

订阅通道 ID

同时,建议将 pom.xml 文件中,指定的 DTS 订阅 SDK 版本修改为最新版本。最新版本的信息可以在 DTS 数据订阅 SDK 下载 中获取。

  1. <dependency>
  2. <groupId>com.aliyun.dts</groupId>
  3. <artifactId>dts-subscribe-sdk</artifactId>
  4. <version>4.8.2.12.2</version>
  5. </dependency>

3. 运行 Demo

上面的三个参数修改完成后,在 Eclipse 中右击 Main.java 文件 -> 运行方式 –> Java 应用程序,即成功运行示例 demo。

使用 JAR 包形式的 SDK

下载并载入 SDK Demo

DTS 提供的 JAVA SDK 支持的开发环境为:J2SE Development Kit (JDK) 1.5 或以上版本。

下面以 Eclipse 工程为例,简单介绍 SDK 的安装步骤:

  1. DTS 数据订阅 SDK 下载 页面下载 SDK 包
  2. 以下以 Eclipse 为例导入下载到的 jar 包:在 Eclipse 上右键点击工程 -> Properties -> Java Build Path -> Libraries -> Add External JARs,选择 JAR 包的存放路径,将下载到的 JAR 包添加到工程中。
  3. 选择 JAR 包,点击“OK”按钮,经过以上步骤,你就可以在工程中使用 DTS 订阅的 Java SDK 了。

运行 Demo

DTS 提供了 DTS SDK 的 Demo 示例,可以在 DTS 控制台的“查看示例代码”功能中复制这段示例代码。下面以 Eclipse 工程为例,简单介绍运行该 SDK Demo 的方式。

  1. 在 Eclipse 中,在上面新建的工程中新建类 MainClass。
  2. 打开生成的 Java 文件 MainClass,删除里面的代码模板。
  3. 将示例代码黏贴在文件 MainClass 中。
  4. 修改示例代码中的 AccessKeyID,AccessKeySecret,订阅通道 ID 三个配置项。

示例代码

其中,AccessKeyID/AccessKeySecret 为订阅实例所属阿里云账号的AccessKeyID/AccessKeySecret,订阅通道 ID 为需要订阅的数据订阅实例 ID,需要到 数据传输 DTS 控制台 中获取。

订阅通道 ID

5.在 Eclipse 中右击该 Demo 文件 -> 运行方式 –> Java 应用程序,即成功运行示例 Demo。

DRDS 订阅示例

本小节简单介绍如何使用 DTS 提供订阅 SDK 进行 分布式关系型数据库服务 DRDS(以下简称 DRDS) 的订阅。

下载 Demo

  1. 首先,需要先下载 DTS 订阅 DRDS 数据变化 Demo
  2. 使用解压工具,解压下载到本地的 Demo。

运行 Demo

本 Demo 的运行方式与 “使用 Maven 依赖形式的 SDK” 章节中 Demo 的运行方式基本相同,区别仅在于,订阅 DRDS 的数据变化时,由于 DRDS 有逻辑数据库和逻辑表的概念,区别与一般的数据库名和表名,因此需要通过对应的方式获取 DRDS 的逻辑数据库名和逻辑表名,可以参考 Demo 中如下代码片段。

  1. System.out.println("PrimaryKey Column Name:" + key);
  2. //DRDS 中物理数据库名和物理数据表名
  3. System.out.println("Record DB Name:"+record.getDbname()+",Table Name:"+record.getTablename());
  4. //DRDS 中逻辑数据库名和逻辑表名
  5. System.out.println("Record Logical DB Name:"+record.getLogicalDbname()+",Table Name:"+record.getLogicalTablename());

如何获取 Access Key

DTS 订阅 SDK 连接订阅通道时,需要通过阿里云账号的 Access Key 进行认证。所以在使用 SDK 之前,需要先创建 Access Key。本文简单介绍如何创建并获取 Access Key/Access Secret。
如果阿里云账号已经创建过 Access Key,那么不需要重新创建。如果未创建,那么具体操作步骤如下:

  1. 打开阿里云官网,登录您的阿里云账号。
  2. 将鼠标移动到左上角的账号上,在弹出的菜单中找到“accesskyes”。
  3. 点击“accesskyes”进入 AccessKey 的管理页面。

创建 AccessKey 的入口

4.根据页面指引创建你的 Access Key,并在 DTS 订阅 SDK 的配置中填入创建的 Access Key ID 和 Access Key Secret,从而使得 DTS 订阅能够获取到订阅数据。

本文导读目录