数据传输服务DTS

    使用数据订阅SDK

    新建Demo文件

    import com.bce.dts.client.ConsumerClient;
    import com.bce.dts.client.ConsumerClientImpl;
    import com.bce.dts.client.ConsumerListener;
    import com.bce.dts.client.RegionContext;
    import com.bce.dts.model.message.data.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 {
                        // TODO: process DataMessage as ur wish
                    System.out.println(dataMsg);
                }
                  
                @Override
                public void noException(Exception paramException) {
                        // TODO: handle exception when process DataMessage
                        System.out.println("Listener exception");
                }
            });
    
            consumerClient.start();  
        }
    }

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

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

    文件新建完成并填入akString、skString和dtsId后,执行Demo即可。 SDK接口方法详见:SDK接口简介

    上一篇
    安装-DTS-Java-SDK
    下一篇
    SDK接口简介