如何修复 Broken Pipe Socket 异常 (Java)？连接在哪里被关闭？

Question

我正在为一个学校项目开发一个多线程网络服务器。我应该能够在浏览器上进入本地主机并请求 3 个不同的文件（.htm、.jpeg、.pdf）。但是，当我对其中包含图片的 .htm 文件执行此操作（2 个请求）时，.htm 文件会出现在浏览器中，但对于我尝试在图片上执行的每次写入，都会出现许多损坏的管道套接字异常（分配需要一次写入 1024 个字节）。我实现此方法的方式明显有问题，但当我尝试写入第二个文件时，我不知道连接在哪里关闭？我尝试了一些不同的方法来尝试解决此问题，包括尝试读取套接字输入流时的循环，但我认为这违背了多线程服务器的目的。服务器：    while(true){        try {            sock = servSock.accept(); // Handles the connection            // Connection received log            System.out.println("Connection received: " + new Date().toString() + " at " + sock.getInetAddress() + sock.getPort());            HTTP pro = new HTTP(sock); // Client handler            pro.run();            ServerThread serverThread = new ServerThread(pro);             // Starts ServerThread            serverThread.start();        } catch (Exception e){            System.out.println(e);        }    }HTTP：    public void run(){        // Try to open reader        try{            readSock = new BufferedReader(new InputStreamReader(sock.getInputStream()));        } catch (Exception e){            System.out.println(e);        }        // Open output stream        try{            this.out = new DataOutputStream(sock.getOutputStream());             this.printOut = new PrintWriter(sock.getOutputStream());         } catch (Exception e){            System.out.println(e);        }        // Try to read incoming line        try {            this.reqMes = readSock.readLine();        } catch (IOException e) {            e.printStackTrace();        }        StringTokenizer st = new StringTokenizer(reqMes);        // Parse the request message        int count = 0;        while(st.hasMoreTokens()){            String str = st.nextToken();            if (count == 1){                this.fileName = "." + str;            }            count += 1;        }对于浏览器中的一个 .htm 文件，该文件和 html 看起来都很好。但看起来它在 html 文件中对 .jpeg 文件发出了第二个请求，并且浏览器在每次写入数据时都会卡住加载 java.net.SocketException: Broken pipeline (Write failed)this.out.write(fileData,0,1024);谢谢，如有任何帮助，我们将不胜感激。

Answer 1

问题在于响应标头的格式不正确，导致连接过早结束。必须在标头之后发送另一个空行（“\r\n”）。

以下代码现在可以运行（this.CRLF 等于“\r\n”）：

   public void run(){

        // Try to open reader

        try{

            readSock = new BufferedReader(new InputStreamReader(sock.getInputStream()));

        } catch (Exception e){

            System.out.println(e);

        }

        // Open output stream

        try{

            this.out = new DataOutputStream(sock.getOutputStream()); // Data output

            this.printOut = new PrintWriter(sock.getOutputStream()); // Print output

        } catch (Exception e){

            System.out.println(e);

        }

        // Try to read incoming line

        try {

            this.reqMes = readSock.readLine();

        } catch (IOException e) {

            e.printStackTrace();

        }

        StringTokenizer st = new StringTokenizer(reqMes);

        // Parse the request message

        int count = 0;

        while(st.hasMoreTokens()){

            String str = st.nextToken();

            if (count == 1){

                this.fileName = "." + str;

            }

            count += 1;

        }

        System.out.println("File name received.");

        // Initialize file to be sent

        File file = null;

        // Try to find file and create input stream

        try {

            file = new File(this.fileName);

            this.f = new FileInputStream(file); // File input stream

            this.fileExists = true;

            System.out.println("File " + this.fileName +  " exists.");

        } catch (FileNotFoundException e) {

            System.out.println(e);

            this.fileExists = false;

            System.out.println("File does not exist.");

        }

        byte[] buffer = new byte[1024];

        // Write status line

        if (this.fileExists) {

            System.out.println("Trying to write data");

            try{

                this.out.writeBytes("HTTP/1.0 " + "200 OK " + this.CRLF);

                this.out.flush();

                // Write Header

                this.out.writeBytes("Content-type: " + getMime(this.fileName) + this.CRLF);

                this.out.flush();

                this.out.writeBytes(this.CRLF);

                this.out.flush();

                // Read file data

                byte[] fileData = new byte[1024];

                int i;

                while ((i = this.f.read(fileData)) > 0) {

                    // Write File data

                    try{

                        this.out.write(fileData,0, i);

                    } catch (IOException e) {

                        System.out.println(e);

                    }

                }

                this.out.flush(); // Flush output stream

                System.out.println("Flushed");

                closeSock(); // Closes socket

            } catch (IOException e) {

                e.printStackTrace();

            }