[JAVA] 파일 전송(File Transfer) - TCP

1. 구성

  UDP 기반의 Socket을 이용한 파일 전송 프로그램입니다.

• Server

1. Receiver

2. 파라메터 :  <port> <filename>

• Client

1. Sender

2. 파라메터 :  <server IP> <port> <filename>

• 다른 언어 다른 방식: https://github.com/cckr2/FileTransfer

2. Source Code(1) - Server(Receiver)

import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.net.InetSocketAddress; import java.net.ServerSocket; import java.net.Socket; public class FileTransferReceiver { public static final int DEFAULT_BUFFER_SIZE = 10000; public static void main(String[] args) { int port = Integer.parseInt(args[0]); //int port = 9999; String filename = args[1]; //String filename = "test.mp4"; //저장할 파일 이름 try { ServerSocket server = new ServerSocket(port); System.out.println("This server is listening... (Port: " + port + ")"); Socket socket = server.accept(); //새로운 연결 소켓 생성 및 accept대기 InetSocketAddress isaClient = (InetSocketAddress) socket.getRemoteSocketAddress(); System.out.println("A client("+isaClient.getAddress().getHostAddress()+ " is connected. (Port: " +isaClient.getPort() + ")"); FileOutputStream fos = new FileOutputStream(filename); InputStream is = socket.getInputStream(); double startTime = System.currentTimeMillis(); byte[] buffer = new byte[DEFAULT_BUFFER_SIZE]; int readBytes; while ((readBytes = is.read(buffer)) != -1) { fos.write(buffer, 0, readBytes); } double endTime = System.currentTimeMillis(); double diffTime = (endTime - startTime)/ 1000;; System.out.println("time: " + diffTime+ " second(s)"); is.close(); fos.close(); socket.close(); server.close(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }

3. Source Code(2) - Client(Sender)

import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.io.OutputStream; import java.net.Socket; import java.net.UnknownHostException; public class FileTransferSender { public static final int DEFAULT_BUFFER_SIZE = 10000; public static void main(String[] args) { String serverIP = args[0]; //String serverIP = "127.0.0.1"; int port = Integer.parseInt(args[1]); //int port = 9999; String FileName = args[2]; //String FileName = "test.mp4"; File file = new File(FileName); if (!file.exists()) { System.out.println("File not Exist."); System.exit(0); } long fileSize = file.length(); long totalReadBytes = 0; byte[] buffer = new byte[DEFAULT_BUFFER_SIZE]; int readBytes; double startTime = 0; try { FileInputStream fis = new FileInputStream(file); Socket socket = new Socket(serverIP, port); if(!socket.isConnected()){ System.out.println("Socket Connect Error."); System.exit(0); } startTime = System.currentTimeMillis(); OutputStream os = socket.getOutputStream(); while ((readBytes = fis.read(buffer)) > 0) { os.write(buffer, 0, readBytes); totalReadBytes += readBytes; System.out.println("In progress: " + totalReadBytes + "/" + fileSize + " Byte(s) (" + (totalReadBytes * 100 / fileSize) + " %)"); } System.out.println("File transfer completed."); fis.close(); os.close(); socket.close(); } catch (UnknownHostException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } double endTime = System.currentTimeMillis(); double diffTime = (endTime - startTime)/ 1000;; double transferSpeed = (fileSize / 1000)/ diffTime; System.out.println("time: " + diffTime+ " second(s)"); System.out.println("Average transfer speed: " + transferSpeed + " KB/s"); } }