Java无效的流标头[重复]

Question

我正在编写一个应该在线玩的游戏。我有一个服务器，每次客户端连接时都会启动新的Thread。然后客户端使用ObjectInputStream 和ObjectOutputStream 与这个Thread 通信。在此通信中，客户可以开始新游戏或选择现有游戏加入。如果客户端加入现有游戏，服务器会与游戏实例启动一个新的Thread，并且该游戏实例应该开始与客户端进行自己的通信。我将Sockets 传递给这个游戏实例，但是当我尝试向客户端发送一些消息时，只有其中一个能正确接收到它。第二个客户端抛出异常java.io.StreamCorruptedException: invalid stream header: 79ACED00。 我使用相同的方法发送消息，所以我不知道为什么它适用于一个客户端以及为什么它不适用于第二个客户端。

这里是创建游戏实例的代码：

GameInstanceDescription joined_game = (GameInstanceDescription) response;
joined_game.setSocket_challenger(socket_from_client);
joined_game.setChallenger(rcvd_msg.getChallenger());
joined_game.setSocket_promoter(game_server.getPromotersSocket(joined_game.getName()));
game_server.startNewGame(joined_game);

在Thread 应该结束的最后一行之后。

这是服务器方法：

public void startNewGame (GameInstanceDescription desc)
{
    Thread t = new Thread(new MainGame(desc));
    t.start();
}

这是从游戏实例向客户端发送消息的方法：

public void sendMessageToClient(ServerToClientMessage message, ObjectOutputStream stream)
{
    try {
        stream.writeObject(message);
        stream.flush();
        stream.reset();
    } catch (IOException e) {
        e.printStackTrace();
    }
}

这里是应该从服务器读取消息的客户端代码，但它只适用于一个客户端，并且这里也会抛出异常：

input = new ObjectInputStream(client.getInputStream());
Object o = input.readObject();

我没有在互联网上找到任何有用的东西可以解决这个问题，所以你能告诉我哪里出了问题吗？ 提前致谢。

Answer 1

不要在每次读取对象时创建一个新的ObjectInputStream（或者每次写入一个对象时都创建一个新的ObjectOutputStream）。在套接字的整个生命周期中使用相同的流。