获取楼宇系统的温湿度,BACnet/IP之BACnet4j学习java代码例子属性读写同网段跨主机

龙哥4个月前软硬件集成250

第一次接触BACnet ip,开发语言使用java,网上搜了下,都是推荐使用BACnet4j,但是找不到完整的demo,折腾了一段时间,勉强跑通了自己写的demo,读取到的设备模拟器上的数据。

1.下载Yabe设备模拟器

  链接: https://pan.baidu.com/s/1OK1uq-tfU-XoOH10h4Otag 提取码: 4eu4


安装后

打开太阳的图标

这是设备模拟器,Yabe还提供了一个客户端,打开放大镜图标

可以在client端看到相关的数据信息。

2.下载BACnet4j

https://github.com/infiniteautomation/BACnet4J


下载需要的版本,本博文的代码使用的是5.0.2版本,然后本地安装 mvn install -Dmaven.test.skip=true


或者下载我打包好的jar包


链接:https://pan.baidu.com/s/1KhCfDM_V8Ez_FXJ_CxyoWw 

提取码:1234


3.写demo代码

创建maven项目,pom.xml引入BACnet4j(上面下载安装的),比如

<dependencies>
	<!-- https://github.com/infiniteautomation/BACnet4J -->
	<dependency>
		<groupId>com.infiniteautomation</groupId>
	    <artifactId>bacnet4j</artifactId>
	    <version>5.0.2</version>
	</dependency>
</dependencies>


package utils.bacnet;
 
import java.util.Arrays;
import java.util.List;
 
import com.serotonin.bacnet4j.LocalDevice;
import com.serotonin.bacnet4j.RemoteDevice;
import com.serotonin.bacnet4j.npdu.ip.IpNetwork;
import com.serotonin.bacnet4j.npdu.ip.IpNetworkBuilder;
import com.serotonin.bacnet4j.transport.DefaultTransport;
import com.serotonin.bacnet4j.type.Encodable;
import com.serotonin.bacnet4j.type.enumerated.ObjectType;
import com.serotonin.bacnet4j.type.enumerated.PropertyIdentifier;
import com.serotonin.bacnet4j.type.primitive.ObjectIdentifier;
import com.serotonin.bacnet4j.type.primitive.UnsignedInteger;
import com.serotonin.bacnet4j.util.PropertyValues;
import com.serotonin.bacnet4j.util.ReadListener;
import com.serotonin.bacnet4j.util.RequestUtils;
 
/**
 * 启动Yabe的天气模拟
 * @author Jfei
 *
 */
public class ReadTest1 {
 
	/**
	 * 同一网段读取
	 * @param args
	 * @throws Exception 
	 */
	public static void main(String[] args) throws Exception {
		LocalDevice d = null;
		try {
			//创建网络对象
			IpNetwork ipNetwork = new IpNetworkBuilder()
					 .withLocalBindAddress("192.168.1.245")//本机的ip
					 .withSubnet("255.255.255.0", 24)
					 .withPort(47808) //Yabe默认的UDP端口
					 .withReuseAddress(true)
					 .build();
			//创建虚拟的本地设备,deviceNumber随意
			 d = new LocalDevice(123, new DefaultTransport(ipNetwork));
			 d.initialize();
			 d.startRemoteDeviceDiscovery();
			 
			 RemoteDevice rd = d.getRemoteDeviceBlocking(2457706);//获取远程设备,instanceNumber 是设备的device id
			 
			 System.out.println("modelName=" + rd.getDeviceProperty( PropertyIdentifier.modelName));
			 System.out.println("analogInput2= " +RequestUtils.readProperty(d, rd, new ObjectIdentifier(ObjectType.analogInput, 2), PropertyIdentifier.presentValue, null));
			 
			 
			 List<ObjectIdentifier> objectList =  RequestUtils.getObjectList(d, rd).getValues();
			 
			 //打印所有的Object 名称
			 for(ObjectIdentifier o : objectList){
				 System.out.println(o);
			 }
			 
			
			 ObjectIdentifier oid = new ObjectIdentifier(ObjectType.analogInput, 0);
		     ObjectIdentifier oid1 = new ObjectIdentifier(ObjectType.analogInput, 1);
		     ObjectIdentifier oid2 = new ObjectIdentifier(ObjectType.analogInput, 2);
		     
		     //获取指定的presentValue
	         PropertyValues pvs = RequestUtils.readOidPresentValues(d, rd,Arrays.asList(oid,oid1,oid2), new ReadListener(){
				@Override
				public boolean progress(double progress, int deviceId,
						ObjectIdentifier oid, PropertyIdentifier pid,
						UnsignedInteger pin, Encodable value) {
					System.out.println("========");
					System.out.println("progress=" + progress);
					System.out.println("deviceId=" + deviceId);
					System.out.println("oid="+oid.toString());
					System.out.println("pid="+pid.toString());
					System.out.println("UnsignedInteger="+pin);
					System.out.println("value="+value.toString() + "  getClass =" +value.getClass());
					return false;
				}
	        	 
	         });
	         Thread.sleep(3000);
	         System.out.println("analogInput:0 == " + pvs.get(oid, PropertyIdentifier.presentValue));
	       //获取指定的presentValue
	         PropertyValues pvs2 = RequestUtils.readOidPresentValues(d, rd,Arrays.asList(oid,oid1,oid2),null);
	         System.out.println("analogInput:1 == " + pvs2.get(oid1, PropertyIdentifier.presentValue));
	         
	         d.terminate();
		} catch (Exception e) {
			e.printStackTrace();
			if(d != null){
				d.terminate();
			}
		}
		
	}
}
package utils.bacnet;
 
