Java Socket传输后ArrayList为空问题求助

我正在开发一款基于java.io Socket的聊天应用，场景如下：

• 客户端将封装在Packet对象中的Message对象通过Socket发送给服务器
• 服务器获取到Packet后，会向客户端广播包含所有Message的ArrayList

问题：服务器端在发送前，Packet的payload是符合预期的（包含客户端发送消息的ArrayList），但客户端接收后，该消息ArrayList为空（调试显示size=0，无法获取任何消息）。

客户端代码 #

public void run(){
    try {
        while(true){
            packet = (Packet) streamFromServer.readObject();
            switch (packet.command){
                case TCGETMSG:
                    messageGlobalStorage = (ArrayList<Message>)packet.payload;
                    break;
                case TCGETUSERS:
                    usersOnline = (DefaultListModel<User>) packet.payload;
                    break;
                case TCGETSTATS:
                    System.out.println("Getting stats");
                    break;
                default:
                    //Add undefined packet handling
                    break;
            }
        }
    }catch (IOException | ClassNotFoundException e){
        e.printStackTrace();
    }
}

public boolean sendMessage(Message message) {
    try {
        streamToServer.writeObject(new Packet(Packet.Commands.FCSENDMSG, message));
        return true;
    }catch (IOException e) {
         e.printStackTrace();
    }
    return false;
} 

服务器端代码 #

private void threadRoutine() throws IOException, ClassNotFoundException{
    try {
        //Receiving from the client => Inverse logic : SENDMSG = retreive message; 
        //GETMSG = broadcast message to client
        while (true){
            Packet packet = (Packet) din.readObject();
            switch (packet.command){
                case FCSENDMSG:
                    server.messageGlobalStorage.add((Message) packet.payload);
                    server.broadcast((Message) packet.payload);
                    break;
                case FCGETMSG:
                    Packet temp = new Packet(Packet.Commands.TCGETMSG, server.messageGlobalStorage);
                    dout.writeObject(temp);
                    break;
                case FCGETUSERS:
                    dout.writeObject(new Packet(Packet.Commands.TCGETUSERS, server.userOnlineMap.keySet()));
                    break;
                case FCGETSTATS:
                    //Add Stats handling
                    break;
                default:
                    //Add undefined packet handling
                    break;
           }
      }
    }finally {
        server.removeConnection(socket);
        System.out.println("Removing connection");
    }
}

void broadcast() throws IOException{
    for (ObjectOutputStream dout : userOnlineMap.values()){
        dout.writeObject(new Packet(Packet.Commands.TCGETMSG, messageGlobalStorage));
    }
}

（若需要Packet/Message类的代码，可补充提供）

可能的解决方向 #

1. 验证序列化一致性

   • 确保Packet、Message类都正确实现Serializable接口，且服务器与客户端的类定义完全一致（包括serialVersionUID）。泛型类型Message也必须是可序列化的，否则ArrayList反序列化时会丢失元素。

2. 强制刷新输出流

   • 在服务器调用writeObject后，立即调用dout.flush()，确保数据被写入Socket而非停留在缓冲区。例如：

     // 服务器threadRoutine中
     dout.writeObject(temp);
     dout.flush();
     
     // broadcast方法中
     dout.writeObject(new Packet(Packet.Commands.TCGETMSG, messageGlobalStorage));
     dout.flush();
     

3. 避免对象引用复用

   • ObjectOutputStream会缓存已序列化的对象引用，多次发送同一个ArrayList实例时，客户端只会接收到第一次的状态。解决方法是每次发送时创建列表副本：

     // 修改broadcast方法
     dout.writeObject(new Packet(Packet.Commands.TCGETMSG, new ArrayList<>(messageGlobalStorage)));
     
     // 修改threadRoutine中的FCGETMSG分支
     Packet temp = new Packet(Packet.Commands.TCGETMSG, new ArrayList<>(server.messageGlobalStorage));
     

4. 检查类型转换安全性

   • 客户端接收时，避免直接强制转换为ArrayList<Message>，可以先转为List再处理，或者使用泛型安全的转换方式，防止泛型擦除导致的类型错误：

     messageGlobalStorage = new ArrayList<>((List<Message>)packet.payload);
     

5. 确认流的创建顺序

   • 客户端和服务器必须先创建ObjectOutputStream，再创建ObjectInputStream，否则会出现阻塞，导致数据接收不完整。例如客户端：

     streamToServer = new ObjectOutputStream(socket.getOutputStream());
     streamFromServer = new ObjectInputStream(socket.getInputStream());
     

内容的提问来源于stack exchange，提问作者Hugo Chittaro