通过socket来将客户端文件传给服务器端

    上一篇为大家介绍了利用java程序发送post请求来传递文件流，但是却有大小限制，那么我们这次就来写一个socket，通过网络套接字来传递来往于客户端和服务器的文件。

     我想大家对于java 的socket编程不会太陌生，那我就直接切入主题，分别编写服务器和客户端代码：

     Server：

import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.io.PrintWriter; import java.net.ServerSocket; import java.net.Socket; import java.util.Scanner; public class Server { /** * @param args */ public static void main(String[] args) { //ServerSocket server; Long beginTime = null; try { ServerSocket server = new ServerSocket(1234); while (true) { final Socket sk = server.accept(); //通过套接字来发送文本 InputStream inStream = sk.getInputStream(); OutputStream outStream = sk.getOutputStream(); Scanner in = new Scanner(inStream); PrintWriter out = new PrintWriter(outStream, true); out.println("the program is beginning:"); boolean done = false; while (!done && in.hasNextLine()) { String line = in.nextLine(); out.println("Echo" + line); if (line.trim().equals("bye")) { done = true; } } sk.close(); /*new Thread(new Runnable() { @Override public void run() { try { BufferedReader br = new BufferedReader(new InputStreamReader(sk.getInputStream())); //System.out.println(br.readLine()); br.close(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }).start();*/ } } catch (IOException e) { System.out.println("fail"); e.printStackTrace(); } } }  

Client：

import java.io.BufferedReader; import java.io.File; import java.io.FileReader; import java.io.IOException; import java.io.PrintStream; import java.net.Socket; import java.net.UnknownHostException; public class Client { /** * @param args */ public static void main(String[] args) { // 创建套接字 Socket sk; PrintStream ps; //Temp temp = Temp.getInstance(); //temp.setSEND_TIME(System.currentTimeMillis()); //Long beginTime = temp.getSEND_TIME(); //System.out.println(beginTime); try { sk = new Socket("localhost", 1234); ps = new PrintStream(sk.getOutputStream()); //读取文件 File file = new File("E:/toodou_work/testSmall.csv"); BufferedReader br = new BufferedReader(new FileReader(file)); StringBuilder sb = new StringBuilder(); String str = null; while ((str = br.readLine()) != null) { sb.append(str); } String content = sb.toString(); ps.print(content); sk.close(); } catch (UnknownHostException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { System.out.println("link to server is fail"); e.printStackTrace(); } } }