使用数据订阅SDK

新建Demo文件

import com.bce.dts.consumer.ConsumerClient;
    import com.bce.dts.consumer.ConsumerClientImpl;
    import com.bce.dts.consumer.ConsumerListener;
    import com.bce.dts.consumer.RegionContext;
    import com.bce.dts.model.DataMessage;
    public class Demo {
        public static void main(String[] args) {
            // Initialize user identity
            String akString = "填入您的Access Key ID";
            String skString = "填入您的Secret Access Key";
            String dtsId = "填入您在DTS控制台发布的数据订阅任务ID";

            // Initialize RegionContext
            RegionContext regionContext = new RegionContext();
            regionContext.setUsePublicIp(false);
            regionContext.setAccessKey(akString);
            regionContext.setSecretKey(skString);

            ConsumerClient consumerClient = new ConsumerClientImpl(regionContext);
            consumerClient.addConcurrentListener(new ConsumerListener() { 
                @Override
                public void notify(DataMessage dataMsg) throws Exception {
                    System.out.println(dataMsg);
                }

                @Override
                public void noException(Exception paramException) {

                }
            });

            try {
                consumerClient.askForDtsId(dtsId);
                consumerClient.askForUserId("");
                consumerClient.start();  
            } catch (Exception e) {
                // TODO: handle exception
                e.printStackTrace();
            }
        }
    }

用户向 ConsumerClient 应添加不同的 ConsumerListener ,并重写notify和noException方法。

方法名称 方法类型 方法参数 返回值 方法描述
notify public abstract DataMessage dataMsg void 执行用户指定的订阅数据消费方法
noException public abstract Exception paramException void 订阅数据消费过程异常处理方法

文件新建完成并填入akString、skString和dtsId后,执行Demo即可。