import java.util.Arrays;
import java.util.List;
 
import com.serotonin.bacnet4j.LocalDevice;
import com.serotonin.bacnet4j.RemoteDevice;
import com.serotonin.bacnet4j.npdu.ip.IpNetwork;
import com.serotonin.bacnet4j.npdu.ip.IpNetworkBuilder;
import com.serotonin.bacnet4j.npdu.ip.IpNetworkUtils;
import com.serotonin.bacnet4j.service.acknowledgement.ReadPropertyAck;
import com.serotonin.bacnet4j.service.confirmed.ReadPropertyRequest;
import com.serotonin.bacnet4j.transport.DefaultTransport;
import com.serotonin.bacnet4j.type.Encodable;
import com.serotonin.bacnet4j.type.constructed.Address;
import com.serotonin.bacnet4j.type.enumerated.ObjectType;
import com.serotonin.bacnet4j.type.enumerated.PropertyIdentifier;
import com.serotonin.bacnet4j.type.primitive.ObjectIdentifier;
import com.serotonin.bacnet4j.type.primitive.UnsignedInteger;
import com.serotonin.bacnet4j.util.PropertyValues;
import com.serotonin.bacnet4j.util.ReadListener;
import com.serotonin.bacnet4j.util.RequestUtils;
 
/**
 * 启动Yabe的天气模拟
 * @author Jfei
 *
 */
public class ReadTest2 {
 
	/**
	 * 跨网段读取
	 * @param args
	 * @throws Exception 
	 */
	public static void main(String[] args) throws Exception {
		LocalDevice d = null;
		try {
			//创建网络对象
			IpNetwork ipNetwork = new IpNetworkBuilder()
	                .withLocalBindAddress("192.168.1.245")
	                .withSubnet("255.255.255.0", 24)
	                .withPort(47808)
	                .withReuseAddress(true)
	                .build();
	        d = new LocalDevice(201, new DefaultTransport(ipNetwork));
	        d.initialize();
	        Address address = new Address(IpNetworkUtils.toOctetString("111.111.51.71:77"));
	        ObjectIdentifier AI = new ObjectIdentifier(ObjectType.analogValue, 3);
	        ReadPropertyAck ack = (ReadPropertyAck) d.send(address, new ReadPropertyRequest(AI, PropertyIdentifier.presentValue, null)).get();
	        //System.out.println(ack.getValue());
	        d.terminate();
			 d.startRemoteDeviceDiscovery();
			 
			 RemoteDevice rd = d.getRemoteDeviceBlocking(2457706);//获取远程设备,instanceNumber 是设备的device id
			 
			 System.out.println("modelName=" + rd.getDeviceProperty( PropertyIdentifier.modelName));
			 System.out.println("analogInput2= " +RequestUtils.readProperty(d, rd, new ObjectIdentifier(ObjectType.analogInput, 2), PropertyIdentifier.presentValue, null));
			 
			 
			 List<ObjectIdentifier> objectList =  RequestUtils.getObjectList(d, rd).getValues();
			 
			 //打印所有的Object 名称
			 for(ObjectIdentifier o : objectList){
				 System.out.println(o);
			 }
			 
			
			 ObjectIdentifier oid = new ObjectIdentifier(ObjectType.analogInput, 0);
		     ObjectIdentifier oid1 = new ObjectIdentifier(ObjectType.analogInput, 1);
		     ObjectIdentifier oid2 = new ObjectIdentifier(ObjectType.analogInput, 2);
		     
		     //获取指定的presentValue
	         PropertyValues pvs = RequestUtils.readOidPresentValues(d, rd,Arrays.asList(oid,oid1,oid2), new ReadListener(){
				@Override
				public boolean progress(double progress, int deviceId,
						ObjectIdentifier oid, PropertyIdentifier pid,
						UnsignedInteger pin, Encodable value) {
					System.out.println("========");
					System.out.println("progress=" + progress);
					System.out.println("deviceId=" + deviceId);
					System.out.println("oid="+oid.toString());
					System.out.println("pid="+pid.toString());
					System.out.println("UnsignedInteger="+pin);
					System.out.println("value="+value.toString() + "  getClass =" +value.getClass());
					return false;
				}
	        	 
	         });
	         Thread.sleep(3000);
	         System.out.println("analogInput:0 == " + pvs.get(oid, PropertyIdentifier.presentValue));
	       //获取指定的presentValue
	         PropertyValues pvs2 = RequestUtils.readOidPresentValues(d, rd,Arrays.asList(oid,oid1,oid2),null);
	         System.out.println("analogInput:1 == " + pvs2.get(oid1, PropertyIdentifier.presentValue));
	         
	         d.terminate();
		} catch (Exception e) {
			e.printStackTrace();
			if(d != null){
				d.terminate();
			}
		}
		
	}
}


