udp tcp 코드 upload

src/kr/co/swh/lecture/network/filetrans/FileReceiveServer.java

@@ -1,63 +0,0 @@
-package kr.co.swh.lecture.network.filetrans; 
-
-import java.io.BufferedOutputStream;
-import java.io.DataOutputStream;
-import java.io.File;
-import java.io.FileOutputStream;
-import java.net.DatagramPacket;
-import java.net.DatagramSocket;
-
-/**
- * <pre>
- * kr.co.swh.lecture.network.filetrans 
- * FileReceiveServer.java
- *
- * 설명 :파일 전송 서버
- * </pre>
- * 
- * @since : 2018. 12. 28.
- * @author : tobby48
- * @version : v1.0
- */
-public class FileReceiveServer {
-	public static void main(String[] args) {
-		//	전송받을 UDP 소켓을 생성
-		try {
-			DatagramSocket socket = new DatagramSocket(9999);
-			System.out.println("수신 준비 완료.");
-
-			//	데이터를 전송받을 스트림
-			FileOutputStream dos = null;
-			while(true){
-				//	전송받을 데이터 패킷 생성
-				DatagramPacket dp = new DatagramPacket(new byte[512], 512);
-				//	데이터 전송받기
-				socket.receive(dp);
-
-				//	전송받은 데이터 를 문자열로 변환
-				String str = new String(dp.getData()).trim();
-				//	전송받은 문자열이 start 라면 파일전송 시작
-				if(str.equals("start")){
-					System.out.println("전송 시작");
-					//	파일 객체 생성
-					File file = new File("C:\\Users\\tobby48\\b.txt");
-					//	파일 쓰기 객체
-					dos = new FileOutputStream(file);
-				}
-				//	전송받은 문자열이 end 라면 전송완료
-				else if(str.equals("end")){
-					System.out.println("전송 완료");
-					break;
-				}
-				else{
-					//	0부터 길이만큼 파일내용 쓰기
-					dos.write(str.getBytes(), 0, str.getBytes().length);
-				}
-			}
-			dos.close();
-			socket.close();
-		} catch (Exception e) {
-			System.out.println(e.getMessage());
-		}
-	}
-}

src/kr/co/swh/lecture/network/filetrans/FileReceiveServerTCP.java

