TCP 上传文件

灰太狼 2022-01-11 08:57 209阅读 0赞

package liu.net.udpupload;
    
    import java.io.BufferedReader;
    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 UploadClient  {
    	public static void main(String[] args) throws UnknownHostException, IOException {
    		/*	上传文本的客户端。读取本地文本数据，发送给服务端，服务端接收完毕后，回馈“上传成功” */
    		
    		System.out.println("客户端启动。。。");
    		//客户端 socket
    		Socket s = new Socket("127.0.0.1",8890);
    		
    		//1.确定数据源，本地文件
    		BufferedReader bufr = new BufferedReader(new FileReader("text.txt"));
    		
    		//2.确定目的地 socket 输出流
    		//BufferedWriter bufw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
    		PrintWriter pw = new PrintWriter(s.getOutputStream(),true);
    		
    		String line = null;
    		while((line=bufr.readLine())!=null){
    			pw.println(line);
    		}
    		
    		//用socket的禁用流输出方法，告诉服务端文件传说完成，否则服务端不知道文件传输完成
    		s.shutdownOutput();
    		
    		//3.通过 socket 读取服务端返回的数据
    		BufferedReader bufIn = new BufferedReader(new InputStreamReader(s.getInputStream()));
    		String lineIn = bufIn.readLine();
    		System.out.println(lineIn);
    		
    		//关闭
    		bufr.close();
    		s.close();
    		System.out.println("客户端关闭成功");
    		
    	}
    }

package liu.net.udpupload;
    
    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 UploadServer {
    	public static void main(String[] args) throws IOException {
    		//上传文本到服务端，服务端接收数据并存储到文件中，服务端接收完毕后，服务端回馈“接收成功”
    		System.out.println("服务端启动。。。");
    		//1.服务端对象
    		ServerSocket ss= new ServerSocket(8890);
    		
    		//2.获取客户端
    		Socket s = ss.accept();
    		
    		//3.获取读取流
    		BufferedReader bufIn = new BufferedReader(new InputStreamReader(s.getInputStream()));
    		
    		//4.确定目的文件
    		PrintWriter pw = new PrintWriter(new FileWriter("server.txt"),true);
    		
    		//5.频繁读写
    		String line = null;
    		while((line=bufIn.readLine())!=null){
    			pw.println(line);
    			
    		}
    		
    		//6.给客户端返回信息
    		PrintWriter out = new PrintWriter(s.getOutputStream(),true);
    		out.println("上传成功");
    		
    		//7.关闭资源
    		pw.close();
    		s.close();
    		ss.close();
    		System.out.println("服务端成功关闭");
    		
    	}
    
    }

转载于:https://blog.51cto.com/11359581/2047979