数据传输服务
有奖捉虫：办公协同&微信生态&物联网文档专题 HOT
文档中心 > 数据传输服务 > DTS 旧版本 > SDK 文档 > SDK 升级说明（旧版）

SDK 升级说明（旧版）

最近更新时间：2023-03-27 17:08:05

我的收藏

本页目录：

腾讯云数据订阅目前正在推动 API 2.0 接口下线。数据订阅 SDK 2.8.0 及以下版本，在鉴权时使用的是 API 2.0 接口，因此 API 2.0 接口下线后，SDK 2.8.0 及以下的版本使用将受到影响。
请及时按照如下方法升级您通过 SDK 进行消费的程序，避免受到 API 2.0 接口下线影响。
注意：
建议用户使用子账号密钥 + 环境变量的方式调用 SDK，提高 SDK 使用的安全性，子账号密钥获取可参考子账号访问密钥管理。为子账号授权时，请遵循最小权限指引原则，防止泄漏目标存储桶或对象之外的资源。
如果您一定要使用永久密钥，建议遵循最小权限指引原则对永久密钥的权限范围进行限制。

步骤1：确认 SDK 版本

确认您之前在 数据订阅 SDK 文档下载并已使用的 SDK 版本。 SDK 版本判断方法如下：
查看使用的 SDK 压缩包名：包名类似于binlogsdk-2.8.0-jar-with-dependencies.jar，其中包含了版本号信息。
查看 SDK_VERSION 版本号：若 SDK 包已被重命名，请使用解压命令unzip 将 SDK 包解压，再查看其中的tencentSubscribe.properties文件，SDK_VERSION标识了 SDK 版本号。
若数据订阅 SDK 版本为2.8.0及以下，请执行 步骤2。

步骤2：升级 SDK 版本

1. 在 数据订阅 SDK 下载最新的 SDK 版本，并替换2.8.0及以下版本的数据订阅 SDK。
2. 替换数据订阅 SDK 版本后，参考如下代码中“程序改动点”， 增加设置订阅 channel 所属 region 的一行代码即可。
package com.qcloud.biz;
import com.qcloud.dts.context.NetworkEnv;
import com.qcloud.dts.context.SubscribeContext;
import com.qcloud.dts.message.ClusterMessage;
import com.qcloud.dts.message.DataMessage;
import com.qcloud.dts.subscribe.ClusterListener;
import com.qcloud.dts.subscribe.DefaultSubscribeClient;
import com.qcloud.dts.subscribe.SubscribeClient;
import java.util.List;
public class Main {
    public static void main(String[] args) throws Exception {

        SubscribeContext context=new SubscribeContext();
        //用户 secretId、secretKey，建议使用子账号密钥，授权遵循最小权限指引，降低使用风险。子账号密钥获取可参考https://cloud.tencent.com/document/product/598/37140
        context.setSecretId("AKID-522dabxxxxxxxxxxxxxxxxxx");  
        context.setSecretKey("AKEY-0ff4cxxxxxxxxxxxxxxxxxxxx");
        /*****************程序改动点 BEGIN ****************/
        // API 2.0 接口下线后，如果不设置 region 参数，将会使用 API 2.0 做鉴权
        // API 2.0 下线后鉴权会失效，SDK 也不能正常使用。
        // 设置订阅 channel 所属的 region。
        context.setRegion("ap-chongqing");
        /*****************程序改动点 END ******************/


        //创建客户端
        SubscribeClient client=new DefaultSubscribeClient(context);
        //创建订阅 listener
        ClusterListener listener= new ClusterListener() {
            @Override
            public void notify(List<ClusterMessage> messages) throws Exception {
                //消费订阅到的数据
                for(ClusterMessage m:messages){
                    for(DataMessage.Record.Field f:m.getRecord().getFieldList()){
                        if(f.getFieldname().equals("id")){
                            System.out.println("seq:"+f.getValue());
                        }
                        DataMessage.Record record  = m.getRecord();
                    }
                    //消费完之后，确认消费
                    m.ackAsConsumed();
                }
            }
            @Override
            public void onException(Exception e){
                System.out.println("listen exception"+e);
            }};
        //添加监听者
        client.addClusterListener(listener);
        //设置请求的订阅通道
        client.askForGUID("dts-channel-r0M8kKsSyRZmSxQt");
        //启动客户端
        client.start();
    }
}

中国站