Android Things阿里云物联网平台的使用（普通版）

清疚 2022-05-26 06:19 250阅读 0赞

研究了物联网，那么接下来你需要做的就是如何去远程控制，实现开发板的远程通讯交互，那么BAT最近也都陆续更新了自己的物联网平台系统，借助BAT的资源，我们能很快的建立起一个物联网开发环境，接下来我们手把手看看阿里云物联网平台的使用吧

1.登录到阿里云，在左上角的产品菜单中找到“产品”

![70][]

2.从“产品”菜单中找到“物联网套件”

![70 1][]

3.点击“管理控制台”，进入物联网控制台进行相关配置

![70 2][]

4.首先创建一个产品

![70 3][]

5.填写相关信息，在这里我们选择基础版，因为高级版虽然增加了很多功能，但是云端开发SDK截止目前为止尚未更新，无法使用云端SDK远程控制开发板

![70 4][]

6.创建完成后，选择设备，点击“查看”，进入选择“前往管理”添加设备信息

![70 5][]

7.点击“添加设备”

![70 6][]

8.填写设备名称

![70 7][]

9.记录备份相关秘钥信息，点击一键复制，保存到记事本，方便开发使用

![70 8][]

10.回到产品信息页，进入“消息通讯”，点击“定义Topic类”添加

![70 9][]

11.填写相关信息

![70 10][]

12.接下来我们开发things程序，首先在项目的build.gradle文件中添加阿里云仓库地址

maven {
        url "http://maven.aliyun.com/nexus/content/repositories/releases/"
    }

13.在app模块的build.gradle文件中添加相关组件

compile 'com.aliyun.alink.linksdk:public-channel-core:0.2.1'

14.集成

/**
     * Created by cc_want on 2018/4/26.
     */
    public class AliyunIoT {
        private String TAG ="AlibabaIOT";
    
        public static final String productKey = "<填写>"; //这个是设备模版productkey
        public static final String deviceName = "<填写>";//这个是设备名称
        public static final String deviceSecret = "<填写>";//这个是设备秘钥
    
        public static final String ACTION_SYS_SERVICE_CMD = String.format(Locale.CHINESE,"/%s/%s/%s",productKey,deviceName,"cmd");
    
        private IConnectionStateListener mConnectionStateListener;
        private IOnPushListener mIOnPushListener;
        private IOnSubscribeListener mSysServiceListener = new IOnSubscribeListener() {
            @Override
            public void onSuccess(String s) {
    
            }
    
            @Override
            public void onFailed(String s, AError aError) {
    
            }
    
            @Override
            public boolean needUISafety() {
                return true;
            }
        };
        AliyunIoT(){
    
        }
        private static AliyunIoT mIntance;
        public static AliyunIoT getIntance() {
            if (mIntance == null) {
                mIntance = new AliyunIoT();
            }
            return mIntance;
        }
        public void init(Context context, IConnectionStateListener listener) {
            mConnectionStateListener = listener;
            ALog.setLevel(ALog.LEVEL_DEBUG);
            MqttConfigure.mqttHost = "ssl://" + productKey + ".iot-as-mqtt.cn-shanghai.aliyuncs.com:1883";
    
            MqttInitParams initParams = new MqttInitParams(productKey, deviceName, deviceSecret);
            PersistentNet.getInstance().init(context, initParams);
    
            PersistentEventDispatcher.getInstance().registerOnTunnelStateListener(mConnectionStateListener, true);// 注册监听
        }
        public void register() {
            PersistentEventDispatcher.getInstance().registerOnPushListener(mIOnPushListener, true);
            PersistentNet.getInstance().subscribe(ACTION_SYS_SERVICE_CMD, mSysServiceListener);
        }
        public void setIOnPushListener(IOnPushListener listener) {
            this.mIOnPushListener = listener;
        }
        public void close() {
            PersistentEventDispatcher.getInstance().unregisterOnTunnelStateListener(mConnectionStateListener);//取消监听
            PersistentEventDispatcher.getInstance().unregisterOnPushListener(mIOnPushListener);
            PersistentNet.getInstance().unSubscribe(ACTION_SYS_SERVICE_CMD, mSysServiceListener);
        }
    }

在MainActivity中初始化

AliyunIoT.getIntance().init(this, this);
    AliyunIoT.getIntance().setIOnPushListener(this);

实现IOnPushListener接口回调方法，接收处理阿里云物联网平台的消息

