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