Android Things阿裡雲物聯網平台的使用（普通版）

Android Things阿裡雲物聯網平台的使用（普通版）

研究了物聯網，那麼接下來你需要做的就是如何去遠端控制，實作開發闆的遠端通訊互動，那麼BAT最近也都陸續更新了自己的物聯網平台系統，借助BAT的資源，我們能很快的建立起一個物聯網開發環境，接下來我們手把手看看阿裡雲物聯網平台的使用吧

1.登入到阿裡雲，在左上角的産品菜單中找到“産品”

2.從“産品”菜單中找到“物聯網套件”

3.點選“管理控制台”，進入物聯網控制台進行相關配置

4.首先建立一個産品

5.填寫相關資訊，在這裡我們選擇基礎版，因為進階版雖然增加了很多功能，但是雲端開發SDK截止目前為止尚未更新，無法使用雲端SDK遠端控制開發闆

6.建立完成後，選擇裝置，點選“檢視”，進入選擇“前往管理”添加裝置資訊

7.點選“添加裝置”

8.填寫裝置名稱

9.記錄備份相關秘鑰資訊，點選一鍵複制，儲存到記事本，友善開發使用

10.回到産品資訊頁，進入“消息通訊”，點選“定義Topic類”添加

11.填寫相關資訊

12.接下來我們開發things程式，首先在項目的build.gradle檔案中添加阿裡雲倉庫位址

[java] view plain copy

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

13.在app子產品的build.gradle檔案中添加相關元件

[html]

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

14.內建

