Java ServerSocket无法建立输入输出流问题求助

问题根源 #

1. Socket被提前关闭：客户端ClientMain使用try-with-resources包裹Socket，main方法启动客户端线程后立即退出try块，Socket被自动关闭，导致服务端初始化流时连接中断。
2. ObjectStream初始化顺序死锁：当前两端均先创建ObjectInputStream，而ObjectInputStream构造时会阻塞等待读取对方ObjectOutputStream发送的流头，双方互相等待最终引发超时或连接断开。

修复方案 #

1. 调整Socket生命周期 #

移除客户端的try-with-resources，确保Socket在客户端线程执行完成后再关闭。

2. 统一流初始化顺序 #

• 客户端：先创建ObjectOutputStream（主动发送流头），再创建ObjectInputStream
• 服务端：先创建ObjectInputStream（读取客户端的流头），再创建ObjectOutputStream

修复后的代码 #

abstractClass #

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;

public abstract class abstractClass extends Thread {
    protected Socket socket;
    protected ObjectInputStream in;
    protected ObjectOutputStream out;

    protected abstractClass(Socket socket) {
        this.socket = socket;
    }

    // 客户端专用初始化：先写后读
    protected void initClientStreams() {
        try {
            out = new ObjectOutputStream(socket.getOutputStream());
            out.flush(); // 确保流头立即发送
            in = new ObjectInputStream(socket.getInputStream());
        } catch (IOException e) {
            e.printStackTrace();
            Thread.currentThread().interrupt();
        }
    }

    // 服务端专用初始化：先读后写
    protected void initServerStreams() {
        try {
            in = new ObjectInputStream(socket.getInputStream());
            out = new ObjectOutputStream(socket.getOutputStream());
        } catch (IOException e) {
            e.printStackTrace();
            Thread.currentThread().interrupt();
        }
    }
}

Client相关代码 #

import java.io.IOException;
import java.net.Socket;

public class ClientMain {
    public static void main(String[] args) {
        Socket server = null;
        try {
            server = new Socket("localhost", 3141);
            Client client = new Client(server);
            client.start();
            client.join(); // 等待客户端线程执行完成再关闭Socket
        } catch (IOException | InterruptedException e) {
            throw new RuntimeException(e);
        } finally {
            if (server != null) {
                try {
                    server.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

class Client extends abstractClass {
    Client(Socket socket) {
        super(socket);
    }

    @Override
    public void run() {
        initClientStreams();
        // 后续业务逻辑
    }
}

Server相关代码 #

import java.io.IOException;
import java.net.ServerSocket;

public class ServerMain {
    public static void main(String[] args) {
        try (ServerSocket serverSocket = new ServerSocket(3141)) {
            MulServerThread mulThread = new MulServerThread(serverSocket.accept());
            mulThread.start();
            mulThread.join(); // 可选：等待服务端线程完成
        } catch (IOException | InterruptedException e) {
            throw new RuntimeException(e);
        }
    }
}

class MulServerThread extends abstractClass {
    public MulServerThread(Socket socket) {
        super(socket);
    }

    @Override
    public void run() {
        initServerStreams();
        // 后续业务逻辑
    }
}

关键说明 #

• ObjectOutputStream创建时会自动写入流头（魔术值+版本号），flush()操作确保流头立即发送到对方，避免延迟。
• 客户端调用join()等待线程执行完毕再关闭Socket，保证流操作期间连接有效。
• 服务端先读取流头再创建输出流，避免阻塞。

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