无法通过 Socket 上的 BufferedWriter 写入数据

Question

在将此标记为可能重复之前，请先阅读一次，因为我找不到任何答案。我正在学习套接字编程并使用套接字创建一个非常基本的服务器-客户端文件传输程序。 这是我的服务器模块：

import java.io.*;
import java.net.*;
import static java.lang.System.out;

public class ServerMain {
    public static void main(String[] args) {
    int PORT=13267;
    ServerSocket servSocket;
    Socket client;
    File source=new File("E:/Styles of Beyond.wav");;
    BufferedInputStream bis;
    BufferedReader br;
    String s="";
    InputStream is;
    byte[] byteBuffer=new byte[10240];
    OutputStream os;
    int count=0;

    try{

        servSocket=new  ServerSocket(PORT);
        out.println("Server running on port: "+PORT+", waiting for client...");
        client=servSocket.accept();
        client.setKeepAlive(true);
        out.println("Client: "+client.getRemoteSocketAddress()+" connected. Sending file...");
        bis=new BufferedInputStream(new FileInputStream(source));
        os=client.getOutputStream();
        is=client.getInputStream();

        while((count=bis.read(byteBuffer))>0){
            os.write(byteBuffer, 0, count);
        }

        out.println("Waiting for confirmation from client...");
        br=new BufferedReader(new InputStreamReader(is));
        if(br.readLine()=="Done")
            out.println("Done.");
        else
            out.println("Couldn't get confirmation from server.");
    }

    catch(Exception e)
    {
        e.printStackTrace();
    }
}
}

还有客户端模块：

import static java.lang.System.out;
import java.io.*;
import java.net.*;

public class ClientMain {

    public static void main(String[] args) {
        int SERV_PORT=13267;
        Socket server;
        File destination=new File("E:/copy.wav");
        byte[] byteBuffer=new byte[10240];
        InputStream is;
        OutputStream os;
        BufferedWriter bw;
        int count=0;

        try{
            out.println("Tyring to connect to server...");
            server=new Socket("localhost",SERV_PORT);
            out.println("Connected to server: "+server.getRemoteSocketAddress());
            is=server.getInputStream();
            os=server.getOutputStream();
            out.println("Receiving data...");
            BufferedOutputStream bos=new BufferedOutputStream(new FileOutputStream(destination));

            while((count=is.read(byteBuffer))>0){
                bos.write(byteBuffer, 0, count);
            }
            bw=new BufferedWriter(new OutputStreamWriter(os));
            bw.write("Done");
            bw.newLine();
            out.println("Data successfully written to copy.wav");
        }
        catch(Exception e){
            e.printStackTrace();
        }
}
}

代码可以正常工作，甚至文件copy.wav也可以正确创建，但是在客户端的操作系统上写入后，服务器卡在“等待来自客户端的确认...”，客户端卡在“正在接收数据。 ……”。我尝试在客户端而不是 BufferedWriter 上使用 PrintWriter，并且还简单地尝试在 os 上写入单个字节，并在服务器端检查该字节以获取文件接收确认，但似乎没有任何效果，客户端没有发送任何内容。我注意到的一件事是，在服务器上调用 is.ready() 总是返回 false。

如果我在客户端和服务器上删除与发送和接收文件确认相关的所有代码，客户端程序会产生 SocketException: connection reset，因为现在服务器不会等待客户端完成其 is.read( ) 任务并在使用 os.write() 完成写入后立即关闭连接，这会创建具有小于原始数据大小的部分数据的 copy.wav。我该如何正确地做这件事？

P.S：我知道我没有关闭流并正确处理异常，但这似乎不是问题。

Answer 1

冲洗它！

https://docs.oracle.com/javase/7/docs/api/java/io/OutputStream.html#flush()

打电话后：

        bw.write("Done");
        bw.newLine();

操作系统正在等待更多，因此它可以有效地以大块的形式发送数据。

此外，您可以在其上设置 TCP_NODELAY，但您通常应该让操作系统来做这件事，因为它比您更了解在大多数情况下发送数据的最佳方式。

How does TCP_NODELAY affect consecutive write() calls?