1. /**
2.  * Created by cc_want on 2018/4/26.
3.  */
4. public class AliyunIoT {
5.     private String TAG ="AlibabaIOT";
6.     public static final String productKey = "<填寫>"; //這個是裝置模版productkey
7.     public static final String deviceName = "<填寫>";//這個是裝置名稱
8.     public static final String deviceSecret = "<填寫>";//這個是裝置秘鑰
9.     public static final String ACTION_SYS_SERVICE_CMD = String.format(Locale.CHINESE,"/%s/%s/%s",productKey,deviceName,"cmd");
10.     private IConnectionStateListener mConnectionStateListener;
11.     private IOnPushListener mIOnPushListener;
12.     private IOnSubscribeListener mSysServiceListener = new IOnSubscribeListener() {
13.         @Override
14.         public void onSuccess(String s) {
15.         }
17.         public void onFailed(String s, AError aError) {
20.         public boolean needUISafety() {
21.             return true;
23.     };
24.     AliyunIoT(){
25.     }
26.     private static AliyunIoT mIntance;
27.     public static AliyunIoT getIntance() {
28.         if (mIntance == null) {
29.             mIntance = new AliyunIoT();
31.         return mIntance;
33.     public void init(Context context, IConnectionStateListener listener) {
34.         mConnectionStateListener = listener;
35.         ALog.setLevel(ALog.LEVEL_DEBUG);
36.         MqttConfigure.mqttHost = "ssl://" + productKey + ".iot-as-mqtt.cn-shanghai.aliyuncs.com:1883";
37.         MqttInitParams initParams = new MqttInitParams(productKey, deviceName, deviceSecret);
38.         PersistentNet.getInstance().init(context, initParams);
39.         PersistentEventDispatcher.getInstance().registerOnTunnelStateListener(mConnectionStateListener, true);// 注冊監聽
41.     public void register() {
42.         PersistentEventDispatcher.getInstance().registerOnPushListener(mIOnPushListener, true);
43.         PersistentNet.getInstance().subscribe(ACTION_SYS_SERVICE_CMD, mSysServiceListener);
45.     public void setIOnPushListener(IOnPushListener listener) {
46.         this.mIOnPushListener = listener;
48.     public void close() {
49.         PersistentEventDispatcher.getInstance().unregisterOnTunnelStateListener(mConnectionStateListener);//取消監聽
50.         PersistentEventDispatcher.getInstance().unregisterOnPushListener(mIOnPushListener);
51.         PersistentNet.getInstance().unSubscribe(ACTION_SYS_SERVICE_CMD, mSysServiceListener);

在MainActivity中初始化

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

實作IOnPushListener接口回調方法，接收處理阿裡雲物聯網平台的消息

2.  * 下推消息回調接口
3.  *
4.  * @param topic
5.  * @param data  下推的消息内容
7. @Override
8. public void onCommand(String topic, String data) {
9.     Log.e(TAG, "接收:  topic=" + topic + "  data=" + data);
10.     JSONObject json = JSON.parseObject(data);
13.  * 根據method過濾消息
15.  * @param topic : 本次下推消息的指令名稱
16.  * @return : 若傳回true，則onCommand被調用，傳回false，則onCommand不會被調用
19. public boolean shouldHandle(String topic) {
20.     Log.e(TAG, "接收 shouldHandle :  topic=" + topic);
21.     return true;

15.服務端內建

在開發闆物聯網平台使用中，我們常需要遠端控制，是以我們需要有一個可以遠端控制的程式，這裡阿裡雲物聯網平台提供了java SDK友善我們調用，但需要注意的是，目前java SDK不支援進階版，這也就是建議使用基礎版的原因，在本教程中，服務端開發了一個Android app，裝在手機上，友善我們測試

注意：這裡使用的是普通版，進階版請檢視另外一篇文章

Android Things阿裡雲物聯網平台的使用（進階版）

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

服務端代碼如下:

2.  * 阿裡雲物聯網平台服務端
3.  * Created by cc_want on 2018/4/11.
5. public class AliyunIOT {
7.     public static final String accessKey = "<填寫>";
8.     public static final String accessSecret = "<填寫>";
10.     public static final String ACTION_DRIVE = "/<填寫>/<填寫deviceName>/cmd";
11.     private DefaultAcsClient mClient;
12.     private static AliyunIOT mIntance;
13.     public static AliyunIOT getIntance(){
14.         if(mIntance == null){
15.             mIntance = new AliyunIOT();
19.     public void init(){
20.         try {
21.             DefaultProfile.addEndpoint("cn-shanghai", "cn-shanghai", "Iot", "iot.cn-shanghai.aliyuncs.com");
22.         } catch (ClientException e) {
23.             e.printStackTrace();
25.         IClientProfile profile = DefaultProfile.getProfile("cn-shanghai", accessKey, accessSecret);
26.         mClient = new DefaultAcsClient(profile); //初始化SDK用戶端
28.     public void open(int lightNo){
29.         //{"LightStatus":1}
30.         JSONObject json = new JSONObject();
32.             json.put("LightStatus",1);
33.         } catch (JSONException e) {
36.         new Drive(json.toString()).execute();
38.     class Drive extends AsyncTask<String,Integer,String>{
39.         String mMsg;
40.         Drive(String msg){
41.             mMsg = msg;
44.         protected String doInBackground(String... params) {
45.             PubRequest request = new PubRequest();
46.             request.setProductKey(productKey);
47.             //此處必須用Base64加密
48.             request.setMessageContent(Base64.encodeToString(mMsg.getBytes(),Base64.DEFAULT));
49.             request.setTopicFullName(ACTION_DRIVE);
50.             request.setQos(0); //目前支援QoS0和QoS1
51.             //如果不加，則報錯，官方文檔沒寫
52.             //Specified signature is not matched with our calculation
53.             request.setMethod(MethodType.POST);
54.             try {
55.                 PubResponse response = mClient.getAcsResponse(request);
56.                 Log.d(TAG,"success:"+response.getSuccess());
57.                 Log.d(TAG,"error:"+response.getErrorMessage());
58.             } catch (ClientException e) {
59.                 e.printStackTrace();
60.             }
61.             return null;

 原文位址

http://www.bieryun.com/3626.html