使用tcp连接
客户端
package net.upload; 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 Client { public static void main(String[] args) throws UnknownHostException, IOException { System.out.println("upload..."); File file = new File("c:\\client.txt"); //要和客户端一致 Socket socket = new Socket("10.1.35.73",10007); BufferedReader bufr = new BufferedReader(new FileReader(file)); PrintWriter pw = new PrintWriter(socket.getOutputStream(), true); String line = null; while((line=bufr.readLine())!=null){ pw.println(line); } //告诉服务端客户端写完了 socket.shutdownOutput(); BufferedReader bufin = new BufferedReader(new InputStreamReader(socket.getInputStream())); String str = bufin.readLine(); System.out.println(str); bufr.close(); socket.close(); } }
服务端
package net.upload; import java.io.BufferedReader; import java.io.BufferedWriter; 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 Server { public static void main(String[] args) throws IOException { System.out.println("上传中...."); ServerSocket socket= new ServerSocket(10007); Socket s = socket.accept(); BufferedReader bufin = new BufferedReader(new InputStreamReader(s.getInputStream())); BufferedWriter bw = new BufferedWriter(new FileWriter("c:\\server.txt")); String line = null; while((line=bufin.readLine())!=null){ bw.write(line); bw.newLine(); bw.flush(); } PrintWriter pw = new PrintWriter(s.getOutputStream(), true); //打给客户端 pw.println("上传成功"); bw.close(); s.close(); socket.close(); } }