数据传输服务 DTS：通过数据订阅实现缓存更新策略

操作步骤

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

1. 下载数据订阅SDK示例代码文件，然后解压该文件。

2. 使用IntelliJ IDEA软件，以Maven工程打开解压后的SDK示例代码文件。

3. 在/subscribe-demo/src/main/java/com/alibaba/dts/demo/路径下，双击打开DTSMySQL2RedisDemo.java文件。

4. 修改main函数中的参数。

   需要修改如下图所示的绿色字体，例如String brokerUrl = "your broker url";中的your broker url。

   • 数据订阅任务参数

     参数	说明	获取方式
     brokerUrl	数据订阅通道的网络地址及端口号信息。 说明 如果您部署SDK客户端所属的ECS实例与数据订阅通道属于经典网络或同一专有网络，建议通过内网地址进行数据订阅，网络延迟最小。 不建议使用公网地址。	在DTS控制台单击目标订阅实例ID，在基本信息页面的网络区域，您可以获取网络地址及端口号信息。
     topic	数据订阅通道的订阅Topic。	在DTS控制台单击目标订阅实例ID，在基本信息页面的基本信息区域，您可以获取到订阅Topic。
     sid	消费组ID。	在DTS控制台单击目标订阅实例ID，然后单击数据消费，您可以获取到消费组ID和消费组的账号信息。 说明 消费组账号的密码已在您新建消费组时指定。
     userName	消费组的账号。 警告 如您未使用本文提供的客户端，请按照<消费组的账号>-<消费组ID>的格式设置用户名（例如：dtstest-dtsae******bpv），否则无法正常连接。
     password	该账号的密码。
     initCheckpoint	消费位点，即SDK客户端消费第一条数据的时间戳，格式为Unix时间戳，例如1620962769。 说明 消费位点信息可用于： 当业务程序中断后，传入已消费位点继续消费数据，防止数据丢失。 在订阅客户端启动时，传入所需的消费位点，调整订阅位点，实现按需消费数据。	消费位点必须在订阅实例的数据范围（如图示）之内，并需转化为Unix时间戳。 说明 Unix时间戳转换工具可用搜索引擎获取。
     ConsumerContext.ConsumerSubscribeMode subscribeMode	SDK客户端的使用模式，取值为： ConsumerContext.ConsumerSubscribeMode.ASSIGN：ASSIGN模式，即一个消费组下仅支持一个SDK客户端消费订阅数据。 ConsumerContext.ConsumerSubscribeMode.SUBSCRIBE：SUBSCRIBE模式，即支持在同一个消费组下同时启动多个SDK客户端实现灾备。	无

   • 目标Redis实例参数

     参数	说明	获取方式
     redisUrl	Redis实例的网络地址信息。	进入Redis实例的实例信息页签，在连接信息区域获取公网访问的连接地址。
     redisPort	Redis实例的端口信息。	进入Redis实例的实例信息页签，在连接信息区域获取公网访问的端口号（Port）。
     redisPassword	消Redis实例的账号及密码。 重要 数据库密码格式为<user>:<password>。例如，Redis实例自定义的用户名为admin，密码为Rp829dlwa，则此处填入的数据库密码为admin:Rp829dlwa。	在您创建Redis实例时已指定。 说明 若您忘记密码，可以重新设置实例的密码，详情请参见修改或重置密码。

5. 在IntelliJ IDEA软件界面的顶部，单击Run > Run运行该程序。