TCP模拟实现文本文件上传Java代码

多线程Main代码：

    new Thread(new TextUploadServer()).start();
    new Thread(new TextUploadClient()).start();    

客户端代码：

public class TextUploadClient implements Runnable {
    @Override
    public void run() {
        try {
            Socket socket = new Socket(InetAddress.getLocalHost(), 50001);
            String path = "D:\src.txt";
            BufferedReader bufferedReader = new BufferedReader(new FileReader(path));
            //可用PrintWriter代替，更简单
            BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
            
            String line = null;
            while((line = bufferedReader.readLine()) != null){
                bufferedWriter.write(line);//只需改为printWriter.println(line);
                bufferedWriter.newLine();
                bufferedWriter.flush();
            }
            socket.shutdownOutput();
            
            BufferedReader backReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            String res = backReader.readLine();
            
            System.out.println(res);
            
            bufferedReader.close();
            socket.close();
        }
        catch (Exception e) {
            e.printStackTrace();
        }
    }

}

服务端代码实现：

public class TextUploadServer implements Runnable {

    @Override
    public void run() {
        
        try {
            ServerSocket ss = new ServerSocket(50001);
            Socket socket = ss.accept();
            
            BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            BufferedWriter bufferedWriter = new BufferedWriter(new FileWriter("D:\tar.txt"));
            
            String line = null;
            while((line = bufferedReader.readLine()) != null){
                bufferedWriter.write(line);
                bufferedWriter.newLine();
                //bufferedWriter.flush();
            }
            
            BufferedWriter returnWriter = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
            returnWriter.write("Txt文本上传成功！！");
            returnWriter.newLine();
            returnWriter.flush();
            
            bufferedWriter.close();
            socket.close();
            ss.close();
            
        }
        catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        
    }
}