/**
         * 下推消息回调接口
         *
         * @param topic
         * @param data  下推的消息内容
         */
        @Override
        public void onCommand(String topic, String data) {
            Log.e(TAG, "接收:  topic=" + topic + "  data=" + data);
            JSONObject json = JSON.parseObject(data);
        }
        /**
         * 根据method过滤消息
         *
         * @param topic : 本次下推消息的命令名称
         * @return : 若返回true，则onCommand被调用，返回false，则onCommand不会被调用
         */
        @Override
        public boolean shouldHandle(String topic) {
            Log.e(TAG, "接收 shouldHandle :  topic=" + topic);
            return true;
        }

15.服务端集成

在开发板物联网平台使用中，我们常需要远程控制，所以我们需要有一个可以远程控制的程序，这里阿里云物联网平台提供了java SDK方便我们调用，但需要注意的是，目前java SDK不支持高级版，这也就是建议使用基础版的原因，在本教程中，服务端开发了一个Android app，装在手机上，方便我们测试

注意：这里使用的是普通版，高级版请查看另外一篇文章

[Android Things阿里云物联网平台的使用（高级版）][Android Things]

compile 'com.aliyun:aliyun-java-sdk-iot:4.0.0'
        compile 'com.aliyun:aliyun-java-sdk-core:3.2.10'

服务端代码如下:

/**
     * 阿里云物联网平台服务端
     * Created by cc_want on 2018/4/11.
     */
    public class AliyunIOT {
        private String TAG ="AlibabaIOT";
    
    
        public static final String accessKey = "<填写>";
        public static final String accessSecret = "<填写>";
    
        public static final String productKey = "<填写>"; //这个是设备模版productkey
        public static final String ACTION_DRIVE = "/<填写>/<填写deviceName>/cmd";
    
        private DefaultAcsClient mClient;
    
        private static AliyunIOT mIntance;
    
        public static AliyunIOT getIntance(){
            if(mIntance == null){
                mIntance = new AliyunIOT();
            }
            return mIntance;
        }
        public void init(){
            try {
                DefaultProfile.addEndpoint("cn-shanghai", "cn-shanghai", "Iot", "iot.cn-shanghai.aliyuncs.com");
            } catch (ClientException e) {
                e.printStackTrace();
            }
            IClientProfile profile = DefaultProfile.getProfile("cn-shanghai", accessKey, accessSecret);
            mClient = new DefaultAcsClient(profile); //初始化SDK客户端
        }
        public void open(int lightNo){
            //{"LightStatus":1}
            JSONObject json = new JSONObject();
            try {
                json.put("LightStatus",1);
            } catch (JSONException e) {
                e.printStackTrace();
            }
            new Drive(json.toString()).execute();
        }
    
        class Drive extends AsyncTask<String,Integer,String>{
    
            String mMsg;
            Drive(String msg){
                mMsg = msg;
            }
            @Override
            protected String doInBackground(String... params) {
                PubRequest request = new PubRequest();
                request.setProductKey(productKey);
                //此处必须用Base64加密
                request.setMessageContent(Base64.encodeToString(mMsg.getBytes(),Base64.DEFAULT));
                request.setTopicFullName(ACTION_DRIVE);
                request.setQos(0); //目前支持QoS0和QoS1
                //如果不加，则报错，官方文档没写
                //Specified signature is not matched with our calculation
                request.setMethod(MethodType.POST);
                try {
                    PubResponse response = mClient.getAcsResponse(request);
                    Log.d(TAG,"success:"+response.getSuccess());
                    Log.d(TAG,"error:"+response.getErrorMessage());
                } catch (ClientException e) {
                    e.printStackTrace();
                }
                return null;
            }
        }
    }

[70]: /images/20220526/cf8ca50ada5e4017bea8320e579fd016.png
[70 1]: /images/20220526/36b1551bcc954ea68aeb112879f5c165.png
[70 2]: /images/20220526/2fbc393dacf44b56aeb37813cdbb543b.png
[70 3]: /images/20220526/934fa721329c44ce9b818fc648c2f451.png
[70 4]: /images/20220526/2d9918100c4f4b8db0e5dafe6e941193.png
[70 5]: /images/20220526/4fe4c239b4464c2281aacec131907202.png
[70 6]: /images/20220526/1cf00a8bd5684484abc5c19475a13c33.png
[70 7]: /images/20220526/27622d95508c49ba85e8aacf4094f7b3.png
[70 8]: /images/20220526/bffc3f923ba84b698415e0acb3356422.png
[70 9]: /images/20220526/352de843c7f04365a644a96dcff2211c.png
[70 10]: /images/20220526/3b3197ee6dc54f2e8a1492f1b65a1c87.png
[Android Things]: https://blog.csdn.net/cc_want/article/details/80192042