Java 无效流 header

Question

我正在编写一个应该在线玩的游戏。我有一个每次客户端连接时都会启动 new 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）。在套接字的生命周期内使用相同的流。

Java 无效流 header

Java invalid stream header

java

sockets

stream