Rose博客

public class BACnetClientTest {
    public static void main(String[] args) {
        IpNetwork network = new IpNetworkBuilder()
                .withSubnet("255.255.255.0", 24)
                .withPort(47809)
                .withReuseAddress(true)
                .build();
        int localDeviceId = RandomUtil.randomInt(10000);

        LocalDevice localDevice = new LocalDevice(localDeviceId, new DefaultTransport(network));
        BACnetClient client = new BACnetXClient(localDevice);
        client.start();

        int deviceId = 2605;

        localDevice.send(IpNetworkUtils.toAddress("192.168.0.220", 47808), new WhoIsRequest(deviceId, deviceId));
        RemoteDeviceFinder.RemoteDeviceFuture future = localDevice.getRemoteDevice(deviceId);

        RemoteDevice remoteDevice = null;
        try {
             remoteDevice = future.get(3000L);
        } catch (BACnetException e) {
            e.printStackTrace();
        }

        DefaultDeviceFactory defaultDeviceFactory = new DefaultDeviceFactory();
        Device device = defaultDeviceFactory.createDevice(remoteDevice);
        
        BACnetObject BACnetObject = new BACnetObject(device, 0,  BACnetObjectTypeEnum.ANALOG_INPUT.getType());
        Object read =  client.getPresentValue(BACnetObject, (BACnetToJavaConverter<Object>) encodable -> Double.parseDouble(encodable.toString()));
        System.out.println("read " + read);
    }
}

IpNetwork network = new IpNetworkBuilder()
        .withSubnet("255.255.255.0", 24)   // 设置子网掩码和前缀长度
        .withPort(47809)				// 设置本地设备的端口号
        .withReuseAddress(true)			// 允许重用地址
        .build();
int localDeviceId = RandomUtil.randomInt(10000); // 使用随机id

LocalDevice localDevice = new LocalDevice(localDeviceId, new DefaultTransport(network));

BACnetClient client = new BACnetXClient(localDevice);
client.start();			// 启动客户端

int deviceId = 2605;
localDevice.send(IpNetworkUtils.toAddress("192.168.0.220", 47808), new WhoIsRequest(deviceId, deviceId));   

RemoteDeviceFinder.RemoteDeviceFuture future = localDevice.getRemoteDevice(deviceId);

RemoteDevice remoteDevice = null;
try {
    remoteDevice = future.get(3000L);  //  等待 3000 毫秒以获取远程设备
} catch (BACnetException e) {
    e.printStackTrace();
}

DefaultDeviceFactory defaultDeviceFactory = new DefaultDeviceFactory();
Device device = defaultDeviceFactory.createDevice(remoteDevice);

BACnetObject BACnetObject = new BACnetObject(device, 0, BACnetObjectTypeEnum.ANALOG_INPUT.getType());	// 创建一个BACnet的数据类型	
Object read = client.getPresentValue(BACnetObject, (BACnetToJavaConverter<Object>) encodable -> Double.parseDouble(encodable.toString()));		// 读取属性值
System.out.println("read " + read);

BACnetObject BACnetObject = new BACnetObject(device, 0,  BACnetObjectTypeEnum.ANALOG_OUTPUT.getType());				// 创建 AO 0 点
client.setPresentValue(BACnetObject, 3.0D, (JavaToBACnetConverter<Object>) e -> new Real((float) ((Double)e).doubleValue()));		// 设置点位值为 3.0

public synchronized LocalDevice initialize(RestartReason lastRestartReason) throws Exception {
        this.deviceObject.writePropertyInternal(PropertyIdentifier.lastRestartReason, lastRestartReason);
        this.timer = this.createScheduledExecutorService();
        this.transport.initialize();   // 初始化 transport
        this.initialized = true;
    
    // 省略其他
}

