Socket File transfer

Client 에서 Server로 파일을 전송한다. 파일 이외 다른 데이터는 전송하지 않기 때문에 DataInputStream/DataOutputStream 이 아닌 기본적인 InputStream/OutputStream을 사용한다.

1. client 소스

import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.io.OutputStream; import java.net.Socket; public class ClientExample { public static void main(String[] args) { OutputStream os = null; FileInputStream fis = null; try { Socket so = new Socket("127.0.0.1", 30100); os = so.getOutputStream(); //전송파일의 경로 및 이름 : F:/development/test/test_client.zip fis = new FileInputStream(new File("F:/development/test/test_client.zip")); byte[] b = new byte[1024*4]; int result = 0; while((result=fis.read(b))>0) { os.write(b,0,result); } } catch(IOException e) { e.printStackTrace(); } finally { try {os.close();} catch(IOException e) {} try {fis.close();} catch(IOException e) {} } } }

2. server 소스

import java.io.File; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.net.ServerSocket; import java.net.Socket; public class ServerExample extends Thread { private Socket so = null; public ServerExample(Socket so) { this.so = so; } public void run() { FileOutputStream fos = null; InputStream is = null; try { //수신파일의 경로 및 이름 : F:/development/test/test_server.zip File file = new File("F:/development/test/test_server.zip"); fos = new FileOutputStream(file); byte[] b = new byte[1024*4]; is = so.getInputStream(); int result = 0; //read bytes from inputstream and stores them into buffer array b //and return total # of bytes read into buffer or -1 if there's no more data while((result=is.read(b))>0) { fos.write(b, 0, result); //byte[] b 의 0 위치에서 부터 result 길이만큼 write한다. } } catch(IOException e) { e.printStackTrace(); } finally { try {fos.close();} catch(IOException e) {} try {is.close();} catch(IOException e) {} } } public static void main(String[] args) { Socket so = null; try { ServerSocket ss = new ServerSocket(30100); do { so = ss.accept(); //listen for connection, blocks until connection is made new ServerExample(so).start(); } while(true); } catch(IOException e) { e.printStackTrace(); } finally { try {so.close();}catch (IOException e){} } } }