0

我有一个 Java 电子表格应用程序,它提供的功能之一(我开发的)是工作表共享。基本上,任何人都可以是客户端或服务器,因为该应用程序同时具有服务器和客户端代码。作为服务器的用户创建共享,指定 IP,然后创建共享并激活(最佳情况),服务器在其 IP 和选定端口上侦听客户端。

对于自动发现,我通过 UDP 广播使用 DatagramSockets,而“真正的通信”是基于 TCP 的(在客户端已经连接之后)。

我已经有这段代码可以将活动共享列表从服务器发送到客户端(它发送一个Listof InetSocketAddress)。

服务器:

public class BroadcastList implements Runnable {
        private final int BROADCAST_PORT = 8888;

        public BroadcastList() {
        }

        @Override
        public void run() {
            try {
                ActiveShareList asl = new ActiveShareList();
                List<InetSocketAddress> shareList = asl.getActiveShareList();
                DatagramSocket broadcast = new DatagramSocket(BROADCAST_PORT);
                ByteArrayOutputStream out = new ByteArrayOutputStream();
                ObjectOutputStream outputStream = new ObjectOutputStream(out);
                outputStream.writeObject(shareList);
                outputStream.close();

                byte[] listData = out.toByteArray();
                byte[] message = new byte[10];

                DatagramPacket listPacket = new DatagramPacket(listData, listData.length);
                DatagramPacket messagePacket = new DatagramPacket(message, message.length);

                broadcast.receive(messagePacket);
                broadcast.send(listPacket);

            } catch (IOException ex) {
                ex.printStackTrace();
            }
        }
    }

客户端:

public void getShareList() {
        DatagramSocket socket;
        try {
            InetSocketAddress address = new InetSocketAddress("255.255.255.255", 8888);
            socket = new DatagramSocket();

            byte[] buffer = new byte[10];
            List<InetSocketAddress> shareList = new ArrayList<InetSocketAddress>();
            byte[] listData = new byte[65535];
            DatagramPacket messagePacket = new DatagramPacket(buffer, buffer.length, address.getAddress(), address.getPort());
            DatagramPacket listPacket = new DatagramPacket(listData, listData.length);

            socket.send(messagePacket);
            socket.receive(listPacket);
            ObjectInputStream inputStream = new ObjectInputStream(new ByteArrayInputStream(listData));

            try {
                shareList = (List<InetSocketAddress>) inputStream.readObject();
            } catch (ClassNotFoundException ex) {
                Logger.getLogger(JoinShareAction.class.getName()).log(Level.SEVERE, null, ex);
            }

}

问题出在客户身上,它java.io.IOException: Can't assign requested address在这一行给我一个错误:socket.send(messagePacket);

有谁知道是什么问题?

4

0 回答 0