3

应用程序

我正在用 Java 编写一个客户端/服务器应用程序，它通过使用 ObjectStream 类通过套接字发送对象来进行通信。应用程序中的每个节点大致如下所示：

class Node {
  SocketServer server;
  Socket[] clients;
}

这里server变量是本节点监听client的套接字，变量是其他节点监听的套接字，以及本节点发送对象的套接字。

我用来将对象写入其中一个客户端套接字的代码如下所示：

void sendMessage(Message<B, F> msg) throws IOException {
    ObjectOutputStream writer = getWriter();
    writer.writeObject(msg);
    writer.flush();
}

private ObjectOutputStream writer;

ObjectOutputStream getWriter() throws IOException {
    if (writer == null)
        writer = new ObjectOutputStream(
            new BufferedOutputStream(client.getOutputStream()));
    return writer;
}

我用来处理连接和从节点的服务器套接字读取对象的代码如下所示：

// the handler will listen for connections
final Thread handler = new Thread(new Runnable() {

    public void run() {
        try {
            // create a new thread to handle the client
            final Socket client = server.accept();
            final Thread thread = new Thread(new Runnable() {

                public void run() {
                    final ObjectInputStream reader;
                    try {
                        reader = new ObjectInputStream(client.getInputStream());
                        while (true) {
                            try {
                                val msg = reader.readObject();
                                messages.add((Message<B, F>) msg);
                            }
                            catch (EOFException e) {
                                // i noted it seemed to throw eofexceptions
                            }
                            catch (IOException e) {
                                // do something
                            }
                        }
                    }
                    catch (IOException e) {
                        // do something
                    }
                }
            });
          thread.start();
        } catch (IOException e) {
            // do something
        }
    }
});
handler.start();

问题

我想我在这里的插座做错了什么。当每台服务器只连接到一个客户端时，一切正常。但是，当多个客户端与同一个服务器通信时，事情变得很糟糕，我从 ObjectInputStream 和其他奇怪的行为中得到了 StreamCorruptedException（放入一个 UpdateRequest 消息的实例，并取出一个 Integer(0) 的实例和一些异常，例如。）

我的直觉告诉我，这两个对象/字节流以某种方式混合在一起，这在尝试反序列化对象时会产生奇怪的结果。我的问题是：为什么会发生这种情况，也就是我做错了什么，我该如何解决？

4

2 回答 2

1

你有一个 Sockets 数组，但你似乎没有一个 writer 和 reader 数组。因此，您可能对所有连接使用相同的写入器和读取器。

实际上，您应该有一个每个连接的 Connection 对象，该对象实现 Runnable，并且具有 Socket、编写器和读取器作为实例成员。

此外，当您捕获 EOFException 时，您必须跳出循环并关闭编写器。

于 2011-06-25T00:27:10.423 回答
0

问题是由于同时发送消息而发生的，这导致字节混合。解决方案是确保一次只接收一条消息。

于 2011-08-03T13:40:29.400 回答