准备工作

创建AccessKey并获取AccessKey ID和AccessKey Secret信息，详情请参见创建AccessKey。

操作步骤

本文以IntelliJ IDEA软件（Community Edition 2018.1.4 Windows版本）为例，介绍如何运行SDK示例代码来消费订阅数据。

1. 下载SDK包（dts-subscribe-3.0.jar）。
2. 将dts-subscribe-3.0.jar添加到项目依赖中。
   1. 打开IntelliJ IDEA软件，单击File > New > Project，然后根据提示创建一个Maven项目。
   2. 单击File > Project Structure。
   3. 单击左侧的Modules，然后在页面右侧单击 > 1 JARs or directories。
   4. 根据提示选择下载的文件：dts-subscribe-3.0.jar，将其加入到项目依赖中。
      
3. 根据业务需求选择下述步骤，运行MongoDB或Redis的缓存示例代码。
   • 运行MongoDB缓存示例代码
     1. 双击打开左侧的pom.xml文件，将下述配置添加至该文件中。

        <dependencies>
            <dependency>
                <groupId>com.vividsolutions</groupId>
                <artifactId>jts</artifactId>
                <version>1.13</version>
            </dependency>
            <dependency>
                <groupId>org.mongodb</groupId>
                <artifactId>mongo-java-driver</artifactId>
                <version>3.2.0</version>
            </dependency>
        </dependencies>

     2. 保存并等待相关依赖包加载完成。
        说明 建议开启IntelliJ IDEA软件的Maven依赖自动更新功能。
     3. 在项目中新建一个名称为DTSMySQL2Mongo的Java Class文件。
     4. 下载MongoDB缓存示例代码。
     5. 将下载后的示例代码中的内容复制并替换至项目中新建的DTSMySQL2Mongo文件中。
     6. 修改项目中DTSMySQL2Mongo文件中代码，设置代码中各参数对应的值。

        参数	说明
        accessKey	分别填写阿里云账号的AccessKey ID和AccessKey Secret信息，详情请参见准备工作。
        accessSecret
        Subscription_Instance_ID	填写数据订阅实例ID。您可以登录数据传输控制台，单击左侧导航栏的数据订阅，然后找到目标数据订阅实例ID。
        mongUrl	填写MongoDB数据库的连接地址及鉴权数据库名，格式为<连接地址>:<服务端口>/<鉴权数据库名>，例如ds-bp********-pub.mongodb.rds.aliyuncs.com:3717/admin。
        mongUserName	填写MongoDB数据库的数据库账号。 说明 该数据库账号需具备目标数据库的读写权限。例如订阅的表所属的库名为testdata，程序获取到增量变更后会将数据写入至MongoDB数据库的testdata库中，因此该数据库账号需具备testdata库的读写权限。
        mongUserPassword	填写该数据库账号对应的密码。

     7. 在IntelliJ IDEA软件界面的顶部，单击Run > Run运行该程序。
   • 运行Redis缓存示例代码
     1. 双击打开左侧的pom.xml文件，将下述配置添加至该文件中。

        <dependencies>
            <dependency>
                <groupId>com.vividsolutions</groupId>
                <artifactId>jts</artifactId>
                <version>1.13</version>
            </dependency>
            <dependency>
                <groupId>redis.clients</groupId>
                <artifactId>jedis</artifactId>
                <version>2.7.2</version>
            </dependency>
        </dependencies>

     2. 保存并等待相关依赖包加载完成。
        说明 建议开启IntelliJ IDEA软件的Maven依赖自动更新功能。
     3. 在项目中新建一个名称为DTSMySQL2Redis的Java Class文件。
     4. 下载Redis缓存示例代码。
     5. 将下载后的示例代码中的内容复制并替换至项目中新建的DTSMySQL2Redis文件中。
     6. 修改项目中DTSMySQL2Redis文件中代码，设置代码中各参数对应的值。

        参数	说明
        accessKey	分别填写阿里云账号的AccessKey ID和AccessKey Secret信息，详情请参见准备工作。
        accessSecret
        Subscription_Instance_ID	填写数据订阅实例ID。您可以登录数据传输控制台，单击左侧导航栏的数据订阅，然后找到目标数据订阅实例ID。
        redisPassword	填写Redis数据库的数据库密码。 说明 如果Redis数据库设置了密码，您还需要将代码中的73行由 pool = new JedisPool(config, redisUrl, redisPort, 3000);修改为 pool = new JedisPool(config, redisUrl, redisPort, 3000,redisPassword)。
        redisPort	填写Redis数据库的服务端口，默认为6379。
        redisUrl	填写Redis数据库的连接地址（域名或IP地址）。

     7. 在IntelliJ IDEA软件界面的顶部，单击Run > Run运行该程序。
4. 等待程序运行，程序会获取源库的增量数据并将其写入至MongoDB或Redis数据库中。