导入SDK

1. 前往下载SDK；然后你回获得SDK对应jar包和SDK
   SDK: ysmq-subscribe-sdk-1.0.2-RELEASE.jar
   demo: ysmq-subscribe-sdk-demo-1.0.1.rar

2. 解压sdk-demo的压缩包. 解压后导入Eclipse/Intellij,导入后如图所示:

这时候项目是有错的,因为没有导入sdk的jar包.

1. 导入SDK的依赖: pom结构如下:

    <properties>
      <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
      <slf4j-version>1.7.25</slf4j-version>
    </properties>
    <dependencies>
    <!-- http -->
       <dependency>
           <groupId>com.squareup.okhttp3</groupId>
           <artifactId>okhttp</artifactId>
           <version>3.9.1</version>
       </dependency>
       <dependency>
         <groupId>com.alibaba</groupId>
         <artifactId>fastjson</artifactId>
         <version>1.2.39</version>
       </dependency>
    <!-- slf4j -->
     <dependency>
        <groupId>org.slf4j</groupId>
        <artifactId>slf4j-log4j12</artifactId>
        <version>${slf4j-version}</version>
     </dependency>
     </dependencies>

主要依赖三个包:

1. 在项目中导入sdk的 jar包.

右键项目选择 Build path -> Configure Build path,如图: 选择Add External JARs... 选择你放jar包的位置,导入即可:

导入后,项目如图:

已经没有报错了,sdk demo 中有四个类. log4j是slf4j日志框架的配置文件.

SDK使用

我们先来看看demo中的这个类:ReadCommitMessagePatternMain

1.首先是一些基本的配置:

    // 设置你的appKey
    private static String appKey = "";
    // 设置你的appSecret
    private static String appSecret = "";
    // 设置group,group只能是group1->group5,其他会报出参数错误
    private static String group = "group3";
    // 打印日志的log可以适配你自己的打印日志的框架.
    private static Log log = LogFactory.getLog(ReadCommitMessagePatternMain.class);

1. 初始化StandardConsumerMessage 类,在这个类中设置你的消费消息的回调接口:

    public static void init() {
        // 设置你的appkey,appSecret,group
        StandardConsumerMessage consumerMessage = new StandardConsumerMessage(appKey, appSecret, group);
        // 设置调用接口的间隔时间,ms
        consumerMessage.setConsumeIntervalTime(1000);
        // 设置消费消息的回调接口,建议把消息放入本地队列,不要在回调函数里做业务处理.
        consumerMessage.setConsumerCallBack(new ConsumerCallBack() {
            public void consumerCall(List<Object> msg) {
                if (msg.size() > 100) {
                    // 消息太多,只打印前100个
                    log.info("msgSize:{},msg:{}", msg.size(), msg.subList(0, 100));
                } else {
                    log.info("msgSize:{},msg:{}", msg.size(), msg);
                }
                for (Object object : msg) {
                    // class com.alibaba.fastjson.JSONObject
                    log.info("my readMessageHandle object:{},class:{}", object, object.getClass());
                }
            }
        });
        consumerMessage.initClient();
    }

注意代码中的 consumerMessage.setConsumerCallBack() 方法,在这里边设置你消费消息的回调函数.

    /**
    * <p>
    * 消费消息的回调
    * </p>
    */
    public interface ConsumerCallBack {
      void consumerCall(List<Object> msg);
    }

回调接口中的 void consumerCall(List

下边是一个自定义回调接口的简单示例:

    new ConsumerCallBack() {
            public void consumerCall(List<Object> msg) {
                if (msg != null) {
                    if (msg.size() > 100) {
                        // 消息太多,只打印前100个
                        log.info("msgSize:{},msg:{}", msg.size(), msg.subList(0, 100));
                    } else {
                        log.info("msgSize:{},msg:{}", msg.size(), msg);
                    }
                    for (Object object : msg) {
                        // class com.alibaba.fastjson.JSONObject
                        log.info("my readMessageHandle object:{},class:{}", object, object.getClass());
                    }
                }
            }
        }

Object的类是com.alibaba.fastjson.JSONObject 这个类

是一个json格式的对象:

    public class JSONObject extends JSON implements Map<String, Object>

这个JSONObject 里边具体的结构如下:

    {
        "header": {
                "type": "device",//用户订阅的消息类型
                "deviceId": "427734203",//设备序列号
                "channelNo":"1"//设备通道号
                },
        "content": {//设备上传的消息,原封不动的放在这里
                "test": "msg_content"
                }
    }

header ---> 消息头

content -->设备上传的消息

附录:消息字段返回字段

type为ys.alarm即表示萤石云告警消息，以下是告警消息结构体：

type为ys.onoffline即表示萤石云上下线消息，以下是上下线消息结构体：