765      iPhone_iPad_Mac_手機_平板_蘋果apple

SDK快速入門__數據訂閱_用戶指南_數據傳輸-阿裏雲

這一節，您將學到如何用DTS Java SDK完成一些基本的操作。

初始化RegionContext

RegionContext 主要用於保存設置安全認證信息及訪問網絡模式設置。下麵代碼顯示如何初始化RegionContext，設置安全認證憑證及網絡訪問模式。

import java.util.List;
import com.aliyun.drc.clusterclient.RegionContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class MainClass
{
   public static void main(String[] args) throws Exception {
      // 創建一個RegionContext
      RegionContext context = new RegionContext();
      // 配置阿裏雲賬號的AccessKey及AccessKeySecret
      context.setAccessKey("<AccessKey>");
      context.setSecret("<AccessKeySecret>");
       // 運行SDK的服務器是否使用公網IP連接DTS訂閱通道
      context.setUsePublicIp(true);
     // 下麵為其他調用代碼 ……
        …………
    }
}

如果要使用SDK，必須先初始化RegionContext，配置連接訂閱通道的安全認證等信息。上麵的接口setAccessKey設置的是阿裏雲賬號的AccessKey
setSecret 設置的是阿裏雲賬號的AccessKeySecret
AccessKey及AccessKeySecret是由阿裏雲的係統直接分配給用戶的，稱為ID對，用戶標識用戶，可到阿裏雲用戶中心創建獲取。
setUsePublicIp 是告訴DTS，您本地SDK運行服務器是否用公網IP連接訂閱通道。如果設置為true，那麼訂閱數據流走公網，否則走內網。

初始化ClusterClient

SDK連接訂閱通道，接受增量數據等操作都是通過類ClusterClient來完成的，下麵代碼創建了一個ClusterClient

import java.util.List;
import com.aliyun.drc.clusterclient.ClusterClient;
import com.aliyun.drc.clusterclient.DefaultClusterClient;
import com.aliyun.drc.clusterclient.RegionContext;
public class MainClass
{
      public static void main(String[] args) throws Exception {
        // 創建一個RegionContext
          RegionContext context = new RegionContext();
          context.setAccessKey("<AccessKey>");
          context.setSecret("<AccessKeySecret>");
          context.setUsePublicIp(true);
          // 創建訂閱消費者
          final ClusterClient client = new DefaultClusterClient(context);
          // 下麵是一些其他調用代碼
          ……………
    }
}

import com.aliyun.drc.clusterclient.ClusterClient;
import com.aliyun.drc.clusterclient.ClusterListener;
import com.aliyun.drc.clusterclient.DefaultClusterClient;
import com.aliyun.drc.clusterclient.RegionContext;
import com.aliyun.drc.clusterclient.message.ClusterMessage;
public class MainClass
{
    public static void main(String[] args) throws Exception {
        // 初始化一個RegionContext對象
        ………
        //初始化一個ClusterClient對象
        ………
        ClusterListener listener = new ClusterListener(){
             @Override
             public void notify(List<ClusterMessage> messages) throws Exception {
                  for (ClusterMessage message : messages) {  
                    //打印訂閱到的增量數據
                      System.out.println(message.getRecord() + ":" + message.getRecord().getTablename() + ":"
                      + message.getRecord().getOpt());  
                      //消費完數據後向DTS匯報ACK，必須調用
                      message.ackAsConsumed();
              }
      }
     }
}

import java.util.List;
import com.aliyun.drc.clusterclient.ClusterClient;
import com.aliyun.drc.clusterclient.ClusterListener;
import com.aliyun.drc.clusterclient.DefaultClusterClient;
import com.aliyun.drc.clusterclient.RegionContext;
import com.aliyun.drc.clusterclient.message.ClusterMessage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class MainClass
{
   public static void main(String[] args) throws Exception {
    //初始化RegionContext
    …………
    //初始化ClusterClient
    …………
    //初始化ClusterListener
    …………
    // 添加監聽者
      client.addConcurrentListener(listener);
      // 設置請求的訂閱通道ID
      client.askForGUID("dts_rdsrjiei2u2afnb_DSF");
      // 啟動後台線程， 注意這裏不會阻塞， 主線程不能退出
      client.start();
}