TCP 上传文件

Posted 2020-10-16

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("服务端成功关闭");
		
	}

}