5

我正在制作一个客户端-服务器应用程序，但在读取服务器上的对象时遇到了一些麻烦。

在我的服务器连接到客户端套接字后，我构建对象输入和输出流并将它们传递给我的service()方法。在那里，我应该处理来自客户端的不同类型的消息。我可以从客户端（即Message我的设计中的一个对象）那里得到一条消息就好了。但当然，我想做的是有一个循环，这样我就可以得到一条消息，处理它，然后回复。

到目前为止，我的代码只适用于一条消息。当我添加循环时，每次迭代都会发生什么，我的服务器只是一遍又一遍地读取相同的消息，然后我的客户端有机会通过套接字发送新消息（我认为这是正在发生的事情，至少） .

所以我真正需要做的是弄清楚如何让我的service()方法等待新的输入。有任何想法吗？还是我接近这个错误？我是否需要在每次迭代中创建一个新的 OIS 或...？一些代码：

public void service(ObjectInputStream input, ObjectOutputStream output) throws IOException, Exception {

    _shouldService = true;

    while (_shouldService) {
                    // It just keeps reading the same message over and over
                    // I need it to wait here until the client sends a new message
                    // Unless I'm just approaching this all wrong!
        NetworkMessage message = (NetworkMessage) input.readObject();

        NetworkMessageHeader header = message.getHeader();

        String headerType = header.getType();

        if (headerType.equals(NetworkMessageHeader.NetworkMessageHeaderTypeConnect)) {
            doLoginForMessage(message, output);
        } else if (headerType.equals(NetworkMessageHeader.NetworkMessageHeaderTypeFiles)) {
            doFilesList(message, output);
        } else {
            System.out.println("Unrecognized header type: " + headerType);

        }
    }
}
4

1 回答 1

2

ObjectOutputStream 缓存对象表示，并且不会检测您是否从客户端一遍又一遍地重新发送相同的实例，但其中有更改。如果这是您的场景，您需要reset在每次发送之前调用流。

NetworkMessage message = new NetworkMessage();
for(;;) {
  message.setProperty(whatever);
  oos.reset();
  oos.writeObject(message);
}
于 2012-02-21T22:53:04.150 回答