하위^^

먼저 화면 좌측 상단 메뉴바

File - Import

General의 Existing Projects into Workspace 선택

Select archive file을 선택하고 Browse..를 눌러

다운받은 Workspace zip파일을 선택하면 리스트에 프로젝트가 나온다.

원하는 프로젝트를 선택하고 Finish를 눌러 Import를 마친다.

본 블로그에서 사용한 Workspace는 아래와 같다.

Java.zip

JavaFX.zip

Java - 게시글 분류 중 개념 및 코딩

JavaFX - 게시글 분류 중 JavaFX

Workspace를 zip파일로 Export하여 공유하는법

화면 좌측 상단의 메뉴바 - File - Export 클릭

리스트 맨 위의 General의 Archive File 선택

화면 좌측의 포함할 프로젝트를 선택 한 후 

To archive file - zip파일이 저장될 경로를 선택해주고 Finish가 활성화 되면 끝

본 블로그에서 사용한 Workspace는 아래와 같다.

Java.zip

JavaFX.zip

Java - 게시글 분류 중 개념 및 코딩

JavaFX - 게시글 분류 중 JavaFX

네트워크를 통해 파일을 전송하는것은 Stream에서 파일 전송의 활용이라고 보면 된다.

Stream을 통해서 읽어온 데이터를 그대로 전송하면 된다.

네트워크 부분은 대부분 비슷하기 때문에 설명은 많이 적지 않고 코드의 주석을 통해 설명

Receiver 클래스

package chap12.exam07.file;

import java.io.FileOutputStream;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
// 직접 만들어본 리시버
public class Receiver {

	public static void main(String[] args) throws Exception {
		// 데이터를 받으려면 항시 대기하여야 하는데 while문으로 묶어버리면
		// 아래의 코드가 작동되지 않으므로 따로 스레드를 만들어야함
		String path = "C:/img/temp2/aaa.pdf";
		// 1. DatagramSocket 생성
		DatagramSocket socket = new DatagramSocket(5001);
		FileOutputStream fos = new FileOutputStream(path);
		
		Thread th = new Thread(){
			@Override
			public void run() {
				// 2. DatagramPacket 준비 (한번에 받은 메시지 크기)
				DatagramPacket packet = new DatagramPacket(new byte[1024], 1024);
				while(true) {
					try {
						socket.receive(packet);		// 3. 데이터 수신
						byte[] character = packet.getData();
						fos.write(character);
					} catch (IOException e) {
						e.printStackTrace();
						break;
					}
				}
			}
		};
		th.setDaemon(true); // main이 끝나면 같이 죽도록 설정
		th.start(); // 스레드 실행
		// 5. 자원 정리
		Thread.sleep(10000);
		socket.close(); // 소켓을 닫고
		// 종료		
	}

}

Main FileReceiver

package chap12.exam07.file;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.DataInputStream;
import java.io.FileOutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class FileReceiver {

	public static void main(String[] args) throws Exception {
		// 1. 서버소켓 생성
		ServerSocket server = new ServerSocket(7777);

		while(true) { // 대기
			System.out.println("요청 대기중...");
			// 2. 연결 수락
			Socket socket = server.accept();
			System.out.println("수락");

			Thread th = new Thread() {

				@Override
				public void run() {
					try {
						// 3. 파일 위치 지정
						String path = "C:/img/temp2/";
						
						// 4. 스트림 준비
						BufferedInputStream bis = new BufferedInputStream(socket.getInputStream()); // 파일명 받기
						DataInputStream dis = new DataInputStream(bis);
						path += dis.readUTF();
						System.out.println(path);
						FileOutputStream fos = new FileOutputStream(path);  // 파일 받아오기
						BufferedOutputStream bos = new BufferedOutputStream(fos);

						// 5. 읽기 -> 쓰기
						// 배열로 받을 경우 다른 IP로 전송 시 파일이 깨질 수 있음
						byte[] source = new byte[1024];
						while(dis.read(source) != -1) {
							bos.write(source);
						}
						
//						int data;
//						while((data = dis.read() != -1)) {
//							bos.write(data);
//						}
						bos.flush();
						System.out.println("다운로드 완료");
						bos.close();
						fos.close();
						bis.close();
						dis.close();
						socket.close();
					}catch (Exception e) {
						System.out.println(e.toString());
					}
				}
			};
			th.start();
		}
	}

}

Sender 클래스

package chap12.exam07.file;

import java.io.FileInputStream;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;

