🚧 deal with BACnet protocol

Author: sanshengshui

IOT-Guide-Bacnet/pom.xml

@@ -2,18 +2,70 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0"
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
     <parent>
         <artifactId>IOT-Guide</artifactId>
         <groupId>iot.technology</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>
-    <modelVersion>4.0.0</modelVersion>
 
+    <name>IOT Technology Guide :: Bacnet</name>
     <artifactId>IOT-Guide-Bacnet</artifactId>
 
     <properties>
-        <maven.compiler.source>11</maven.compiler.source>
-        <maven.compiler.target>11</maven.compiler.target>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+        <bacnet4j.version>5.0.2</bacnet4j.version>
     </properties>
 
+    <dependencies>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>log4j-over-slf4j</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>ch.qos.logback</groupId>
+            <artifactId>logback-core</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>ch.qos.logback</groupId>
+            <artifactId>logback-classic</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.infiniteautomation</groupId>
+            <artifactId>bacnet4j</artifactId>
+            <version>${bacnet4j.version}</version>
+        </dependency>
+    </dependencies>
+
+    <repositories>
+        <repository>
+            <releases>
+                <enabled>false</enabled>
+            </releases>
+            <snapshots>
+                <enabled>true</enabled>
+            </snapshots>
+            <id>ias-snapshots</id>
+            <name>Infinite Automation Snapshot Repository</name>
+            <url>https://maven.mangoautomation.net/repository/ias-snapshot/</url>
+        </repository>
+        <repository>
+            <releases>
+                <enabled>true</enabled>
+            </releases>
+            <snapshots>
+                <enabled>false</enabled>
+            </snapshots>
+            <id>ias-releases</id>
+            <name>Infinite Automation Release Repository</name>
+            <url>https://maven.mangoautomation.net/repository/ias-release/</url>
+        </repository>
+    </repositories>
+
+
 </project>

IOT-Guide-Bacnet/src/main/java/iot/technology/bacnet/BacnetYabeReadTest.java

@@ -0,0 +1,28 @@
+package iot.technology.bacnet;
+
+import com.serotonin.bacnet4j.LocalDevice;
+import com.serotonin.bacnet4j.RemoteDevice;
+import com.serotonin.bacnet4j.exception.BACnetException;
+import com.serotonin.bacnet4j.npdu.ip.IpNetwork;
+import com.serotonin.bacnet4j.type.primitive.ObjectIdentifier;
+import com.serotonin.bacnet4j.util.RequestUtils;
+import iot.technology.bacnet.util.BACnetUtil;
+import lombok.extern.slf4j.Slf4j;
+
+import java.util.List;
+
+@Slf4j
+public class BacnetYabeReadTest {
+
+    public static void main(String[] args) throws BACnetException {
+        IpNetwork ipNetwork = BACnetUtil.initIpNetwork("172.30.176.1", 47808);
+        LocalDevice localDevice = BACnetUtil.initLocalDevice(123, ipNetwork);
+
+        RemoteDevice remoteDevice = localDevice.getRemoteDeviceBlocking(2130082);
+
+        List<ObjectIdentifier> objectList = RequestUtils.getObjectList(localDevice, remoteDevice).getValues();
+        objectList.forEach(objectIdentifier -> {
+            log.info("objectIdentifier: {}", objectIdentifier);
+        });
+    }
+}

IOT-Guide-Bacnet/src/main/java/iot/technology/bacnet/package_info.java

@@ -0,0 +1,47 @@
+package iot.technology.bacnet.util;
+
+import com.serotonin.bacnet4j.LocalDevice;
+import com.serotonin.bacnet4j.npdu.ip.IpNetwork;
+import com.serotonin.bacnet4j.npdu.ip.IpNetworkBuilder;
+import com.serotonin.bacnet4j.transport.DefaultTransport;
+
+public class BACnetUtil {
+
+    /**
+     * 创建网络对象
+     *
+     * @param ip 网络地址
+     * @param port 端口
+     * @return
+     */
+    public static IpNetwork initIpNetwork(String ip, int port) {
+        IpNetwork ipNetwork = new IpNetworkBuilder()
+                //本机ip
+                .withLocalBindAddress(ip)
+                .withSubnet("255.255.255.0", 24)
+                .withPort(port)
+                .withReuseAddress(true)
+                .build();
+        return ipNetwork;
+
+    }
+
+    /**
+     * 创建虚拟的本地设备， deviceNumber随意
+     *
+     * @param deviceNumber 设备标识
+     * @param ipNetwork 网络对象
+     * @return
+     */
+    public static LocalDevice initLocalDevice(int deviceNumber, IpNetwork ipNetwork) {
+        LocalDevice localDevice = new LocalDevice(deviceNumber, new DefaultTransport(ipNetwork));
+        try {
+            //初始化
+            localDevice.initialize();
+            localDevice.startRemoteDeviceDiscovery();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return localDevice;
+    }
+}