基于java的多設備類型物聯(lián)網(wǎng)架構實現(xiàn)

前言：19年11月開始從 【金融】行業(yè)轉 【物聯(lián)網(wǎng)】，路途坎坷，一個人摸索前進，不過也學到了很多新的東西，交了很多好朋友，在此感謝各位！

以下是一些經(jīng)驗分享，希望能幫到有需要的朋友。

1、架構思路

考慮了很久打算用springboot + mysql 去實現(xiàn)，因為熟悉這個框架，而且能減輕70%的機械性開發(fā)工作量，以后改springcloud也方便(注意邏輯實現(xiàn)不然工作量很大)。

物聯(lián)網(wǎng)和互聯(lián)網(wǎng)可以說是有共同點的，但是也有很多的不一樣。

先說協(xié)議，互聯(lián)網(wǎng)很多都是https或者http，但是物聯(lián)網(wǎng)這塊就不僅僅是這兩種協(xié)議，會有UDP協(xié)議，TCP協(xié)議。

上干貨：

環(huán)境：java+mysql+redis+rabbitMQ+Mqtt

圖解：

這個是比較簡單的邏輯圖，里面的復雜邏輯還是不能說的。

這里面涉及到幾個問題，好多物聯(lián)網(wǎng)設備終端會有心跳，事件數(shù)據(jù)上來，怎么保證并發(fā)？入庫的數(shù)據(jù)唯一？多種設備的數(shù)據(jù)上行，怎么存儲？怎么管理？有多個第三方服務怎么分發(fā)數(shù)據(jù)？

咱們一點點說：

1、根據(jù)協(xié)議解析數(shù)據(jù)

終端上行的數(shù)據(jù)有433協(xié)議，有藍牙的，有zigbee的，還有tcp、http的，還分1代、2代、3代等協(xié)議。我用了一個笨方法：根據(jù)協(xié)議的不同解析，存入不同的表

我整了個枚舉類來存放不同的類型，在解析方法里面通過唯一性的一段上行數(shù)據(jù)去區(qū)分(為什么這么做？以為上行數(shù)據(jù)是16進制的)

HH0F22AEBB8200011100020001BB23AABB8637

“HH0F”就是A協(xié)議的特有字符，那這個就入A協(xié)議庫。

A協(xié)議是A設備專用的，那建表就是這樣的

A_tag —————— 設備表

A_data ——————設備數(shù)據(jù)表

A_gateway ——————網(wǎng)關表

那么問題來了，要是10種設備不得30個表了？

做過物聯(lián)網(wǎng)的都知道，不同類型的設備可能帶的屬性都是不一樣的，有的設備可能就3個：

電量、包序、特征值

但是有的設備可能就不止了，比方說：

電量、包序、心跳、呼吸、體溫、動態(tài)值。。。。

data表中數(shù)據(jù)不得爆掉？——我深思熟慮也只是想到通用字段存儲，data1~data20

多設備類型的暫時解決了，后面怎么具體操作呢？

2、怎么保證數(shù)據(jù)不會重復并快速入庫

上圖我采用了兩個服務，一個接受服務，一個處理服務，具體處理方法：

接受服務將受到的數(shù)據(jù)轉base64編碼后直接發(fā)到消息隊列(rabbitMQ)，處理服務監(jiān)聽rabbitMQ消息，走解析服務。就是這么簡單！

但是，有一點，rabbitMQ要開啟ack模式！！！而且可以用負載來做這步！

問題二：設備一多，并發(fā)問題就來了，怎么搞？

Semaphore 這可是個好東西

如果來一條數(shù)據(jù)就insert，哪個數(shù)據(jù)庫都受不了，后來采用批量方式插入：

// ----------------------數(shù)據(jù)批量入庫開始-------------------------

private static ListlistNnObjectSaveDO = new ArrayList();

private static Long startTimeNnData = 0L;

//private static int countSend = 0;

private static Semaphore semaphoreNnData = new Semaphore(1);

@Override

public void saveDO(NnData nnData) {

try {

semaphoreNnData.acquire();

if (startTimeNnData == 0L) {

startTimeNnData = System.currentTimeMillis();

}

listNnObjectSaveDO.add(nnData);

if (System.currentTimeMillis() - startTimeNnData > 2000) {

ListlistSaveDOOne = new ArrayList();

listSaveDOOne.addAll(listNnObjectSaveDO);

asyncInsertBatch(listSaveDOOne);

listNnObjectSaveDO.clear();

startTimeNnData = 0L;

}

} catch (Exception e) {

e.printStackTrace();

} finally {

semaphoreNnData.release();

}

}

@Async

private void asyncInsertBatch(Listlist) {

this.insertBatch(list);

//countSend = countSend + list.size();

//System.out.println("=================入庫數(shù)據(jù)條數(shù)：" + countSend);

}

// ----------------------數(shù)據(jù)批量入庫結束-------------------------

我做過測試，這樣的方式遠超2000條/秒，有眼尖的朋友看出來了：

System.currentTimeMillis() - startTimeNnData > 2000 //2秒批量入庫一次

暫時就到這兒，后續(xù)想到我再補充！

總結

以上是生活随笔為你收集整理的物联网 云端java架构_基于java的物联网架构实现的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。