完成数据订阅通道的配置后,您可以使用DTS提供的SDK示例代码来订阅数据变更信息,本文介绍该示例代码的使用说明。
准备工作
创建AccessKey并获取AccessKey ID和AccessKey Secret信息,详情请参见创建AccessKey。
操作步骤
本文以IntelliJ IDEA软件(Community Edition 2018.1.4 Windows版本)为例,介绍如何运行SDK示例代码来消费订阅数据。
- 根据订阅的数据源选择并下载SDK示例代码文件,然后解压该文件。
- 可选:定位至SDK示例代码解压的目录,使用文本编辑工具打开pom.xml文件,将数据订阅SDK的版本修改为最新版本。
- 打开IntelliJ IDEA软件,然后单击Open。
- 在弹出的对话框中,定位至SDK示例代码解压的目录,依次展开文件夹,找到项目对象模型文件:pom.xml。
- 在弹出对话框中,选择Open as Project。
- 在IntelliJ IDEA软件界面,依次展开文件夹,找到并双击打开对应的Java客户端文件。
- RDS MySQL:对应的文件为Main.java。

- DRDS:对应的文件为drds_demo.java。

- 设置Java客户端文件中的代码参数。
参数 |
说明 |
accessKey |
分别填写阿里云账号的AccessKey ID和AccessKey Secret信息,详情请参见准备工作。 |
accessSecret |
subscribeInstanceID |
填写数据订阅实例ID。您可以登录数据传输控制台,单击左侧导航栏的数据订阅,然后找到目标数据订阅实例ID。 |
- 在IntelliJ IDEA软件界面的顶部,选择运行该客户端。
说明 首次运行时,软件需要一定时间自动加载相关依赖包并完成安装。
执行结果
运行结果如下图所示,该客户端可正常订阅到源库的数据变更信息。