obix协议在java中的配置和使用详解

前言

本文主要给大家介绍的是关于obix协议在java中的配置和使用，分享出来供大家参考学习，下面话不多说了，来一起看看详细的介绍吧。

什么是 obix?

简单来讲，obix是一种 xml 通讯协议，使用http request/post方式进行数据通讯。所有数据通过可读字符进行传送，一个obix对象可以有唯一的一个url识别。

obix的实现原理

首先数据储存在niagara的服务平台上，我们需要做的是从niagara获取数据，并且储存在influxdb中。下面是实现的流程方法。

• 加粗 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	循环抓取obix传输的数据

1、遍历各个点

2、先遍历各个设备，将相同的typeid的设备存入同一个hashmap中

3、开始执行主程序，先从数据库中查询出项目名称

4、开始搜索！

public class obixfetcher implements jobinterface{
 
 //这个是接口的抽象方法
 public void cycleonce() {
  //从数据库中取出项目信息
  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数据库中将数据取出，存入bulidnametoid（同样还是构造方法）
    //从device数据库中将数据取出，存入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就是说这个类的当前这个对象，也就是构造方法产生的对象。

以下信息好像并没有用到

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;
    //遍历数据库中的建筑，存入map
    list<build> bs = builddao.selectbyexample(new buildexample());
    for(build b : bs){
      buildnametoid.put(b.getname(), b.getid());
    }
    //遍历数据库中的设备，存入map
    list<device> ds = devicedao.selectbyexample(new deviceexample());
    for(device d : ds){
      devicenumbertoid.put(d.getnumber(), d.getid());
    }
  }
}

以上信息好像并没有用到

接着跑了下面两个接口

还没搞懂什么意思以下

public class discoverengine {
  //此处一直用内部类来实现，上面定义了一个匿名内部类，此处给匿名内部类赋值
  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){
          //如果信息不为空，我们就要准备存读出来的数了
          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 {
      //根据我们传进去的url中读出一个obj,这个obj如果有value，就返回一个数，否则就返回地址 href="http://115.28.2.201:28088/obix/config/drivers/niagaranetwork/himalayas_pc/points/himalayas_301/points/jf/"/>
      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 );
    }
    
    //将所得所得数据存入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();
    }
  }

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作能带来一定的帮助，如果有疑问大家可以留言交流，谢谢大家对的支持。