12. UDP 소켓

UDP

1.비 연결 지향 프로그래밍
2.TCP와 달리 연결되지 않은 상태로 데이터 통신을 하기 때문에 패킷이 유실될 가능성이 있다
3.속도 면에서는 큰 장점이 있다. ( 처음 반응속도가 빠르다 )

TCP 서버 포트 6000 / UDP 서버 포트 6000 일 때 충돌이 날까?
나지않는다. 다른 프로토콜이라서 그렇다.

UDP Echo Server

UDPEchoServer.java

public class UDPEchoServer {
	private static final int PORT = 6000;
	private static final int BUFFER_SIZE = 1000;

	public static void main(String[] args) {

		DatagramSocket socket = null;

		try {
			//1. Socket 생성
			socket = new DatagramSocket(PORT);

			//2. 데이터 수신
			DatagramPacket receivePacket =
					new DatagramPacket(new byte[BUFFER_SIZE], BUFFER_SIZE);

			while( true ) {
			//3. 데이터 수신 대기
			socket.receive( receivePacket ); //block

			//4. 수신
			String message =
					new String( receivePacket.getData(), 0, receivePacket.getLength(), "UTF-8");

			System.out.println( message );

			//5. 데이터 송신
			byte[] sendData = message.getBytes( "UTF-8" );
			DatagramPacket sendPacket =
					new DatagramPacket( sendData,
										sendData.length,
										receivePacket.getAddress(),
										receivePacket.getPort() );

			socket.send( sendPacket );
			}
		} catch (SocketException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		} finally {
			if( socket != null && socket.isClosed() == false) {
				socket.close();				
			}

		}
	}

}

UDP Echo Client

UDPEchoClient.java

public class UDPEchoClient {
	private static final String SERVER_IP = "192.168.111.1";
	private static final int SERVER_PORT = 6000;
	private static final int BUFFER_SIZE = 1024;

	public static void main(String[] args) {
		DatagramSocket socket = null;
		Scanner scanner = null;

		try {
			// 0. 키보드 연결
			scanner = new Scanner(System.in);

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

			while (true) {

				System.out.print(">>");
				String message = scanner.nextLine();

				if( "".equals(message)) {
					continue;					
				}

				if( "quit".equals( message )) {
					break;
				}

				//2. 전송패킷 생성
				byte[] sendData = message.getBytes("utf-8");

				DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length,
						new InetSocketAddress(SERVER_IP, SERVER_PORT));

				//3. 전송
				socket.send(sendPacket);

				//4. 메세지 수신
				DatagramPacket receivePacket = new DatagramPacket( new byte[ BUFFER_SIZE], BUFFER_SIZE);
				socket.receive(receivePacket);

				message = new String( receivePacket.getData(), 0, receivePacket.getLength(), "UTF-8") ;
				System.out.println("<<"+message);						

			}
		} catch (SocketException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		} finally {
			if (socket != null && socket.isClosed() == false) {
				socket.close();
			}
			scanner.close();
		}
	}
}