public class Sender { // 직접 만들어본 sender

	public static void main(String[] args) throws Exception {
		String pathInput = "C:/img/10multi.pdf";
		FileInputStream fis = new FileInputStream(pathInput);
		// 1. DatagramSocket 생성
		DatagramSocket socket = new DatagramSocket();
		int i = 0;
		byte[] buffer = new byte[1024];
		
		while(fis.read(buffer)!=-1) { // -1 == EOF
			// 4. 내보내기
			DatagramPacket packet = new DatagramPacket(buffer, buffer.length, new InetSocketAddress("localhost", 5001));
			socket.send(packet);
			i++;
			System.out.println("파일 복사중... " + i);
		}


		fis.close();
		socket.close();

	}

}

Main FileSender

package chap12.exam07.file;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.DataOutputStream;
import java.io.FileInputStream;
import java.net.Socket;

public class FileSender {

	public static void main(String[] args) throws Exception {
		// 1. 파일 위치
		String path = "C:/img/10multi.pdf";
		int i = 0;
		// 2. 스트림 준비 + 소켓(스트림)
		try(
		FileInputStream fis = new FileInputStream(path);
		BufferedInputStream bis = new BufferedInputStream(fis);
		Socket socket = new Socket("여기에 IP를 입력해야 정상적으로 동작해요">", 7777);
		BufferedOutputStream bos = new BufferedOutputStream(socket.getOutputStream());
		DataOutputStream dos = new DataOutputStream(bos);
		){
			// 3. 읽어오기 -> 전송(파일 바이너리 + 파일 명)
			String[] name = path.split("/");
			dos.writeUTF(name[name.length-1]); // -1번방의 내용을 전송
			dos.flush();
			
			// 파일 바이너리 전송
			byte[] source = new byte[1024];
			while(bis.read(source) != -1 ) {  // 한번의 루프로 1024바이트(1kb) 전송
				dos.write(source);
				// 전송 진행율 표시를 어떻게 할 것인가????
				i++;
				System.out.println("파일 전송중..." + i + " / " + source.length);
			}
			dos.flush();
			System.out.println("전송 완료...!");
			
		} catch (Exception e) {
			System.out.println(e.toString());
		}
	}

}

File Sender의 19번째 줄에 접속할 대상의 IP를 입력해주어야 한다.

그리고 서버는 이클립스에서 실행하고

클라이언트를 따로 실행해야 하는데

https://qdgbjsdnb.tistory.com/79 를 참조하여 cmd에서 클라이언트를 작동해보자.

UDP는 TCP와 달리 DatagramSocket과 DatagramPacket을 사용한다.

TCP와의 차이점으로는 일방적인 전송을 하고 확인 작업이 없기 때문에 속도가 빠르지만

정확도가 낮다

Server가 될 Receiver

package chap12.exam06.udp;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;

public class Receiver {

	public static void main(String[] args) throws Exception {
		// 데이터를 받으려면 항시 대기하여야 하는데 while문으로 묶어버리면
		// 아래의 코드가 작동되지 않으므로 따로 스레드를 만들어야함

		// 1. DatagramSocket 생성
		DatagramSocket socket = new DatagramSocket(5001);

		Thread th = new Thread(){

			@Override
			public void run() {
				// 2. DatagramPacket 준비 (한번에 받은 메시지 크기)
				DatagramPacket packet = new DatagramPacket(new byte[100],  100);
				while(true) {
					try {
						socket.receive(packet);		// 3. 데이터 수신
						byte[] character = packet.getData();
						String data = new String(character,  "UTF-8").replace('\0', ' ');
						System.out.println(data);		// 4. 받은 데이터 출력
					} catch (IOException e) {
						e.printStackTrace();
						break;
					}
				}
			}
		};
		th.setDaemon(true); // main이 끝나면 같이 죽도록 설정
		th.start(); // 스레드 실행
		// 5. 자원 정리
		Thread.sleep(10000);
		socket.close(); // 소켓을 닫고
		// 종료		
	}

}

Client가 될 Sender

package chap12.exam06.udp;

import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;

public class Sender {

