obix協(xié)議在java中的配置和使用詳解
更新時間：2017年08月29日 10:58:05 作者：失控的嬰兒車
這篇文章主要給大家介紹了關于obix協(xié)議在java中的配置和使用，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧。
前言
本文主要給大家介紹的是關于obix協(xié)議在java中的配置和使用，分享出來供大家參考學習，下面話不多說了，來一起看看詳細的介紹吧。
什么是 oBIX?
簡單來講，obix是一種 XML 通訊協(xié)議，使用Http Request/Post方式進行數(shù)據(jù)通訊。所有數(shù)據(jù)通過可讀字符進行傳送，一個oBIX對象可以有唯一的一個URL識別。
oBIX的實現(xiàn)原理
首先數(shù)據(jù)儲存在Niagara的服務平臺上，我們需要做的是從Niagara獲取數(shù)據(jù)，并且儲存在InfluxDB中。下面是實現(xiàn)的流程方法。
- 加粗 Ctrl + B
- 斜體 Ctrl + I
- 引用 Ctrl + Q
- 插入鏈接 Ctrl + L
- 插入代碼 Ctrl + K
- 插入圖片 Ctrl + G
- 提升標題 Ctrl + H
- 有序列表 Ctrl + O
- 無序列表 Ctrl + U
- 橫線 Ctrl + R
- 撤銷 Ctrl + Z
- 重做 Ctrl + Y
我們都需要定義哪些類以及變量？
| 類/接口 名 | 用途 |
|---|---|
| Calculator | |
| DiscoverEngine | 搜索工具 |
| FactorInfo | 定義所采集元素的信息 |
| FactorNameDecoderInterface | 元素名稱解碼接口 |
| FactorNameDecoderObixUrlImpl | |
| NewValueInterface | |
| NewValueInterfaceImpl | |
| ObixClientMgr | |
| ObixClient | |
| ObixFetcher | 循環(huán)抓取obix傳輸?shù)臄?shù)據(jù) |
1、遍歷各個點
2、先遍歷各個設備，將相同的typeid的設備存入同一個hashmap中
3、開始執(zhí)行主程序，先從數(shù)據(jù)庫中查詢出項目名稱
4、開始搜索！
public class ObixFetcher implements JobInterface{
//這個是接口的抽象方法
public void cycleOnce() {
//從數(shù)據(jù)庫中取出項目信息
List<Project> ps = dao.selectByExample(new ProjectExample());
//遍歷項目信息，如果項目信息的關鍵信息不為null
for(Project p : ps){
if(p.getObixBaseAddress() != null && p.getObixUsername() != null
&& p.getObixPassword() != null){
//開啟探索工具 （應該還是一個內部類），將關鍵項目信息傳入探索工具，
DiscoverEngine de = new DiscoverEngine(p.getObixBaseAddress(),
p.getObixUsername(), p.getObixPassword());
//從build數(shù)據(jù)庫中將數(shù)據(jù)取出，存入bulidNameToId（同樣還是構造方法）
//從device數(shù)據(jù)庫中將數(shù)據(jù)取出，存入deviceNumberToId（同樣還是構造方法）
de.setNewValueInterface(new NewValueInterfaceImpl(p.getId(), deviceService, deviceDao, deviceTypeDao, buildDao));
//return回來一個FactorInfo
de.setFactorNameDecoderInterface(new FactorNameDecoderObixUrlImpl());
de.run();
}
}
}
}
以下是上文 DiscoverEngine de的構造方法
public class DiscoverEngine {
public DiscoverEngine(String baseUrl, String username, String password){
this.baseUrl = baseUrl;
obixClient = new ObixClient(baseUrl, username, password);
}
}
以下是上文obixClient = new ObixClient(baseUrl, username, password)的構造方法
public class ObixClient {
public ObixClient(String baseUrl, String userName, String password){
this.baseUrl = baseUrl;
this.userName = userName;
this.password = password;
init();
}
//uri中存放著路由地址，然后傳給session，session會在后面用到
private void init() {
Uri uri = new Uri(baseUrl);
session = new ObixSession (uri, userName, password);
}
}
this就是說這個類的當前這個對象，也就是構造方法產(chǎn)生的對象。
以下信息好像并沒有用到
public class NewValueInterfaceImpl implements NewValueInterface{
HashMap<String, Integer> buildNameToId = new HashMap<String, Integer>();
HashMap<String, Integer> deviceNumberToId = new HashMap<String, Integer>();
public NewValueInterfaceImpl(Integer projectId, IDeviceManagementService deviceService, DeviceMapper deviceDao, DeviceTypeMapper deviceTypeDao,BuildMapper buildDao) {
this.deviceDao = deviceDao;
this.deviceTypeDao = deviceTypeDao;
this.buildDao = buildDao;
this.projectId = projectId;
this.deviceService = deviceService;
//遍歷數(shù)據(jù)庫中的建筑，存入map
List<Build> bs = buildDao.selectByExample(new BuildExample());
for(Build b : bs){
buildNameToId.put(b.getName(), b.getId());
}
//遍歷數(shù)據(jù)庫中的設備，存入map
List<Device> ds = deviceDao.selectByExample(new DeviceExample());
for(Device d : ds){
deviceNumberToId.put(d.getNumber(), d.getId());
}
}
}
以上信息好像并沒有用到
接著跑了下面兩個接口
還沒搞懂什么意思以下
public class DiscoverEngine {
//此處一直用內部類來實現(xiàn)，上面定義了一個匿名內部類，此處給匿名內部類賦值
public void setNewValueInterface(NewValueInterface inft){
newValueInterface = inft;
}
//同上
public void setFactorNameDecoderInterface(FactorNameDecoderInterface inft){
factorNameDecoderInterface = inft;
}
}
以上
然后開始無情的 run 起來這個搜索工具
public class DiscoverEngine {
//首先傳進來url地址
public void run(){
readUrl(baseUrl);
}
public void readUrl(String url){
// System.out.println("processing url " + url);
//此處用到session方法
Obj obj = obixClient.read(url);
if(obj == null){
return;
}
//新建一個Obj，用于儲存 out 所對應的 value
Obj outObj = obj.get("out");//此處的out是儲存的值（理解成標簽的ID）
if(outObj != null){
//如果****那么就新建一個fi 將項目信息分項保存
if(this.factorNameDecoderInterface != null){
FactorInfo fi = factorNameDecoderInterface.decode(obj.getHref().get());
if(newValueInterface != null && fi != null){
//如果信息不為空，我們就要準備存讀出來的數(shù)了
newValueInterface.onNewValue(fi, outObj.toString());
}
}
}
else{
for(Obj o : obj.list()){
readUrl(url + o.getHref());
}
}
}
}
下面用到了session
public class ObixClient {
public Obj read(String url){
try {
//根據(jù)我們傳進去的url中讀出一個obj,這個obj如果有value，就返回一個數(shù)，否則就返回地址 />
Obj obj = session.read(new Uri(url));
return obj;
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
}
將URL地址中的信息分項保存
public class FactorNameDecoderObixUrlImpl implements FactorNameDecoderInterface{
@Override
public FactorInfo decode(String url) {
String[] tokens = url.split(":")[2].split("\\/");
//新建一個 對象 將url中解析出的信息分享保存到這個對象中
FactorInfo fi = new FactorInfo();
fi.setDeviceName(tokens[tokens.length - 2]);
fi.setDeviceTypeName(tokens[tokens.length - 3]);
fi.setFactorName(tokens[tokens.length - 1]);
fi.setBuildName("");
fi.setFloorName("");
fi.setProjectName("");
return fi;
}
}
public class NewValueInterfaceImpl implements NewValueInterface{
static ConcurrentHashMap<String, Long> dataInfluxTime = new ConcurrentHashMap<String, Long>();
DeviceMapper deviceDao;
IDeviceManagementService deviceService;
DeviceTypeMapper deviceTypeDao;
BuildMapper buildDao;
Integer projectId;
HashMap<String, Integer> buildNameToId = new HashMap<String, Integer>();
HashMap<String, Integer> deviceNumberToId = new HashMap<String, Integer>();
public NewValueInterfaceImpl(Integer projectId, IDeviceManagementService deviceService, DeviceMapper deviceDao, DeviceTypeMapper deviceTypeDao,BuildMapper buildDao) {
this.deviceDao = deviceDao;
this.deviceTypeDao = deviceTypeDao;
this.buildDao = buildDao;
this.projectId = projectId;
this.deviceService = deviceService;
List<Build> bs = buildDao.selectByExample(new BuildExample());
for(Build b : bs){
buildNameToId.put(b.getName(), b.getId());
}
List<Device> ds = deviceDao.selectByExample(new DeviceExample());
for(Device d : ds){
deviceNumberToId.put(d.getNumber(), d.getId());
}
}
@Override
public void onNewValue(FactorInfo fi, String value) {
//先將URL中的設備名稱信息取出來，然后再取出對應的ID
String number = fi.getDeviceName();
Integer deviceId = deviceNumberToId.get(number);
if(deviceId == null){
number = fi.getDeviceName();
Device record = new Device();
record.setName(number);
record.setNumber(number);
record.setProjectId(projectId);
record.setTypeId(fi.getDeviceTypeId());
deviceService.insert(record );
deviceId = record.getId();
System.out.println("found new device id=" + deviceId + ", name=" + number);
deviceNumberToId.put(number, deviceId);
}
Double val = null;
//然后將ID存入device中
Device updateRecord = new Device();
updateRecord.setId(deviceId);
//將取出的值也存入device
try{
Double d = Double.parseDouble(value);
updateRecord.setCurrentValue(d.intValue());
val = d;
}
catch(Exception e){
if(value.equalsIgnoreCase("true")){
updateRecord.setCurrentValue(1);
val = 1.0;
}
else if(value.equalsIgnoreCase("false")){
updateRecord.setCurrentValue(0);
val = 0.0;
}
}
if(updateRecord.getCurrentValue() != null){
deviceDao.updateByPrimaryKeySelective(updateRecord );
}
//將所得所得數(shù)據(jù)存入influxDB
try{
String timeKey = projectId+"_"+deviceId+"_"+fi.getFactorName();
Long t = dataInfluxTime.get(timeKey);
if(t == null) t = new Long(0);
Long now = System.currentTimeMillis();
if(now - t > 10 * 60 * 1000){
InfluxDBUtil.insert(projectId, deviceId, convert10Minutes(now), fi.getFactorName(), val);
dataInfluxTime.put(timeKey, now);
}
}
catch(Exception e){
e.printStackTrace();
}
}
總結
以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作能帶來一定的幫助，如果有疑問大家可以留言交流，謝謝大家對腳本之家的支持。
相關文章
這篇文章主要介紹了Java 文件解壓縮實現(xiàn)代碼，有需要的朋友可以參考一下2013-12-12
這篇文章主要介紹了Spring-AOP 靜態(tài)普通方法名匹配切面操作，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-07-07
這篇文章主要介紹了Mybatis-Plus的使用詳解,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-10-10
SpringBoot切面實現(xiàn)token權限校驗詳解
這篇文章主要介紹了SpringBoot切面實現(xiàn)token權限校驗詳解,要實現(xiàn)權限校驗,首先數(shù)據(jù)表和實體類上需要有權限字段,我的表中permission和gender是通過外鍵約束permission表和gender表實現(xiàn)枚舉的,因為可拓展性更好,需要的朋友可以參考下2024-01-01
Springboot基于websocket實現(xiàn)簡單在線聊天功能
這篇文章主要介紹了Springboot基于websocket實現(xiàn)簡單在線聊天功能,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-06-06
這篇文章主要介紹了Java?PTA?計算3到7位?水仙花數(shù)實例，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-03-03
這篇文章主要介紹了Java線程池ForkJoinPool實例解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-02-02
這篇文章主要介紹了Java中Minio的基本使用詳解,MinIO 是一個基于Apache License v2.0開源協(xié)議的對象存儲服務,它兼容亞馬遜S3云存儲服務接口,非常適合于存儲大容量非結構化的數(shù)據(jù),例如圖片、視頻、日志文件、備份數(shù)據(jù)和容器/虛擬機鏡像等,需要的朋友可以參考下2024-01-01
spring boot 常見http請求url參數(shù)獲取方法
這篇文章主要介紹了spring boot 常見http請求url參數(shù)獲取,本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2021-03-03
springboot下mybatis-plus開啟打印sql日志的配置指南
這篇文章主要給大家介紹了關于springboot下mybatis-plus開啟打印sql日志的配置指南的相關資料,還介紹了關閉打印的方法,文中通過實例代碼介紹的非常詳細,需要的朋友可以參考下2023-03-03