首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >问答首页 >BACnet客户端未使用BACnet4j连接到BACnet接口

BACnet客户端未使用BACnet4j连接到BACnet接口
EN

Stack Overflow用户
提问于 2017-07-28 16:03:30
回答 3查看 1.2K关注 0票数 0

我是BACnet和其他自动化protocols.We的新手,我们将编写一个BACnet客户端,它将连接到BACnet接口来获取对象,此外,我们将在我们的微服务layer.Our服务器基础设施中摄取这些对象,其中包含LumInsight桌面,它将把数据推送到BACnet接口。我们引用了一个示例代码,但在运行它的过程中,我遇到了以下问题:

代码语言:javascript
运行
复制
> inside main....com.serotonin.bacnet4j.transport.DefaultTransport@7b7221a0
inside main....3996: BACnet device
Exception in thread "main" java.net.BindException: Address already in use: Cannot bind
    at java.net.DualStackPlainDatagramSocketImpl.socketBind(Native Method)
    at java.net.DualStackPlainDatagramSocketImpl.bind0(Unknown Source)
    at java.net.AbstractPlainDatagramSocketImpl.bind(Unknown Source)
    at java.net.DatagramSocket.bind(Unknown Source)
    at java.net.DatagramSocket.<init>(Unknown Source)
    at com.serotonin.bacnet4j.npdu.ip.IpNetwork.initialize(IpNetwork.java:215)
    at com.serotonin.bacnet4j.transport.DefaultTransport.initialize(DefaultTransport.java:183)
    at com.serotonin.bacnet4j.LocalDevice.initialize(LocalDevice.java:228)
    at com.bacnet.Main.main(Main.java:110)


    package com.bacnet;

    import com.serotonin.bacnet4j.LocalDevice;
    import com.serotonin.bacnet4j.RemoteDevice;
    import com.serotonin.bacnet4j.ServiceFuture;
    import com.serotonin.bacnet4j.event.DeviceEventAdapter;
    import com.serotonin.bacnet4j.exception.BACnetException;
    import com.serotonin.bacnet4j.exception.ErrorAPDUException;
    import com.serotonin.bacnet4j.npdu.ip.IpNetwork;
    import com.serotonin.bacnet4j.service.acknowledgement.ReadPropertyAck;
    import com.serotonin.bacnet4j.service.acknowledgement.ReadPropertyMultipleAck;
    import com.serotonin.bacnet4j.service.confirmed.*;
    import com.serotonin.bacnet4j.service.unconfirmed.WhoIsRequest;
    import com.serotonin.bacnet4j.transport.DefaultTransport;
    import com.serotonin.bacnet4j.transport.Transport;
    import com.serotonin.bacnet4j.type.constructed.ReadAccessResult;
    import com.serotonin.bacnet4j.type.constructed.ReadAccessSpecification;
    import com.serotonin.bacnet4j.type.constructed.SequenceOf;
    import com.serotonin.bacnet4j.type.enumerated.ObjectType;
    import com.serotonin.bacnet4j.type.enumerated.PropertyIdentifier;
    import com.serotonin.bacnet4j.type.enumerated.Segmentation;
    import com.serotonin.bacnet4j.type.primitive.ObjectIdentifier;
    import com.serotonin.bacnet4j.type.primitive.Real;
    import com.serotonin.bacnet4j.util.DiscoveryUtils;
    import com.serotonin.bacnet4j.RemoteObject;

    import java.util.ArrayList;
    import java.util.List;

    public class Main {
        public static void main(String[] args) throws Exception {

            IpNetwork network = new IpNetwork("10.44.55.5", IpNetwork.DEFAULT_PORT);

            Transport transport = new DefaultTransport(network);
            System.out.println("inside main...." + transport);
            transport.setTimeout(500);
            transport.setSegTimeout(150);
            final LocalDevice localDevice = new LocalDevice(3996, transport);
            System.out.println("inside main...." + localDevice);
            localDevice.getEventHandler().addListener(new DeviceEventAdapter() {
                @Override
                public void iAmReceived(RemoteDevice device) {
                    System.out.println("inside I am received...");
                    System.out.println("Discovered device " + device);
                    localDevice.addRemoteDevice(device);

                    final RemoteDevice remoteDevice = localDevice
                            .getRemoteDevice(device.getAddress());

                    remoteDevice
                            .setSegmentationSupported(Segmentation.segmentedBoth);
                    new Thread(new Runnable() {
                        @Override
                        public void run() {
                            try {
                                try {
                                    DiscoveryUtils.getExtendedDeviceInformation(
                                            localDevice, remoteDevice);
                                } catch (BACnetException e) {
                                    e.printStackTrace();
                                }
                                System.out.println(remoteDevice.getName() + " "
                                        + remoteDevice.getVendorName() + " "
                                        + remoteDevice.getModelName() + " "
                                        + remoteDevice.getAddress() + " "
                                        + remoteDevice.getProtocolRevision() + " "
                                        + remoteDevice.getProtocolVersion());

                                ReadPropertyAck ack = localDevice.send(
                                        remoteDevice,
                                        new ReadPropertyRequest(remoteDevice
                                                .getObjectIdentifier(),
                                                PropertyIdentifier.objectList))
                                        .get();
                                SequenceOf<ObjectIdentifier> value = ack.getValue();

                                for (ObjectIdentifier id : value) {

                                    List<ReadAccessSpecification> specs = new ArrayList<ReadAccessSpecification>();
                                    specs.add(new ReadAccessSpecification(id,
                                            PropertyIdentifier.presentValue));
                                    specs.add(new ReadAccessSpecification(id,
                                            PropertyIdentifier.units));
                                    specs.add(new ReadAccessSpecification(id,
                                            PropertyIdentifier.objectName));
                                    specs.add(new ReadAccessSpecification(id,
                                            PropertyIdentifier.description));
                                    specs.add(new ReadAccessSpecification(id,
                                            PropertyIdentifier.objectType));
                                    ReadPropertyMultipleRequest multipleRequest = new ReadPropertyMultipleRequest(
                                            new SequenceOf<ReadAccessSpecification>(
                                                    specs));

                                    ReadPropertyMultipleAck send = localDevice
                                            .send(remoteDevice, multipleRequest)
                                            .get();
                                    SequenceOf<ReadAccessResult> readAccessResults = send
                                            .getListOfReadAccessResults();

                                    System.out.print(id.getInstanceNumber() + " "
                                            + id.getObjectType() + ", ");
                                    for (ReadAccessResult result : readAccessResults) {
                                        for (ReadAccessResult.Result r : result
                                                .getListOfResults()) {
                                            System.out.print(r.getReadResult()
                                                    + ", ");
                                        }
                                    }
                                    System.out.println();
                                }

                                ObjectIdentifier mode = new ObjectIdentifier(
                                        ObjectType.analogValue, 11);

                                ServiceFuture send = localDevice.send(remoteDevice,
                                        new WritePropertyRequest(mode,
                                                PropertyIdentifier.presentValue,
                                                null, new Real(2), null));
                                System.out.println(send.getClass());
                                System.out.println(send.get().getClass());

                            } catch (ErrorAPDUException e) {
                                System.out.println("Could not read value "
                                        + e.getApdu().getError() + " " + e);
                            } catch (BACnetException e) {
                                e.printStackTrace();
                            }

                        }
                    }).start();
                }

                @Override
                public void iHaveReceived(RemoteDevice device, RemoteObject object) {
                    System.out.println("Value reported " + device + " " + object);
                }
            });

            localDevice.initialize();
            localDevice.sendGlobalBroadcast(new WhoIsRequest());

            List<RemoteDevice> remoteDevices = localDevice.getRemoteDevices();
            for (RemoteDevice device : remoteDevices) {
                System.out.println("Remote dev " + device);
            }

            System.in.read();
            localDevice.terminate();
        }

    }