package utils.bacnet;
 
import com.serotonin.bacnet4j.LocalDevice;
import com.serotonin.bacnet4j.RemoteDevice;
import com.serotonin.bacnet4j.npdu.ip.IpNetwork;
import com.serotonin.bacnet4j.npdu.ip.IpNetworkBuilder;
import com.serotonin.bacnet4j.transport.DefaultTransport;
import com.serotonin.bacnet4j.type.enumerated.ObjectType;
import com.serotonin.bacnet4j.type.enumerated.PropertyIdentifier;
import com.serotonin.bacnet4j.type.primitive.Boolean;
import com.serotonin.bacnet4j.type.primitive.ObjectIdentifier;
import com.serotonin.bacnet4j.type.primitive.Real;
import com.serotonin.bacnet4j.util.RequestUtils;
 
/**
 * 写入修改数据
 * @author nbuu
 *
 */
public class WriteTest1 {
 
	public static void main(String[] args) throws Exception {
		LocalDevice d = null;
		try {
			IpNetwork ipNetwork = new IpNetworkBuilder()
			 .withLocalBindAddress("192.168.1.114")
			 .withSubnet("255.255.255.0", 24)
			 .withPort(47808)
			 .withReuseAddress(true)
			 .build();
			
			d = new LocalDevice(123, new DefaultTransport(ipNetwork));
			d.initialize();
			d.startRemoteDeviceDiscovery();
			
			RemoteDevice rd = d.getRemoteDevice(3).get();//获取远程设备
			
			//必须先修改out of service为true
	        RequestUtils.writeProperty(d, rd, new ObjectIdentifier(ObjectType.analogValue, 0),PropertyIdentifier.outOfService, Boolean.TRUE);
	        Thread.sleep(1000);
	        //修改属性值
			RequestUtils.writePresentValue(d, rd, new ObjectIdentifier(ObjectType.analogValue, 0), new Real(77));
			Thread.sleep(2000);
			System.out.println("analogValue0= " +RequestUtils.readProperty(d, rd, new ObjectIdentifier(ObjectType.analogValue, 0), PropertyIdentifier.presentValue, null));
			 
			 Thread.sleep(1000);
			d.terminate();
		} catch (Exception e) {
			e.printStackTrace();
			if(d != null){
				d.terminate();
			}
		}
		
	}
}


参考

https://blog.csdn.net/dream_broken/article/details/106646604

https://blog.csdn.net/dream_broken/article/details/106659096


作者:龙哥leon
链接:http://anool.net
著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。 如果觉得文章对你有帮助,可以请我喝杯咖啡

相关文章

涂鸦iot实战

涂鸦iot实战批量获取灯光id,循环调用灯光开关和亮度...

热成像模块对接

热成像模块对接头部热成像系统,将人脸照片和温度数据上传到我们的安卓app或者网页,进行展示...

zkteco iface702 (也可能叫IF702+ic) 中控考勤机java开发步骤一---连接考勤机 ,开门

中控脱机通讯开发包-6.3.1.38 里面有zkemkeeper.dll链接:https://pan.baidu.com/s/1kC5chunZmquh1ucKY7jNIw 提取码:1234...

室内蓝牙定位技术

一个基站布置好后,厂商的服务装好之后,44444端口下有些接口可以查询,当前蓝牙设备的xy坐标和数据更新时间...

对接中控门禁

厂商提供了一个java项目叫attpush大概流程就是启动这个项目比如192.168.1.19:8085门禁上去设置服务器的ip和端口门禁的用户和通行记录他会上传到attpush,这样你就可以选择上传...

TM机械臂对接,智慧档案抓取机器人

TM机械臂对接机械臂监听服务器广播的指令,进行一系列机械臂操作,目前,用于档案的抓取...

发表评论    

◎欢迎参与讨论,请在这里发表您的看法、交流您的观点。