TCP复制文件

缺乏、安全感 2021-09-15 09:16 444阅读 0赞

客户端：

import java.io.BufferedReader;
    import java.io.File;
    import java.io.FileReader;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.PrintWriter;
    import java.net.Socket;
    import java.net.UnknownHostException;
    
    public class TextClient {
    
    	public static void main(String[] args) throws UnknownHostException, IOException {
    		
    		Socket socket=new Socket("10.1.9.34",10006);
    		
    		BufferedReader bufr=new BufferedReader(new FileReader("ListDemo.java"));
    		
    		PrintWriter out=new PrintWriter(socket.getOutputStream(),true);
    		
    		String line=null;
    		while((line=bufr.readLine())!=null){
    			out.println(line);
    		}	
    		out.println("over");
    		BufferedReader bufIn=new BufferedReader(new InputStreamReader(socket.getInputStream()));
    		
    		String str=bufIn.readLine();
    		System.out.println(str);
    		
    		bufr.close();
    		socket.close();
    	}
    }

服务端：

import java.io.BufferedReader;
    import java.io.FileWriter;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.PrintWriter;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    public class TextServer {
    
    	public static void main(String[] args) throws Exception {
    		ServerSocket serverSocket=new ServerSocket(10006);
    		
    		Socket socket=serverSocket.accept();
    		
    		String ip=socket.getInetAddress().getHostAddress();
    		System.out.println(ip+"......connected");
    		
    		BufferedReader bufr=new BufferedReader(new InputStreamReader(socket.getInputStream()));
    		
    		PrintWriter out=new PrintWriter(new FileWriter("server.txt"),true);
    		
    		String line=null;
    		while((line=bufr.readLine())!=null){
    			if("over".equals(line)){
    				break;
    			}
    			out.println(line);
    		}
    		
    		PrintWriter pw=new PrintWriter(socket.getOutputStream(),true);
    		pw.println("上传成功");
    		
    		out.close();
    		socket.close();
    		serverSocket.close();
    	}
    }

![20180504164945402][] ![20180504164953674][]

但是上述中 over可能会出现在文章中，当作结束符，故可换另一种方式来写：

在over位置处，使用shutdownOutput();语句来代替

**  则修改后代码如下 ：**

**  客户端：**

import java.io.BufferedReader;
    import java.io.File;
    import java.io.FileReader;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.PrintWriter;
    import java.net.Socket;
    import java.net.UnknownHostException;
    
    public class TextClient {
    
    	public static void main(String[] args) throws UnknownHostException, IOException {
    		
    		Socket socket=new Socket("10.1.9.34",10006);
    		
    		BufferedReader bufr=new BufferedReader(new FileReader("ListDemo.java"));
    		
    		PrintWriter out=new PrintWriter(socket.getOutputStream(),true);
    		
    		String line=null;
    		while((line=bufr.readLine())!=null){
    			out.println(line);
    		}	
    //		out.println("over");
    		socket.shutdownOutput();//关闭客户端输出流，相当于给流中加入一个结束标记-1；
    		
    		BufferedReader bufIn=new BufferedReader(new InputStreamReader(socket.getInputStream()));
    		
    		String str=bufIn.readLine();
    		System.out.println(str);
    		
    		bufr.close();
    		socket.close();
    	}
    }

**    服务端：**

import java.io.BufferedReader;
    import java.io.FileWriter;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.PrintWriter;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    public class TextServer {
    
    	public static void main(String[] args) throws Exception {
    		ServerSocket serverSocket=new ServerSocket(10006);
    		
    		Socket socket=serverSocket.accept();
    		
    		String ip=socket.getInetAddress().getHostAddress();
    		System.out.println(ip+"......connected");
    		
    		BufferedReader bufr=new BufferedReader(new InputStreamReader(socket.getInputStream()));
    		
    		PrintWriter out=new PrintWriter(new FileWriter("server.txt"),true);
    		
    		String line=null;
    		while((line=bufr.readLine())!=null){
    //			if("over".equals(line)){
    //				break;
    //			}
    			out.println(line);
    		}
    		
    		PrintWriter pw=new PrintWriter(socket.getOutputStream(),true);
    		pw.println("上传成功");
    		
    		out.close();
    		socket.close();
    		serverSocket.close();
    	}
    }

![20180504164945402][] ![20180504164953674][]

[20180504164945402]: https://img-blog.csdn.net/20180504164945402
[20180504164953674]: /images/20210720/093420e2cf0445da88fed5905d6d838a.png