使用数据订阅SDK
所有文档

          数据传输服务 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接口简介