tencent cloud

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 {
        // Create a context
        SubscribeContext context=new SubscribeContext();
        // User `secretId` and `secretKey`. We recommend that you use a sub-account key and follow the principle of minimum permission to reduce risks. For information on how to obtain a sub-account key, visit https://www.tencentcloud.com/document/product/598/32675.
        context.setSecretId("AKID-522dabxxxxxxxxxxxxxxxxxx"); 
        context.setSecretKey("AKEY-0ff4cxxxxxxxxxxxxxxxxxxxx"); 
        // Specify the channel region, which is required for SDKs on version 2.8.0 or later.
        // For more information on region values, visit https://www.tencentcloud.com/document/product/236/15833?from_cn_redirect=1#.E5.9C.B0.E5.9F.9F.E5.88.97.E8.A1.A8.
        context.setRegion("ap-chongqing");
        // Subscribed `serviceIp` and `servicePort`
        // Note that the `IP` and `Port` parameters are required for SDKs on versions earlier than 2.8.0 and can be ignored for those on later versions if `region` is set.
        // context.setServiceIp("10.xx.xx.24");
        // context.setServicePort(50120);

        // Set the network environment to private network if the CVM instance where the SDK is running cannot be accessed over the public network. Public network access is used by default.
        context.setNetworkEnv(NetworkEnv.LAN);
        // Create a client
        SubscribeClient client=new DefaultSubscribeClient(context);
        // Create a subscription listener
        ClusterListener listener= new ClusterListener() {
            @Override
            public void notify(List<ClusterMessage> messages) throws Exception {
                // Consume the subscribed data
                for(ClusterMessage m:messages){
                  for(DataMessage.Record.Field f:m.getRecord().getFieldList()){

                      if (f.getType().equals(DataMessage.Record.Field.Type.BLOB)){
                          System.out.println("["+f.getType()+"]["+f.getFieldname()+"] the original value:");
                          byte[] theRawBytesValue = f.getValueAsBytes();
                      }if(f.getType().equals(DataMessage.Record.Field.Type.INT8)){
                          // If this value is null, `f.getValueAsInteger()` will return null.
                          System.out.println(f.getValueAsInteger());
                      }if(f.getType().equals(DataMessage.Record.Field.Type.JSON)){
                          // JSON data can be returned only if the source instance is MySQL 5.7.
                          System.out.println(f.getValueAsString());
                      }if(f.getType().equals(DataMessage.Record.Field.Type.STRING)){
                          // If this value is null, `f.getValueAsString()` will return null.
                          System.out.println(f.getValueAsString());
                          // The original encoding of the field
                          System.out.println(f.getFieldEnc());
                      }
                      else{
                          // The `f.getValue()` method will be disused soon.
                          String value = f.getValue() == null ? "Null": f.getValue();
                          String msg = "["+f.getType()+"]"+f.getFieldname()+"[encoding:"+f.getFieldEnc()+"]"+"[value:"+value+"]";
                          System.out.println(msg);
                      }

                  }
                  // Acknowledge the consumption
                  m.ackAsConsumed();
              }
            }
            @Override
            public void onException(Exception e){
                System.out.println("listen exception"+e);
            }};
        // Add a listener
        client.addClusterListener(listener);
        // Configure the requested subscription channel
        client.askForGUID("dts-channel-r0M8kKsSyRZmSxQt");
        // Start the client
        client.start();
    }
}