public void run() {
        while(this.running) {
            boolean pause = true;
            Outgoing out = (Outgoing)this.outgoing.poll();
            if (out != null) {
                try {
                    out.send();	  // 最终使用network发送请求
                } catch (Exception var8) {}
                pause = false;
            }

            NPDU in = (NPDU)this.incoming.poll();
            if (in != null) {
                try {
                    this.receiveImpl(in);
                } catch (Exception var7) {}
                pause = false;
            }

            // 省略部分代码
            if (pause && this.running) {
                ThreadUtils.waitSync(this.pauseLock, 50L);  // 等待
            }
        }

    }

public void initialize(Transport transport) throws Exception {
        super.initialize(transport);
    	// 初始化 用户数据包套接字 UDP
        this.localBindAddress = InetAddrCache.get(this.localBindAddressStr, this.port);
    
        if (this.reuseAddress) {
            this.socket = new DatagramSocket((SocketAddress)null);
            this.socket.setReuseAddress(true);
            if (!this.socket.getReuseAddress()) {
                LOG.warn("reuseAddress was set, but not supported by the underlying platform");
            }

            this.socket.bind(this.localBindAddress);
        } else {
            this.socket = new DatagramSocket(this.localBindAddress);
        }

		// 启动线程
        this.thread = new Thread(this, "BACnet4J IP socket listener for " + transport.getLocalDevice().getId());
        this.thread.start();
    }

public void run() {
        byte[] buffer = new byte[2048];		// 2M的缓存区
        DatagramPacket p = new DatagramPacket(buffer, buffer.length);

        while(!this.socket.isClosed()) {
            try {
                this.socket.receive(p);		// 接收数据
                this.bytesIn += (long)p.getLength();
                ByteQueue queue = new ByteQueue(p.getData(), 0, p.getLength());
                OctetString link = IpNetworkUtils.toOctetString(p.getAddress().getAddress(), p.getPort());
                this.handleIncomingData(queue, link);  // 处理数据
                p.setData(buffer);
            } catch (IOException var5) {
            }
        }

}

/**
 * 将数据转成NPDU在放置到incoming队列
 */
protected void handleIncomingData(ByteQueue queue, OctetString linkService) {
        try {
            // 根据不同ip协议有不同实现来处理数据
            NPDU npdu = this.handleIncomingDataImpl(queue, linkService);
            if (npdu != null) {
                this.getTransport().incoming(npdu);
            }
        } catch (Exception var4) {}

}

import com.serotonin.bacnet4j.LocalDevice;
import com.serotonin.bacnet4j.type.constructed.ReadAccessResult;
import com.serotonin.bacnet4j.type.constructed.SequenceOf;
import org.code_house.bacnet4j.wrapper.api.BacNetClientBase;
import org.code_house.bacnet4j.wrapper.api.BacNetObject;
import org.code_house.bacnet4j.wrapper.api.Device;
import org.code_house.bacnet4j.wrapper.api.Type;


public class BacNetXClient extends BacNetClientBase {

    public BacNetXClient(LocalDevice localDevice) {
        super(localDevice);
    }

    @Override
    protected BacNetObject createObject(Device device, int instance, Type type, SequenceOf<ReadAccessResult> readAccessResults) {

        if (readAccessResults.size() == 1) {
            SequenceOf<ReadAccessResult.Result> results = readAccessResults.get(0).getListOfResults();
            if (results.size() == 4) {
                String name = results.get(2).toString();
                String units = results.get(1).toString();
                String description = results.get(3).toString();
                return new BacNetObject(device, instance, type, name, description, units);
            }
            throw new IllegalStateException("Unsupported response structure " + readAccessResults);
        }
        String name = getReadValue(readAccessResults.get(2));
        String units = getReadValue(readAccessResults.get(1));
        String description = getReadValue(readAccessResults.get(3));
        return new BacNetObject(device, instance, type, name, description, units);
    }

    private String getReadValue(ReadAccessResult readAccessResult) {
        // first index contains 0 value.. I know it is weird, but that's how bacnet4j works
        return readAccessResult.getListOfResults().get(0).getReadResult().toString();
    }

}