EN

回答 3

Stack Overflow用户

发布于 2017-10-03 18:15:45

错误是不言而喻的“地址已在使用”,请检查是否有任何其他客户端正在运行并使用端口47808 (默认端口)。

票数 0
EN

Stack Overflow用户

发布于 2018-06-07 20:01:50

请在终止eclipse中所有当前正在运行的任务后重新运行您的程序。或者执行netstat -a来检查哪个应用程序正在获取47808。

最简单的解决方案是将本地默认端口更改为其他端口,如47809或大于1024时的端口。

以防你还有什么问题。请回复,我已经使用BACnet4j创建了几个客户端。

票数 0
EN

Stack Overflow用户

发布于 2019-02-09 18:33:11

理论上,如果你将套接字设置为“非独占”和“重用”--在你“绑定”到它之前,你只能使用相同的(套接字)端口#,但是尝试共享它可能没有意义,因为只有一个监听器/“客户端”可能在那个UDP端口上/从那个UDP端口接收响应。

始终考虑在另一个端口上发送(“客户端”)请求;如果可以的话,在标准端口#- 47808/0xBAC0上唯一地监听(监听“服务器”响应) (-假设它还没有被积极使用/你不能放弃现有的使用端口号来代替这个/你的新用法/需求)。

对于Windows,你可以从‘命令提示符’中使用'netstat -ao‘cmd-line工具,查看持有/使用端口号的应用程序的" PID“(进程ID),然后你可以在Windows的”任务管理器“中显示PID列,以查看PID映射到哪个应用程序。

票数 0
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/45368061

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档