[Java] TCP 네트워킹

TCP 네트워킹

-TCP는 연결형 프로토콜로 상대방이 연결된 상태에서 데이터를 주고 받는다.

-클라이언트가 연결 요청을 하고 서버가 연결을 수락하면 고정회선을 통해 데이터 전달

-java.net 패키지에서 ServerSocket 과 Socket 클래스 제공

- ServerSocket : 클라이언트의 연결을 수락하는 서버쪽 클래스
- Socket :  클라이언트 연결요청과 양쪽 데이터를 주고 받을때 사용 되는 클래스

[서버] 
- ServerSocket / Scoket 이용

package study0602.Network;

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

public class ServerExample {
	private static ServerSocket serverSocket = null;

	public static void main(String[] args) {
		// P.831

		System.out.println("---------------------------");
		System.out.println("서버를 종료하면 q 또는 Q를 입력하고 Enter 키를 입력하세요.");
		System.out.println("---------------------------");

		// TCP 서버시작
		startServer();

		// 키보드 입력
		Scanner sc = new Scanner(System.in);
		while (true) {
			String key = sc.nextLine();
			if (key.toLowerCase().equals("q")) {
				break;
			}
		}
		sc.close();

		// TCP서버 종료
		stopServer();

	}//

	private static void startServer() {
		// 작업 스레드 정의
		Thread thread = new Thread() {
			@Override
			public void run() {
				try {
					// ServerSocket 생성 및 Port 바인딩
					serverSocket = new ServerSocket(50001);
					System.out.println("[서버] 시작됨");

					while (true) {
						System.out.println("[서버] 연결 요청을 기다림");
						// 연결 수락
						Socket socket = serverSocket.accept();

						// 연결된 클라이언트 정보 얻기
						InetSocketAddress isa = (InetSocketAddress) socket.getRemoteSocketAddress();
						System.out.println("[서버]" + isa.getHostName() + "연결 요청을 수락함");

						// 연결 끊기
						socket.close();
						System.out.println("[서버]" + isa.getHostName() + "의 연결을 끊음");
					}

				} catch (IOException e) {
					// TODO: handle exception
					System.out.println("[서버]" + e.getMessage());
				}
			}
		};
		// 스레드 시작
		thread.start();

	}

	private static void stopServer() {

		try {
			// ServerSocket을 닫고 Port 언바인딩
			serverSocket.close();
			System.out.println("[서버] 종료됨");

		} catch (IOException e1) {
			// TODO: handle exception
		}

	}

}//

[클라이언트] 
- Socket 이용

package study0602.Client;

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

public class ClientExample {

	public static void main(String[] args) {
		// TODO Auto-generated method stub

		try {
			//Socket 생성과 동시에 localhost의 50001 Port로 연결 요청;
			Socket socket = new Socket("localhost",50001);
			System.out.println("[클라이언트] 연결성공");
			
			//Socket 닫기
			socket.close();
			System.out.println("[클라이언트] 연결 끊기");
			
		}catch (UnknownHostException e) {
			// IP 표기방법이 잘못되었을경우
		} 
		catch (IOException e) {
			// 해당 포트의 서버에 연결할 수 없는 경우
		}
		
		
		
	}//

}//

 

 

 

입출력 스트림으로 데이터 주고받기

- 클라이언트가 연결 요청( connect( ) )을 하고 서버가 연결 수락 ( accept( ) ) 했다면, 양쪽의 Socket객체로부터 각각 입력 스트림 ( InputStream ) 과 출력 스트림 ( OutPutStream ) 을 얻을 수 있다.

- 문자열을 간편하게 주고 받고 싶다면 보조 스트림 DataOutputStream / DataInputStream을 연결해서 사용 하면 된다.

 

DataOutputStream / DataInputStream 을 이용한 예제

[Server]

package study0602.Network;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