@@ -0,0 +1,95 @@
+package kr.co.swh.lecture.network.filetrans; 
+
+import java.io.BufferedOutputStream;
+import java.io.DataInputStream;
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.net.ServerSocket;
+import java.net.Socket;
+
+/**
+ * <pre>
+ * kr.co.swh.lecture.network.filetrans 
+ * FileReceiveServer.java
+ *
+ * 설명 :파일 전송 서버
+ * </pre>
+ * 
+ * @since : 2018. 12. 28.
+ * @author : tobby48
+ * @version : v1.0
+ */
+public class FileReceiveServerTCP {
+
+	public static void main(String[] args) {
+        ServerSocket serverSocket = null;
+        Socket socket = null;
+        String filename = "C:\\Users\\tobby48\\receive-data.txt";
+        try {
+            // 리스너 소켓 생성 후 대기
+            serverSocket = new ServerSocket(8081); // socket(),bind();
+  
+            // 연결되면 통신용 소켓 생성           
+            socket = serverSocket.accept(); // listen(),accept();
+            long start = System.currentTimeMillis();
+            // 파일 수신 작업 시작
+            FileReceiver fr = new FileReceiver(socket,filename,start);
+            fr.start();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+  
+    }
+}
+  
+class FileReceiver extends Thread {
+    Socket socket;
+    DataInputStream dis;
+    FileOutputStream fos;
+    BufferedOutputStream bos;
+    String filename;
+    long start;
+    int control = 0;
+    public FileReceiver(Socket socket,String filestr,long starttime) {
+        this.socket = socket;
+        this.filename = filestr;
+        this.start = starttime;
+    }
+  
+    @Override
+    public void run() {
+        try {
+            dis = new DataInputStream(socket.getInputStream());
+ 
+            String fName = filename;
+  
+            // 파일을 생성하고 파일에 대한 출력 스트림 생성
+            File f = new File(fName);
+            fos = new FileOutputStream(f);
+            bos = new BufferedOutputStream(fos);
+            
+  
+            // 바이트 데이터를 전송받으면서 기록
+            int len;
+            int size = 4096;
+            byte[] data = new byte[size];
+            while ((len = dis.read(data)) != -1) {
+                control++;
+                if(control % 10000 == 0)
+                {
+                    System.out.println("수신중..." + control/10000);      
+                }
+                bos.write(data, 0, len);
+            }
+            long end = System.currentTimeMillis();
+            System.out.println( "Elapsed Time (seconds) : " + ( end - start )/1000.0 );
+            bos.flush();
+            bos.close();
+            fos.close();
+            dis.close();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+}

src/kr/co/swh/lecture/network/filetrans/FileReceiveServerUDP.java

@@ -0,0 +1,87 @@
+package kr.co.swh.lecture.network.filetrans; 
+
+import java.io.FileOutputStream;
+import java.net.DatagramPacket;
+import java.net.DatagramSocket;
+
+/**
+ * <pre>
+ * kr.co.swh.lecture.network.filetrans 
+ * FileReceiveServerUDP.java
+ *
+ * 설명 :파일 전송 서버
+ * </pre>
+ * 
+ * @since : 2018. 12. 28.
+ * @author : tobby48
+ * @version : v1.0
+ */
+public class FileReceiveServerUDP {
+	public static final int DEFAULT_BUFFER_SIZE = 10000;
+	
+	public static void main(String[] args) {
+		int port =  9999;
+		String filename = "C:\\Users\\tobby48\\receive-data.txt";
+
+		long fileSize;
+		long totalReadBytes = 0;
+
+		byte[] buffer = new byte[DEFAULT_BUFFER_SIZE];
+		try {
+			int nReadSize = 0;
+			System.out.println("Waitng.....");
+
+			DatagramSocket ds = new DatagramSocket(port);
+			FileOutputStream fos = null;       
+			fos = new FileOutputStream(filename);
+			
+			//	start 신호 받는 파트
+			DatagramPacket dp = new DatagramPacket(buffer, buffer.length);
+			ds.receive(dp);		//	start 신호 받음
+			String str = new String(dp.getData()).trim();
+
+			if (str.equals("start")){
+				System.out.println(str);
+				
+				//	파일의 크기 받는 파트
+				dp = new DatagramPacket(buffer, buffer.length);
+				ds.receive(dp);	//	파일의 크기 받음
+				str = new String(dp.getData()).trim();
+				fileSize = Long.parseLong(str);
+				
+				//	클라이언트로부터 파일의 내용을 받는 파트
+				double startTime = System.currentTimeMillis(); 
+				while (true) {
+					ds.receive(dp);
+					str = new String(dp.getData()).trim();
+					nReadSize = dp.getLength();
+					fos.write(dp.getData(), 0, nReadSize);
+					
+					//	진행률 출력
+					totalReadBytes+=nReadSize;
+					System.out.println("In progress: " + totalReadBytes + "/"
+							+ fileSize + " Byte(s) ("
+							+ (totalReadBytes * 100 / fileSize) + " %)");
+					if(totalReadBytes>=fileSize)
+						break;
+				}
+				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");
+				System.out.println("File transfer completed");
+				Thread.sleep(5000);
+				fos.close();
+				ds.close();
+			}
+			else{
+				System.out.println("Start Error");
+				fos.close();
+				ds.close();
+			}
+		} catch (Exception e) {}
+		System.out.println("Process Close");
+	}
+}

src/kr/co/swh/lecture/network/filetrans/FileSendClient.java

@@ -1,69 +0,0 @@
-package kr.co.swh.lecture.network.filetrans; 
-
-import java.io.File;
-import java.io.FileInputStream;
-import java.net.DatagramPacket;
-import java.net.DatagramSocket;
-import java.net.InetAddress;
-
-/**
- * <pre>
- * kr.co.swh.lecture.network.filetrans 
- * FileSendClient.java
- *
- * 설명 :파일 전송 클라이언트
- * </pre>
- * 
- * @since : 2018. 12. 28.
- * @author : tobby48
- * @version : v1.0
- */
-public class FileSendClient {
-
-	public static void main(String[] args) {
-		try{
-			File file = new File("C:\\Users\\tobby48\\Google 드라이브\\학원\\운영\\데이터베이스 백업\\2018-11-21.sql");
-			//	파일이 없다면 프로그램 종료
-			if(file.exists() == false){
-				System.out.println("파일이 존재하지 않습니다.");
-				System.exit(0);
-			}
-			
-			//	파일내용을 읽기위한 스트림 생성
-			FileInputStream fis = new FileInputStream(file);
-			
-			//	UDP 소켓 생성
-			DatagramSocket socket = new DatagramSocket();
-			//	전송할 파일 서버위치
-			InetAddress ia = InetAddress.getByName("127.0.0.1");
-			//	파일 전송 시작 알림
-			String str = "start";
-			//	전송할 객체 생성
-			DatagramPacket dp = new DatagramPacket(str.getBytes(), str.getBytes().length, ia, 9999);
-			//	시작 메세지를 전송
-			socket.send(dp);
-
-			//	파일의 내용을 저장할 배열
-			byte [] buffer = new byte[512];
-
-			//	모든 내용을 읽어서 전송
-			while(true){
-				int readSize = fis.read(buffer, 0, buffer.length);
-				if(readSize == -1)
-					break;
-				dp = new DatagramPacket(buffer, readSize , ia , 9999);
-				socket.send(dp);
-				
-
-			}
-			//	종료 메세지를 전송
-			str = "end";
-			dp = new DatagramPacket(str.getBytes(), str.getBytes().length, ia, 9999);
-			socket.send(dp);
-			fis.close();
-			socket.close();
-		}catch(Exception e){
-			System.out.println(e.getMessage());
-		}
-	}
-}

src/kr/co/swh/lecture/network/filetrans/FileSendClientTCP.java

@@ -0,0 +1,89 @@
+package kr.co.swh.lecture.network.filetrans; 
+
+import java.io.BufferedInputStream;
+import java.io.DataOutputStream;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.net.Socket;
+
+/**
+ * <pre>
+ * kr.co.swh.lecture.network.filetrans 
+ * FileSendClient.java
+ *
+ * 설명 :파일 전송 클라이언트
+ * </pre>
+ * 
+ * @since : 2018. 12. 28.
+ * @author : tobby48
+ * @version : v1.0
+ */
+public class FileSendClientTCP {
+	public static void main(String[] args) {
+        Socket socket = null;       
+        String serverIp = "127.0.0.1";
+        int serverPort = 8081;
+        String filename = "C:\\Users\\tobby48\\transfer-data.log";
+         
+        try {
+            // 서버 연결
+            socket = new Socket(serverIp, serverPort); // socket(),connect();
+            System.out.println("서버에 연결되었습니다.");
+  
+            FileSender fs = new FileSender(socket,filename);
+            fs.start();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+}
+ 
+class FileSender extends Thread {
+    Socket socket;
+    DataOutputStream dos;
+    FileInputStream fis;
+    BufferedInputStream bis;
+    String filename;
+    int control = 0;
+    public FileSender(Socket socket,String filestr) {
+        this.socket = socket;
+        this.filename = filestr;
+        try {
+            // 데이터 전송용 스트림 생성
+            dos = new DataOutputStream(socket.getOutputStream());
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+  
+    @Override
+    public void run() {
+        try {
+            // 파일 내용을 읽으면서 전송
+            File f = new File(filename);
+            fis = new FileInputStream(f);
+            bis = new BufferedInputStream(fis);
+  
+            int len;
+            int size = 4096;
+            byte[] data = new byte[size];
+            while ((len = bis.read(data)) != -1) {
+                control++;
+                if(control % 10000 == 0)
+                {
+                    System.out.println("전송중..." + control/10000);      
+                }
+                dos.write(data, 0, len);
+            }
+  
+            dos.flush();
+            dos.close();
+            bis.close();
+            fis.close();
+            System.out.println("완료");
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+}

src/kr/co/swh/lecture/network/filetrans/FileSendClientUDP.java

@@ -0,0 +1,93 @@
+package kr.co.swh.lecture.network.filetrans; 
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.net.DatagramPacket;
+import java.net.DatagramSocket;
+import java.net.InetAddress;
+
+/**
+ * <pre>
+ * kr.co.swh.lecture.network.filetrans 
+ * FileSendClientUDP.java
+ *
+ * 설명 :파일 전송 클라이언트
+ * </pre>
+ * 
+ * @since : 2018. 12. 28.
+ * @author : tobby48
+ * @version : v1.0
+ */
+public class FileSendClientUDP {
+	public static final int DEFAULT_BUFFER_SIZE = 10000;
+	public static void main(String[] args) {
+		String serverIP = "127.0.0.1";
+		int port = 9999;
+		String FileName = "C:\\Users\\tobby48\\transfer-data.log";
+
+		File file = new File(FileName);
+		DatagramSocket ds = null;
+		if (!file.exists()) {
+			System.out.println("File not Exist");
+			System.exit(0);
+		}
+		long fileSize = file.length();
+		long totalReadBytes = 0;
+
+		double startTime = 0;  
+		try {
+			ds = new DatagramSocket();
+			InetAddress serverAdd = InetAddress.getByName(serverIP);
+			startTime = System.currentTimeMillis();
+			
+			//	start 신호 보내는 파트
+			String str = "start";
+			DatagramPacket dp = new DatagramPacket(str.getBytes(), str.getBytes().length, serverAdd, port);
+			ds.send(dp);	//	start 신호 전송
+
+			//	파일의 크기 보내는 파트
+			str = String.valueOf(fileSize);
+			dp = new DatagramPacket(str.getBytes(), str.getBytes().length, serverAdd, port);
+			ds.send(dp);	//	파일의 크기 전송
+
+			//	파일의 내용을 읽어 서버로 전송하는 파트
+			FileInputStream fis = new FileInputStream(file);
+			byte[] buffer = new byte[DEFAULT_BUFFER_SIZE];
+			while (true) {
+				Thread.sleep(10);
+				//	파일 내용 읽어오기
+				int readBytes = fis.read(buffer, 0, buffer.length);
+				if (readBytes == -1)
+					break;
+				//	파일의 내용을 서버로 전송
+				dp = new DatagramPacket(buffer, readBytes, serverAdd, port); // *
+				ds.send(dp);
+				
+				//	진행률 출력
+				totalReadBytes += readBytes;
+				System.out.println("In progress: " + totalReadBytes + "/"
+						+ fileSize + " Byte(s) ("
+						+ (totalReadBytes * 100 / fileSize) + " %)");
+
+			}
+			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");
+
+			str = "end";
+			dp = new DatagramPacket(str.getBytes(), str.getBytes().length, serverAdd, port);
+			ds.send(dp);
+			Thread.sleep(5000);
+			System.out.println("Process Close");
+			fis.close();
+			ds.close();
+
+		} catch (Exception e) {
+			System.out.println(e.getMessage());
+		}
+
+	}
+}