	public static void main(String[] args) throws Exception {
		// 1. DatagramSocket 생성
		DatagramSocket socket = new DatagramSocket();
		// 2. 보낼 메시지 준비
		for(int i = 1; i <= 3; i++) {
			String msg = "data_" + i;
			byte[] arr = msg.getBytes();
			// 3. DatagramPacket으로 전송
			DatagramPacket packet = new DatagramPacket(arr,  arr.length, new InetSocketAddress("localhost", 5001));
			socket.send(packet);
		}

		// 4. 자원 반납
		socket.close();
		
	}

}

서버는 이클립스에서 실행하고

클라이언트를 따로 실행해야 하는데

https://qdgbjsdnb.tistory.com/79 를 참조하여 cmd에서 클라이언트를 작동해보자.

1:1 채팅을 조금 바꾼 다대다, N:M 멀티 채팅이다.

전과 다른점으로는 클라이언트와 서버에 사용할 Receiver, Sender 따로 있는 점이다.

서버 기능을 가지고 있는 ServerManager 클래스

package chap12.exam05.multichat;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;

public class ServerManager extends Thread {
	Socket socket;
	DataInputStream in;
	DataOutputStream out;
	// 서버이기에 in 먼저 일어남
	
	public ServerManager(Socket socket) throws IOException {
		this.socket = socket;
		in= new DataInputStream(socket.getInputStream());
		sendMsg(socket.getPort() + "님이 입장 하였습니다.");
	}