public class EchoServer {
	private static ServerSocket serverSocket = null;
	public static void main(String[] args) {
		// P.838 입출력 스트림으로 데이터 받기

		
		System.out.println("---------------------------");
		System.out.println("서버를 종료하면 q 또는 Q를 입력하고 Enter 키를 입력하세요.");
		System.out.println("---------------------------");
		
		//TCP 서버시작
		startServer();
		
		//키보드 입력
		Scanner sc= new Scanner(System.in);
		while (true) {
			String key = sc.nextLine();
			if(key.toLowerCase().equals("q")) {
				break;
			}
		}
		sc.close();
		
		//TCP서버 종료
		stopServer();
		
		
	}//
	
	private static void startServer() {
		Scanner sc = new Scanner(System.in);
		// 작업 스레드 정의
		Thread thread = new Thread(){
			@Override
			public void run() {
			try {
				//ServerSocket 생성 및 Port 바인딩
				serverSocket = new ServerSocket(50001);
				System.out.println("[서버] 시작됨");
				
				while (true) {
					System.out.println("[서버] 연결 요청을 기다림");
					//연결 수락
					Socket socket = serverSocket.accept();
					
					//연결된 클라이언트 정보 얻기
					InetSocketAddress isa = 
							(InetSocketAddress)socket.getRemoteSocketAddress();
					System.out.println("[서버]"+ isa.getHostName()+"연결 요청을 수락함");
					//-----------------------------------------------------
					//==데이터 받기
					
					DataInputStream dis = new DataInputStream(socket.getInputStream());
					String message = dis.readUTF();
					System.out.println("[서버] 받은 데이터 : " + message);
					
					//데이터 보내기
					DataOutputStream dos = new DataOutputStream(socket.getOutputStream());
					
					
					System.out.println("=====클라이언트에게 보낼 메세지 입력=====");				
					String send =sc.nextLine();
					System.out.println("=======================");
					dos.writeUTF(send);
					dos.flush();
					
					
					
					
					//----------------------------------------------------
					//연결 끊기
					socket.close();
					System.out.println("[서버]"+isa.getHostName()+ "의 연결을 끊음");
				}
				
			} catch (IOException e) {
				// TODO: handle exception
				System.out.println("[서버]"+e.getMessage());
			}
			}
		};
	//스레드 시작
		thread.start();
		
	}

	private static void stopServer() {
		
		try {
			//ServerSocket을 닫고 Port 언바인딩
			serverSocket.close();
			System.out.println("[서버] 종료됨");
			
		} catch (IOException e1) {
			// TODO: handle exception
		}
		
	}

	
	
	

}//

[Client]

package study0602.Client;

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

public class EchoClient {

	public static void main(String[] args) {
		// TODO Auto-generated method stub
		Scanner sc = new Scanner(System.in);
		try {
			//Socket 생성과 동시에 localhost의 50001 Port로 연결 요청;
			Socket socket = new Socket("localhost",50001);
			System.out.println("[클라이언트] 연결성공");
			
			//----------------------------------------
			
			System.out.println("======메세지 입력======");
			String sendMessage = sc.nextLine();
			
			
			DataOutputStream dos = new DataOutputStream(socket.getOutputStream());
			dos.writeUTF(sendMessage);
			dos.flush();
			System.out.println("[클라이언트] 데이터 보냄: "+sendMessage);
			
			//데이터 받기
			DataInputStream dis=new DataInputStream(socket.getInputStream());
			String receiveMessage = dis.readUTF();
			System.out.println("[클라이언트] 데이터 받음: " +receiveMessage  );
			
			//----------------------------------------			
						
			//Socket 닫기
			socket.close();
			System.out.println("[클라이언트] 연결 끊기");
			
		}catch (UnknownHostException e) {
			// IP 표기방법이 잘못되었을경우
		} 
		catch (IOException e) {
			// 해당 포트의 서버에 연결할 수 없는 경우
		}
		
	}//

}//