物聯網架構成長之路(61)-物聯網第三方應用命令下發方案

0.前言

　　

　　上一篇博客講的這個圖，說到，設備主動上報數據到應用服務器端，只說到基於MQ來實現，只講到安裝篇，至於代碼篇，等后面實際用到再繼續深入了解。本篇博客主要講，客戶端（手機或者PC端）命令下發到設備，然后設備應答，返回結果到客戶端。常用於掃碼支付類應用。這該是如何設計呢？以前有說到，把手機或者PC客戶端當作一個設備，同樣接入MQTT Broker，這樣，設備和客戶端，同時訂閱和發布相同Topic，就可以兩者之間進行通信。這種方式實現比較簡單。效率高。適用范圍比較單一。一般也就用於自家設備與自家手機應用客戶端。適合公司做自己項目的公司。因為這種方式，平台端還需要管理終端用戶，這對於互聯網公司來說，一般是不太樂意接受的。

　　下面講到的這種異步調用與同步調用，比較適合一些硬件廠商，或者一些想做大平台的公司。就是提供API給第三方客戶接入。完全分離設備端廠商與應用端廠商，兩者只需要按照流程接入即可，不用管Topic的事情。這樣做的好處是，可以做成一個類似小米一樣的生態系統。定好協議，左邊是給設備廠商接入，右邊是給第三方公司，特別是互聯網公司接入。平台只做好設備認證和客戶應用接入。客戶的終端客戶我們平台端就不需要管了。專心做好平台，做好生態即可。

　　應用場景：

　　假如我是一個賣設備模塊的公司，假如這個模塊就一個開關功能。現在定義好模塊的通信協議。開放給硬件產品公司模塊，就一個功能，開跟關。至於硬件產品公司，把開關應用到消防安防的開關，還是閘門、門禁的開關，還是智能插座的開關等等開關類應用。然后這批模塊，按照不同的產品公司，在物聯網平台創建好模型，創建好產品。完成設備接入。

　　下一步，就是開放API給第三方軟件公司。軟件公司，只需要與平台對接，通過產品key，設備sn，命令參數，就可以下發命令到設備。第三方軟件公司，開發自己的APP應用。接收命令后通過RPC調用物聯網平台，平台下發命令，設備應答，平台返回命令下發結果。完成整個調用。（以上應用場景，均可用於共享儀器，掃碼支付等場景）

 

1. 異步調用

　　

2. 同步調用

　　

　　注：本時序圖，最后為什么會有輪詢呢？因為在一個同步調用過程中，會設置超時，如果超時時間內，設備還無法回復。那么就返回超時並返回請求的Msgid給應用服務器。應用服務根據MsgID再去定時輪詢。（也有可能是硬件故障無法回復）。

　　當然上面的應用服務器與客戶端之間，除了Http請求外，可以采用其他的請求方式。

 

3. 同步調用參考代碼

　　同步調用，是基於Java Servlet 3.x 提供的DeferredResult實現的。

　　MessageQueueDeferredService.java

package com.wunaozai.demo.deferred;

import java.util.HashMap;
import java.util.Map;

import org.springframework.stereotype.Service;
import org.springframework.web.context.request.async.DeferredResult;

@Service
public class MessageQueueDeferredService {

    /**
     * 內存級別消息隊列
     */
    private final Map<String, DeferredResult<String>> results =
            new HashMap<String, DeferredResult<String>>();
    
    /**
     * 設置應答
     * @param key
     * @param value
     * @return
     */
    public boolean setResponse(String key, String value) {
        if(results.containsKey(key)) {
            DeferredResult<String> res = results.get(key);
            res.setResult(value);
            results.remove(key);
            return true;
        }
        //可能超時或者不存在對應key
        return false;
    }
    /**
     * 設置請求
     * @param key
     * @param result
     * @return
     */
    public DeferredResult<String> setRequest(String key) {
        DeferredResult<String> result = new DeferredResult<String>(5000L, "not response");
        results.put(key, result);
        result.onTimeout(new Runnable() {
            @Override
            public void run() {
                results.remove(key, result);
            }
        });
        result.onCompletion(new Runnable() {
            @Override
            public void run() {
                results.remove(key, result);
            }
        });
        return result;
    }

}

　　DeferredResultController.java

package com.wunaozai.demo.deferred;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.context.request.async.DeferredResult;

@RestController
@RequestMapping(value="/deferredresult/")
public class DeferredResultController {

    @Autowired
    private MessageQueueDeferredService messagequeuedeferredService;
    
    @GetMapping(value="/request")
    public DeferredResult<String> setRequest(String msgid){
        DeferredResult<String> result = messagequeuedeferredService.setRequest(msgid);
        return result;
    }
    @GetMapping(value="/response")
    public boolean setResponse(String msgid, String value) {
        boolean flag = messagequeuedeferredService.setResponse(msgid, value);
        return flag;
    }

}

　　運行結果

　　

　　前三次請求，由於沒有調用response方法，所以等到5秒超時。並返回not response。等第四次，在5秒內訪問 http://127.0.0.1:8080/deferredresult/reponse?msgid=001&value=test ，然后就在 http://127.0.0.1:8080/deferredresult/request?msgid=003 頁面看到返回結果test了。

 

參考資料:

　　https://www.cnblogs.com/coderxiaohei/p/14061468.html

 

本文地址：https://www.cnblogs.com/wunaozai/p/14078660.html
本系列目錄： https://www.cnblogs.com/wunaozai/p/8067577.html
個人主頁：https://www.wunaozai.com/