设备端检测自己是否在线

import java.io.UnsupportedEncodingException;



import com.aliyun.alink.dm.api.DeviceInfo;

import com.aliyun.alink.dm.api.InitResult;

import com.aliyun.alink.linkkit.api.ILinkKitConnectListener;

import com.aliyun.alink.linkkit.api.IoTMqttClientConfig;

import com.aliyun.alink.linkkit.api.LinkKit;

import com.aliyun.alink.linkkit.api.LinkKitInitParams;

import com.aliyun.alink.linksdk.cmp.connect.channel.MqttPublishRequest;

import com.aliyun.alink.linksdk.cmp.connect.channel.MqttSubscribeRequest;

import com.aliyun.alink.linksdk.cmp.core.base.AMessage;

import com.aliyun.alink.linksdk.cmp.core.base.ARequest;

import com.aliyun.alink.linksdk.cmp.core.base.AResponse;

import com.aliyun.alink.linksdk.cmp.core.base.ConnectState;

import com.aliyun.alink.linksdk.cmp.core.listener.IConnectNotifyListener;

import com.aliyun.alink.linksdk.cmp.core.listener.IConnectSendListener;

import com.aliyun.alink.linksdk.cmp.core.listener.IConnectSubscribeListener;

import com.aliyun.alink.linksdk.tools.AError;



public class CheckDeviceStatusOnDevice {



        // ===================需要用户填写的参数，开始===========================

        // 产品productKey，设备证书参数之一

        private static String productKey = "";

        // 设备名字deviceName，设备证书参数之一

        private static String deviceName = "";

        // 设备密钥deviceSecret，设备证书参数之一

        private static String deviceSecret = "";

        // 消息通信的Topic，需要在控制台定义，权限必须为发布和订阅

        private static String checkStatusTopic = "/" + productKey + "/" + deviceName + "/user/checkstatus";

        // ===================需要用户填写的参数结束===========================



        // 接收到的消息

        private static String subInfo = "";



        public static void main(String[] args) throws InterruptedException {



                CheckDeviceStatusOnDevice device = new CheckDeviceStatusOnDevice();



                // 初始化

                device.init(productKey, deviceName, deviceSecret);



                // 下行数据监听

                device.registerNotifyListener();



                // 订阅Topic

                device.subscribe(checkStatusTopic);



                // 测试设备状态

                System.out.println("we will check device online status now.");

                device.checkStatus();



                // 准备测试设备离线状态，请拔掉网线

                System.out.println("pls close network，we will check device offline status after 60 seconds.");

                for (int i = 0; i < 6; i++) {

                        Thread.sleep(10000);

                }

                device.checkStatus();

        }



        /**

         * 测试设备状态

         * 

         * @throws InterruptedException

         */

        public void checkStatus() throws InterruptedException {



                // -------------------------------------------------------------------

                // 要发送的消息，可以自定义，建议使用当前格式

                // -------------------------------------------------------------------

                // Field   | Tyep   | Desc

                // -------------------------------------------------------------------

                // id      | Object | 用于验证收发的消息是否是同一个，请自行业务层保证唯一

                // -------------------------------------------------------------------

                // version | String | 版本号固定1.0

                // -------------------------------------------------------------------

                // time    | Long   | 发送消息的时间戳，可以计算消息来回的延时，评估当前的通信质量

                // -------------------------------------------------------------------

                String payload = "{"id":123, "version":"1.0","time":" + System.currentTimeMillis() + "}";



                // 发送消息

                publish(checkStatusTopic, payload);



                // 严格的离线判定逻辑：发送消息后，5秒内没有收到消息算失败，出现1次失败，判定为离线

                boolean isTimeout = true;

                for (int i = 0; i < 5; i++) {

                        Thread.sleep(1000);

                        if (!subInfo.isEmpty()) {

                                isTimeout = false;

                                break;

                        }

                }

                if (!isTimeout && payload.equals(subInfo)) {

                        System.out.println("Device is online !!");

                } else {

                        System.out.println("Device is offline !!");

                }



                // 置空接收到的消息，方便下一次测试

                subInfo = "";

        }



        /**

         * 初始化

         * 

         * @param pk productKey

         * @param dn devcieName

         * @param ds deviceSecret

         * @throws InterruptedException

         */

        public void init(String pk, String dn, String ds) throws InterruptedException {



                LinkKitInitParams params = new LinkKitInitParams();



                // 设置 MQTT 初始化参数

                IoTMqttClientConfig config = new IoTMqttClientConfig();

                config.productKey = pk;

                config.deviceName = dn;

                config.deviceSecret = ds;

                params.mqttClientConfig = config;



                // 设置初始化设备证书信息，用户传入

                DeviceInfo deviceInfo = new DeviceInfo();

                deviceInfo.productKey = pk;

                deviceInfo.deviceName = dn;

                deviceInfo.deviceSecret = ds;



                params.deviceInfo = deviceInfo;



                LinkKit.getInstance().init(params, new ILinkKitConnectListener() {

                        @Override

                        public void onInitDone(InitResult initResult) {

                                System.out.println("init success !!");

                        }



                        @Override

                        public void onError(AError aError) {

                                System.out.println("init failed !! code=" + aError.getCode() + ",msg=" + aError.getMsg() + ",subCode="

                                                + aError.getSubCode() + ",subMsg=" + aError.getSubMsg());

                        }

                });



                // 确保初始化成功后才执行后面的步骤，可以根据实际情况适当延长这里的延时

                Thread.sleep(2000);

        }



        /**

         * 监听下行数据

         */

        public void registerNotifyListener() {

                LinkKit.getInstance().registerOnNotifyListener(new IConnectNotifyListener() {

                        @Override

                        public boolean shouldHandle(String connectId, String topic) {

                                // 只处理特定Topic的消息

                                if (checkStatusTopic.equals(topic)) {

                                        return true;

                                } else {

                                        return false;

                                }

                        }



                        @Override

                        public void onNotify(String connectId, String topic, AMessage aMessage) {

                                // 接收消息

                                try {

                                        subInfo = new String((byte[]) aMessage.getData(), "UTF-8");

                                } catch (UnsupportedEncodingException e) {

                                        e.printStackTrace();

                                }

                        }



                        @Override

                        public void onConnectStateChange(String connectId, ConnectState connectState) {

                        }

                });

        }



        /**

         * 发布消息

         * 

         * @param topic 发送消息的Topic

         * @param payload 发送的消息内容

         */

        public void publish(String topic, String payload) {

                MqttPublishRequest request = new MqttPublishRequest();

                request.topic = topic;

                request.payloadObj = payload;

                request.qos = 0;

                LinkKit.getInstance().getMqttClient().publish(request, new IConnectSendListener() {

                        @Override

                        public void onResponse(ARequest aRequest, AResponse aResponse) {

                        }



                        @Override

                        public void onFailure(ARequest aRequest, AError aError) {

                        }

                });

        }



        /**

         * 订阅消息

         * 

         * @param topic 订阅消息的Topic

         */

        public void subscribe(String topic) {

                MqttSubscribeRequest request = new MqttSubscribeRequest();

                request.topic = topic;

                LinkKit.getInstance().getMqttClient().subscribe(request, new IConnectSubscribeListener() {

                        @Override

                        public void onSuccess() {

                        }



                        @Override

                        public void onFailure(AError aError) {

                        }

                });

        }



}