	@Override
	public void run() { // 서버는 메시지를 감지해야 하므로 in을 이용
		while(in != null) {
			try {
				sendMsg(socket.getPort()+"> " + in.readUTF());
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		try {
			in.close();
			out.close();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	
	public void sendMsg(String msg) throws IOException { // MultiServer의 List에서 소켓 리스트를 받아옴
		System.out.println(msg);
		for(Socket soc : MultiServer.list) {
			out = new DataOutputStream(soc.getOutputStream());
			out.writeUTF(msg);
			out.flush();
		}
	}


}

ServerManager를 불러오는 MultiServer

package chap12.exam05.multichat;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;

public class MultiServer {
	static ArrayList<Socket> list = new ArrayList<>();
	
	public static void main(String[] args) throws IOException {
		
		ServerManager manager;
		Socket socket;
		ServerSocket server = new ServerSocket(5252);
		System.out.println("서버 실행 중");
		
		while(true) {
			socket = server.accept(); // 소켓을 기다림
			list.add(socket); // 추가
			manager = new ServerManager(socket);
			manager.start();
		}
	}

}

다음으로는 Client에 필요한 클래스와 메인 클라이언트

Sender

package chap12.exam05.multichat;

import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.util.Scanner;

public class ClientSender extends Thread {
	Socket socket;
	DataOutputStream out;
	
	public ClientSender(Socket socket) throws IOException {
		// 초기화와 동시에 스트림도 잡아주면 효율적
		this.socket = socket;
		out = new DataOutputStream(socket.getOutputStream());
		// socket.getOutputStream을 그대로 형변환 해도 된다.
	}

	@Override
	public void run() {
		while(out != null) {
			System.out.print("당신>");
			Scanner scan = new Scanner(System.in);
			
			try {
				out.writeUTF(scan.nextLine());
				out.flush();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		try {
			out.close();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

Receiver

package chap12.exam05.multichat;

import java.io.DataInputStream;
import java.io.IOException;
import java.net.Socket;

public class ClientReceiver extends Thread {
	Socket socket;
	DataInputStream in;
	
	public ClientReceiver(Socket socket) throws IOException {
		this.socket = socket;
		in = new DataInputStream(socket.getInputStream());
		// Sender와 크게 차이 없음
	}

	@Override
	public void run() {
		while(in != null) {
			try {
				System.out.println(in.readUTF());
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		try {
			in.close();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

}

실질적으로 동작할 Main MultiClient

package chap12.exam05.multichat;

import java.net.Socket;

public class MultiClient {

	public static void main(String[] args) throws Exception {
		Socket socket = new Socket("여기에 IP를 입력해야 정상적으로 동작해요", 5252);
		System.out.println("연결 성공");
		ClientReceiver receiver = new ClientReceiver(socket);
		ClientSender sender = new ClientSender(socket);
		
		receiver.start();
		sender.start();
	}

}

8번째 줄에 접속할 대상의 IP를 입력해주어야 하고 1개의 컴퓨터로 테스트 할 경우

대상 Server가 자기 자신이므로 자신의 IP를 입력하면 된다.

그리고 서버는 이클립스에서 실행하고

클라이언트를 따로 실행해야 하는데

https://qdgbjsdnb.tistory.com/79 를 참조하여 cmd에서 클라이언트를 작동해보자.

이번에는 1:1 채팅 프로그램으로

채팅을 한번 하고 끝나지 않기 위해서는 반복문을 돌려야만 한다.

또한 통신 기능 외의 작업이 같이 돌아가야 하기 때문에 Thread를 이용한다.

메시지를 받을 서버 Receiver 클래스

package chap12.exam04.chat;

import java.io.BufferedInputStream;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.Socket;

public class Receiver extends Thread {
	private Socket socket = null;

	public Receiver(Socket socket) {
		this.socket = socket;
	}

	@Override
	public void run() {
		try {
			// 4. InputStream으로 보내온 메시지를 받는다.
			InputStream is = socket.getInputStream(); // 핵심
			BufferedInputStream bis = new BufferedInputStream(is);
			InputStreamReader reader = new InputStreamReader(bis, "UTF-8");
			char[] arr = new char[100];
			while(is != null) {  // 스트림으로 반복문 제어
				// 5. 출력
				reader.read(arr);
				// ㅁㅁㅁ는 \0이고 배열의 공백을 의미한다.
				String msg = new String(arr).replace('\0', ' ');
				System.out.println("[상대] " + msg);

				// 긴 문장 후 짧은 문장이 들어올 경우 이전 값과 섞여 들어온다.
				// 초기화
				arr = new char[100];
			}
		} catch (Exception e) {
			System.out.println(e.toString());
		}
	}

}

메시지를 받을 클라이언트 Sender 클래스

package chap12.exam04.chat;

import java.io.BufferedOutputStream;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.util.Scanner;

public class Sender extends Thread {
	private Socket socket = null;
	
	public Sender(Socket socket) {
		this.socket = socket;
	}

	@Override
	public void run() {
		try {
			// 입력값을 받는 Scanner
			Scanner scan = new Scanner(System.in);
			// OutputStream으로 보내온 메시지를 전송한다.
			OutputStream os = socket.getOutputStream();
			BufferedOutputStream bos = new BufferedOutputStream(os);
			OutputStreamWriter writer = new OutputStreamWriter(bos, "UTF-8");

			while(os != null) {
				String msg = scan.nextLine();
				writer.write(msg);
				writer.flush();
				
			}
			
			scan.close();
		} catch (Exception e) {
			System.out.println(e.toString());
		}
	}

}

Receiver와 Sender을 Thread로 만들어 실행해준다.

Server

package chap12.exam04.chat;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class ChatServer {

	public static void main(String[] args) {

		try {
			// 1. 소켓 생성(bind 생략 가능)
			ServerSocket server = new ServerSocket(5001);
			// 2. 접속 수락
			Socket socket = server.accept();
			System.out.println("접속 수락");
			// 3. 받기 전용 스레드 실행
			Receiver receiver = new Receiver(socket);
			receiver.start();
			// 4. 전송 전용 스레드 실행
			Sender sender = new Sender(socket);
			sender.start();
		} catch (IOException e) {
			e.printStackTrace();
		}
		
	}

}

Client

package chap12.exam04.chat;

import java.net.Socket;

public class ChatClient {

	public static void main(String[] args) {
		try {
			// 1. 소켓 생성
			Socket socket = new Socket("여기에 IP를 입력해야 정상적으로 동작해요", 5001);
			// 2. 연결 요청
			// 3. 받기 전용 스레드 실행
			Receiver receiver = new Receiver(socket);
			receiver.start();
			// 4. 전송 전용 스레드 실행
			Sender sender = new Sender(socket);
			sender.start();
		} catch (Exception e) {
			System.out.println(e.toString());
		}
	}

}

10번째 줄에 접속할 대상의 IP를 입력해주어야 하고 1개의 컴퓨터로 테스트 할 경우

대상 Server가 자기 자신이므로 자신의 IP를 입력하면 된다.

그리고 서버는 이클립스에서 실행하고

클라이언트를 따로 실행해야 하는데

https://qdgbjsdnb.tistory.com/79 를 참조하여 cmd에서 클라이언트를 작동해보자.

Echo 서버는 메아리처럼 client에서 메시지를 서버에 전송하여

서버가 받은 메시지를 그대로 client에 전송하는 프로그램이다.

서버

package chap12.exam03.echo;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {

	public static void main(String[] args) throws Exception {
		// 1. Server Socket 생성
		ServerSocket server = new ServerSocket();
		// 2. IP 개방 (localhost는 자기만 들어오고, 자신의 ip를 입력하면 외부에서 접속가능)
		server.bind(new InetSocketAddress("여기에 IP를 입력해야 정상적으로 동작해요", 5001));
		// 3. 요청 대기
		while(true) {
			System.out.println("Connect Ready");
			Socket socket = server.accept(); // block
			
			// 접속 요청이 있을 경우 요청 주소를 뽑아 낸다.(선택)
			InetSocketAddress addr = (InetSocketAddress) socket.getRemoteSocketAddress();
			System.out.println("접속 완료 : " + addr.getAddress());
			
			// 4. InputStream으로 보내온 메시지를 받는다.
			InputStream is = socket.getInputStream(); // 핵심
			BufferedInputStream bis = new BufferedInputStream(is);
			InputStreamReader reader = new InputStreamReader(bis);
			
			// 5. 출력
			char[]arr = new char[100];
			reader.read(arr);
			// ㅁㅁㅁ는 \0이고 배열의 공백을 의미한다, 38번째 줄의 replace를 생략한다면 이상한 문자를 볼 수 있다.
			String msg = new String(arr).replace('\0', ' ');
			System.out.println("[client] " + msg);
			
			// 6. OutputStream으로 보내온 메시지를 전송한다.
			OutputStream os = socket.getOutputStream();
			BufferedOutputStream bos = new BufferedOutputStream(os);
			OutputStreamWriter writer = new OutputStreamWriter(bos, "UTF-8");
			writer.write(msg);
			writer.flush();
			// 서버는 켜져있어야 하므로 자원반납을 생략
		}
	}

}

클라이언트

package chap12.exam03.echo;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.InetSocketAddress;
import java.net.Socket;

public class Client {

	public static void main(String[] args) throws Exception {
		// 1. 소켓 생성
		Socket socket = new Socket();
		// 2. 접속 요청
		try {
			socket.connect(new InetSocketAddress("여기에 IP를 입력해야 정상적으로 동작해요", 5001));
			System.out.println("접속 완료");
			
			OutputStream os = socket.getOutputStream();
			BufferedOutputStream bos = new BufferedOutputStream(os);
			OutputStreamWriter writer = new OutputStreamWriter(bos,  "UTF-8");
			writer.write("Hello, Server");
			writer.flush();
			// 3. 데이터 전송
			// 4. 받아온 데이터 출력
			InputStream is = socket.getInputStream();
			BufferedInputStream bis = new BufferedInputStream(is);
			InputStreamReader reader = new InputStreamReader(bis);
			
			char[] arr = new char[100];
			reader.read(arr);

			String msg = new String(arr);
			System.out.println("내가 받은 메세지 : " + msg);
			// 5. 자원반납
			os.close();
			bos.close();
			writer.close();
			is.close();
			bis.close();
			reader.close();
		} catch (Exception e) {
			// 
		}
		

	}

}

서버의 19번째 줄과 클라이언트의 20번째 줄에

접속할 대상의 IP를 입력해주어야 하고 1개의 컴퓨터로 테스트 할 경우

대상 Server가 자기 자신이므로 자신의 IP를 입력하면 된다.

그리고 서버는 이클립스에서 실행하고

클라이언트를 따로 실행해야 하는데

https://qdgbjsdnb.tistory.com/79 를 참조하여 cmd에서 클라이언트를 작동해보자.

TCP는 연결지향적 프로토콜로 데이터를 안전하고 정확하게 전달한다.

데이터가 잘 전송 됫는지 확인 작업이 따로 있으며

작업이 추가로 있기 때문에 UDP보다 느리다.

여기서는 Socket을 이용한 통신을 해볼것이다.

Socket은 안에 IP, 포트 등 다양한 정보를 담고

상대방에게 전송된다.

다음의 간단한 예제를 통해 확인해보자.

서버

package chap12.exam02.tcp;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {

	public static void main(String[] args) {

		ServerSocket server = null;

		// 1. 서버 소켓 생성
		try {
			server = new ServerSocket();
			// 2. IP를 개방 (열어주길 원하는 IP, 오픈 호스트), localhost는 자기 자신의 IP를 의미
			server.bind(new InetSocketAddress("localhost", 5001));
			// 3. 요청 대기
			while(true) {
				System.out.println("요청 대기중");
				// 4. 접속 요청이 있을 경우 수락 (하나의 스레드, 조인, 블로킹하여 요청이 올 때 까지 대기)
				Socket socket = server.accept();
				// 4-1. 요청이 있을 경우 처리 (클라이언트 주소 알아내기)
				InetSocketAddress addr = (InetSocketAddress) socket.getRemoteSocketAddress();
				System.out.println("접속 완료 >" + addr.getAddress() + ":" + addr.getPort());
			}
			// 5. 자원 반납 (서버는 5번 아래로 잘 안씀)
			// 6. 종료
		} catch (IOException e) { // 서버에 문제가 있을 때
			// 5. 자원 반납 (서버는 5번 아래로 잘 안씀)
			try {
				server.close();
			} catch (IOException e1) {
				e1.printStackTrace();
			}
			// 6. 종료
			e.printStackTrace();
		}
	}

}

클라이언트

package chap12.exam02.tcp;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.Socket;

public class Client {

	public static void main(String[] args) {
		Socket socket = null;
		
		try {
			// 1. 소켓 생성
			socket = new Socket();
			
			// 2. 접속 요청
			socket.connect(new InetSocketAddress("localhost", 5001));
			
			// 3. 시킬 일 있으면 요청
			System.out.println("접속 완료");
		} catch (IOException e) {
			e.printStackTrace();
		} finally {
			// 4. 종료
			try {
				socket.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}

}

먼저 서버를 작동한 후 클라이언트 코드도 작동을 해줘야 하는데

서버는 이클립스에서 돌리고

https://qdgbjsdnb.tistory.com/79 를 참조하여 cmd에서 클라이언트를 작동해보자.

Network는 다양한 컴퓨터들끼리 연결되어 있는 망을 의미한다.

컴퓨터 뿐만 아니라 다양한 사물(Things), 예를들어 냉장고 선풍기, 에어컨 등의 사물(Things)들이 Network, Internet에 연결이 되고

그것을 IOT(Internet Of Things) 사물 인터넷이라고 한다.

특히 Java는 컴퓨터를 벗어나 다양한 사물에 활용되기 좋아 널리 사용되고 있다.

Network의 깊은 지식이 목적이 아니기 때문에 전문적인 내용을 다루지 않고

Java에서 쓸만한 간단한 Server, Client 통신을 공부한다.

Network는 결국 목적지까지 어떻게 가느냐가 제일 중요한 과제이다.

그래서 컴퓨터에 고유 통신 번호인 IP가 지정되고 IP는 집주소 처럼 데이터를 전달할 목적지 주소로 쓰이게 된다.

또한 컴퓨터 장치 자체에 부여된 주소도 따로 있지만 IP만 사용한다.

IP와 함께 필요한게 하나 있는데 포트 번호가 꼭 필요하다.

일반적으로 사용하는 포트는 TCP와 UDP가 있고

TCP는 Three Way Handshake와 같은 방법으로 확실한 데이터를 전송하지만 속도가 조금 느리다.

UDP는 일방적인 전송을 하므로 불확실한 데이터를 전송하지만 속도가 빠르다는 장점이 있다.

IP와 포트의 예로는 127.0.0.1:8080과 같이

127.0.0.1은 IP가 되고

: 뒤에 8080은 포트 번호가 된다.

그리고 127.0.0.1은 자신을 지정하는 IP로 자신의 IP를 모를때 쓰는 IP이다.

Java에서 자신의 IP 주소를 얻는법과

특정 도메인의 IP를 얻는법을 확인해보자

InetAddress를 사용한다.

여기서 도메인은 네이버로 예를 든다면

naver.com이 도메인(IP의 닉네임으로 이해하면 된다)이다.

수많은 웹사이트들을 접속하는데 일일히 IP를 암기하고 사용 할 수 없으니 닉네임을 배정하는 혁신적인 기술이다.

도메인이 생기고 인터넷의 발전은 급격히 상승했다.

package chap12.exam01.ipaddr;

import java.net.InetAddress;

public class GetIp {

	public static void main(String[] args) throws Exception {
		// 내 컴퓨터의 IP 얻기
		// localhost => 127.0.0.1 => 자신의 주소를 지정하는 주소
		InetAddress addr = InetAddress.getLocalHost();
		System.out.println("my PC IP " + addr.getHostAddress());
		
		// 특정 도메인으로 IP 얻기
		String domain = "naver.com";
		addr = InetAddress.getByName(domain);
		System.out.println(addr.getHostAddress());
		
		// 특정 도메인으로 IP 전부 얻기
		domain = "www.youtube.com";
		InetAddress[] addrs = InetAddress.getAllByName(domain); // 반환값이 배열
		for(InetAddress ip : addrs) {
			System.out.println("ip : " + ip);
		}
	}

}

여기서 특정 도메인으로 IP 전부 얻기라는 말이 이해가 안 갈수도 있다.

왜 여러대가 나오는거지? 할 수 있는데 웹사이트들은 서버를 여러대를 두어 접속을 대비하여야 하기 때문에 여러개가 나온다.

예를들면 naver.com과 같이 대형 웹사이트는 1분안에 수만, 수십만명이 동시에 접속할 수 있기 때문에

서버를 여러대 준비하여 부하가 낮아지게끔 해야한다.

만약 여러대를 준비하지 않을 경우 사람이 몰리는 아침시간에 naver.com에 접속하려고 하면

과장해서 1시간, 2시간 걸릴 것이다...

Java NIO는 New Input Output의 줄임말로 기능 중 간단한 파일 제어만 설명

Java IO와는 다르게 Stream이 아니고 Channel 방식을 사용

1. Files, 파일 다루기

Files의 다양한 메소드들은 다음 예제를 통해 확인하자.

package chap11.exam13.files;

import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;

public class FilesExam {
	// 파일의 속성을 알아 볼 수 있다.
	public static void main(String[] args) throws Exception {
		
		Path path = Paths.get("C:/img/asd.txt");
		System.out.println("디렉토리 여부 : " + Files.isDirectory(path));
		System.out.println("파일 여부 : " + Files.isRegularFile(path));
		System.out.println("마지막 수정 시간 : " + Files.getLastModifiedTime(path));
		System.out.println("파일 크기 : " + Files.size(path));
		System.out.println("소유자 : " + Files.getOwner(path));
		System.out.println("숨김 파일 여부 : " + Files.isHidden(path));
		System.out.println("읽기 가능 여부 : " + Files.isReadable(path));
		System.out.println("쓰기 가능 여부 : " + Files.isWritable(path));
		System.out.println("실행 여부 : " + Files.isExecutable(path));
	}

}

2. FileSystem, 파일 정보

FileSystem은 현재 시스템의 다양한 정보를 불러올 수 있다.

Iterable에 FileStroe을 붙여서 사용

package chap11.exam13.files;

import java.io.IOException;
import java.nio.file.FileStore;
import java.nio.file.FileSystem;
import java.nio.file.FileSystems;
import java.nio.file.Path;

public class FileSystemExam {
	// 파일 시스템(파일/폴더/저장공간) 정보
	public static void main(String[] args) throws IOException {
		// 기본 파일 시스템 정보 추출하는 객체
		FileSystem fs = FileSystems.getDefault();
		Iterable<FileStore> infolist = fs.getFileStores();
		for(FileStore info : infolist) {
			System.out.println("드라이브 이름 : " + info.name());
			System.out.println("저장 타입 : " + info.type());
			System.out.println("용량 : " + info.getTotalSpace()/(1024*1024*1024) + "GB");
			System.out.println("사용 가능한 용량 : " + info.getUsableSpace()/(1024*1024*1024) + "GB");
		}
		
		System.out.println("====현재 사용중인 드라이버 루트 ====");
		for(Path path : fs.getRootDirectories()) {
			System.out.println(path.toString());
		}
	}

}

3. Path, 경로

Path는 경로에 관련된 다양한 메소드들이 있다.

폴더 생성 또는 파일 이름만 뽑는다던가 상위 폴더를 알아 낸다던가 등 여러가지 있다.

package chap11.exam13.files;

import java.nio.file.Path;
import java.nio.file.Paths;

public class PathExam {
	// 1. 파일 경로 확인 전문화
	public static void main(String[] args) {
		// 특정 경로의 파일 정보를 가져옴(Uri | String)
		Path path = Paths.get("C:/img/temp/10multi_copy");
		
		// 파일명
		System.out.println(path.getFileName());
		// 부모 확인
		System.out.println(path.getParent().getFileName());
		// 루트 확인
		System.out.println(path.getRoot());
		// 위에 쓴 경로들의 단계 수
		System.out.println(path.getNameCount());
		// 개별 단계 확인
		for(int i = 0; i < path.getNameCount(); i++) {
			System.out.println(i + " 단계 : " + path.getName(i));
		}
	}

}

package chap11.exam13.files;

import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;

public class MKdirExam {
	// 디렉토리 및 파일 생성
	public static void main(String[] args) throws Exception {
		Path path = Paths.get("c:/img/test");
		// !File.exists()
		if(Files.notExists(path)) {
			System.out.println("폴더 생성");
			Files.createDirectories(path);
		}
		path = Paths.get("c:/img/test/textFile.txt");
		if(Files.notExists(path)) {
			System.out.println("파일 생성");
			Files.createFile(path);
		}
	}

}

4. WatchService, 파일 감시

WatchService는 지정한 폴더 내부의 파일이 생성되거나 수정되거나 삭제되는 경우를 감지하는 기능을 가지고 있다.

생성 시 감시할 이벤트들을 설정하고 사용한다.

package chap11.exam13.files;

import java.nio.file.FileSystems;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.nio.file.StandardWatchEventKinds;
import java.nio.file.WatchEvent;
import java.nio.file.WatchEvent.Kind;
import java.nio.file.WatchKey;
import java.nio.file.WatchService;
import java.util.List;

public class WatchServiceExam {
	// 특정 경로의 파일 변경을 감시
	public static void main(String[] args) throws Exception {
		
		// 기본 영역 지정
		WatchService watch = FileSystems.getDefault().newWatchService();
		
		// 감시 할 상세 주소 지정
		Path path = Paths.get("c:/img");
		
		// 어떤 와치 서비스가 어떤것을 감시하나?
		path.register(watch,  StandardWatchEventKinds.ENTRY_CREATE, 
				StandardWatchEventKinds.ENTRY_DELETE, 
				StandardWatchEventKinds.ENTRY_MODIFY);
		// 감시 실행
		while(true) {
			// 등록한 이벤트 발생 시 WatchKey로 반환
			WatchKey key = watch.take();
			// 이벤트 추출, ?는 와일드 카드 타입
			List<WatchEvent<?>> list = key.pollEvents();
			// 상세 내용을 추출
			for(WatchEvent e: list) {
				// 이벤트 상세 내용
				Kind evtKind = e.kind();
				Path evtPath = (Path) e.context();
				System.out.println(evtKind);
				System.out.println(evtPath);
			}
			// 다 쓰고난 이벤트 키는 리셋 해 주어야 한다.
			// reset을 하지 않으면 감시가 일회성으로 끝난다.
			// false : 초기화 실패, 해당 디렉토리가 사라진 경우
			boolean success = key.reset();
			System.out.println(success);
		}
	}

}

5. Path를 이용한 Write Read Copy

위에 사용한 Path를 이용하여 파일을 만들거나 읽거나 복사하는 기능

쓰기

package chap11.exam14.fileRW;

import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.nio.file.StandardOpenOption;
import java.util.Scanner;

public class fileWriteEx {

	public static void main(String[] args) throws Exception{
		// 파일 위치 지정
		Path path = Paths.get("c:/img/write.txt");
		// 쓰기 할 값 입력 받기
		Scanner scan = new Scanner(System.in);
		System.out.println("아무거나 입력하세요!");
		String txt = scan.nextLine() + "\r\n";
		// 스트림 준비 + 쓰기
		Files.write(path, txt.getBytes(), StandardOpenOption.APPEND);
		System.out.println("저장 되었습니다.");
		// 자원반납(flush, close) - 생략
	}

}

읽기

package chap11.exam14.fileRW;

import java.nio.charset.Charset;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.List;

public class FileReadEx {

	public static void main(String[] args) throws Exception {
		// 1. 경로
		Path path = Paths.get("C:/img/asd.txt");
		// 2. 스트림 생성		// 3. 읽기
		List<String> contents = Files.readAllLines(path, Charset.forName("UTF-8"));

		// 4. 출력
		for(String line : contents) {
			System.out.println(line);
		}
	}

}

복사

package chap11.exam14.fileRW;

import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.nio.file.StandardCopyOption;

public class FileCopyEx {
	// 파일 복사
	public static void main(String[] args) throws Exception {
		// 읽어와서 -> 쓰기
		// 파일 지정
		Path from = Paths.get("c:/img/10multi.pdf");
		Path to = Paths.get("c:/img/temp/10multicopyFile");
		// 스트림 + 읽기 + 읽어온 값 쓰기
		Files.copy(from,  to, StandardCopyOption.REPLACE_EXISTING);
		System.out.println("파일 복사 완료");
		// REPLACE_EXISTING : 기존 파일이 있으면 덮어쓰기
		// COPY_ATTRIBUTES : 파일의 모든 속성 복사(권한, 읽기 전용)
		// 자원 반납
	}

}