obix協(xié)議在java中的配置和使用詳解

更新時(shí)間：2017年08月29日 10:58:05 作者：失控的嬰兒車

這篇文章主要給大家介紹了關(guān)于obix協(xié)議在java中的配置和使用，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧。

前言

本文主要給大家介紹的是關(guān)于obix協(xié)議在java中的配置和使用，分享出來供大家參考學(xué)習(xí)，下面話不多說了，來一起看看詳細(xì)的介紹吧。

什么是 oBIX?

簡(jiǎn)單來講，obix是一種 XML 通訊協(xié)議，使用Http Request/Post方式進(jìn)行數(shù)據(jù)通訊。所有數(shù)據(jù)通過可讀字符進(jìn)行傳送，一個(gè)oBIX對(duì)象可以有唯一的一個(gè)URL識(shí)別。

oBIX的實(shí)現(xiàn)原理

首先數(shù)據(jù)儲(chǔ)存在Niagara的服務(wù)平臺(tái)上，我們需要做的是從Niagara獲取數(shù)據(jù)，并且儲(chǔ)存在InfluxDB中。下面是實(shí)現(xiàn)的流程方法。

加粗 Ctrl + B
斜體 Ctrl + I
引用 Ctrl + Q
插入鏈接 Ctrl + L
插入代碼 Ctrl + K
插入圖片 Ctrl + G
提升標(biāo)題 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、遍歷各個(gè)點(diǎn)

2、先遍歷各個(gè)設(shè)備，將相同的typeid的設(shè)備存入同一個(gè)hashmap中

3、開始執(zhí)行主程序，先從數(shù)據(jù)庫(kù)中查詢出項(xiàng)目名稱

4、開始搜索！

public class ObixFetcher implements JobInterface{
 
 //這個(gè)是接口的抽象方法
 public void cycleOnce() {
  //從數(shù)據(jù)庫(kù)中取出項(xiàng)目信息
  List<Project> ps = dao.selectByExample(new ProjectExample());
  //遍歷項(xiàng)目信息，如果項(xiàng)目信息的關(guān)鍵信息不為null
  for(Project p : ps){
   if(p.getObixBaseAddress() != null && p.getObixUsername() != null 
     && p.getObixPassword() != null){
    //開啟探索工具 （應(yīng)該還是一個(gè)內(nèi)部類），將關(guān)鍵項(xiàng)目信息傳入探索工具，
    DiscoverEngine de = new DiscoverEngine(p.getObixBaseAddress(),
      p.getObixUsername(), p.getObixPassword());
    //從build數(shù)據(jù)庫(kù)中將數(shù)據(jù)取出，存入bulidNameToId（同樣還是構(gòu)造方法）
    //從device數(shù)據(jù)庫(kù)中將數(shù)據(jù)取出，存入deviceNumberToId（同樣還是構(gòu)造方法）
    de.setNewValueInterface(new NewValueInterfaceImpl(p.getId(), deviceService, deviceDao, deviceTypeDao, buildDao));
    //return回來一個(gè)FactorInfo
    de.setFactorNameDecoderInterface(new FactorNameDecoderObixUrlImpl());
    de.run();
   }
  }
 }
}

以下是上文 DiscoverEngine de的構(gòu)造方法

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)的構(gòu)造方法

public class ObixClient {
  public ObixClient(String baseUrl, String userName, String password){
    
    this.baseUrl = baseUrl;
    this.userName = userName;
    this.password = password;
    
    init();
  }
  //uri中存放著路由地址，然后傳給session，session會(huì)在后面用到
  private void init() {
    Uri uri = new Uri(baseUrl); 
    session = new ObixSession (uri, userName, password);
  }
}

this就是說這個(gè)類的當(dāng)前這個(gè)對(duì)象，也就是構(gòu)造方法產(chǎn)生的對(duì)象。

以下信息好像并沒有用到

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ù)庫(kù)中的建筑，存入map
    List<Build> bs = buildDao.selectByExample(new BuildExample());
    for(Build b : bs){
      buildNameToId.put(b.getName(), b.getId());
    }
    //遍歷數(shù)據(jù)庫(kù)中的設(shè)備，存入map
    List<Device> ds = deviceDao.selectByExample(new DeviceExample());
    for(Device d : ds){
      deviceNumberToId.put(d.getNumber(), d.getId());
    }
  }
}

以上信息好像并沒有用到

接著跑了下面兩個(gè)接口

還沒搞懂什么意思以下

public class DiscoverEngine {
  //此處一直用內(nèi)部類來實(shí)現(xiàn)，上面定義了一個(gè)匿名內(nèi)部類，此處給匿名內(nèi)部類賦值
  public void setNewValueInterface(NewValueInterface inft){
    newValueInterface = inft;
  }
  //同上
  public void setFactorNameDecoderInterface(FactorNameDecoderInterface inft){
    factorNameDecoderInterface = inft;
  }
}

以上

然后開始無情的 run 起來這個(gè)搜索工具

public class DiscoverEngine {
  //首先傳進(jìn)來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;
    }
    //新建一個(gè)Obj，用于儲(chǔ)存 out 所對(duì)應(yīng)的 value
    Obj outObj = obj.get("out");//此處的out是儲(chǔ)存的值（理解成標(biāo)簽的ID）
    if(outObj != null){
      //如果****那么就新建一個(gè)fi 將項(xiàng)目信息分項(xiàng)保存
      if(this.factorNameDecoderInterface != null){
        FactorInfo fi = factorNameDecoderInterface.decode(obj.getHref().get());
        if(newValueInterface != null && fi != null){
          //如果信息不為空，我們就要準(zhǔn)備存讀出來的數(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ù)我們傳進(jìn)去的url中讀出一個(gè)obj,這個(gè)obj如果有value，就返回一個(gè)數(shù)，否則就返回地址 />
      Obj obj = session.read(new Uri(url));
      return obj;
    } catch (Exception e) {
      e.printStackTrace();
      
      return null;
    }
  }
}

將URL地址中的信息分項(xiàng)保存

public class FactorNameDecoderObixUrlImpl implements FactorNameDecoderInterface{

  @Override
  public FactorInfo decode(String url) {

    
    String[] tokens = url.split(":")[2].split("\\/");
    //新建一個(gè) 對(duì)象 將url中解析出的信息分享保存到這個(gè)對(duì)象中
    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中的設(shè)備名稱信息取出來，然后再取出對(duì)應(yīng)的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();
    }
  }

總結(jié)

以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作能帶來一定的幫助，如果有疑問大家可以留言交流，謝謝大家對(duì)腳本之家的支持。