1. 웹소켓의 주요 특징은 무엇인가요?
2. 웹소켓은 어떻게 동작하나요?
3. 웹소켓과 HTTP의 차이점은 무엇인가요?
4. 웹소켓의 핸드셰이크 과정이란 무엇인가요?
5. 웹소켓의 활용 사례는 무엇인가요?
6. 웹소켓의 단점은 무엇인가요?
7. 웹소켓과 폴링(Polling), 롱 폴링(Long Polling)의 차이는 무엇인가요?
8. 웹소켓과 REST API를 언제 사용해야 하나요?
9. 웹소켓 보안을 어떻게 보장하나요?
10. 웹소켓 연결 상태 코드
11. 웹소켓의 대안 기술은 무엇인가요?
12. 웹소켓을 활용한 채팅 프로젝트
7. 웹소켓과 폴링(Polling), 롱 폴링(Long Polling)의 차이는 무엇인가요?
웹소켓 - 서버 코드
// Spring WebSocket 서버
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.handler.TextWebSocketHandler;
import org.springframework.web.socket.config.annotation.EnableWebSocket;
import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;
@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {
@Override
public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
registry.addHandler(new WebSocketHandler(), "/ws");
}
}
class WebSocketHandler extends TextWebSocketHandler {
@Override
public void afterConnectionEstablished(WebSocketSession session) throws Exception {
System.out.println("WebSocket connection established.");
}
@Override
protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
System.out.println("Received message: " + message.getPayload());
session.sendMessage(new TextMessage("Hello from server!"));
}
@Override
public void afterConnectionClosed(WebSocketSession session, org.springframework.web.socket.CloseStatus status) {
System.out.println("WebSocket connection closed.");
}
}
웹소켓 - 클라이언트 코드
import javax.websocket.*;
import java.net.URI;
@ClientEndpoint
public class WebSocketClient {
@OnOpen
public void onOpen(Session session) {
System.out.println("Connected to server.");
try {
session.getBasicRemote().sendText("Hello Server!");
} catch (Exception e) {
e.printStackTrace();
}
}
@OnMessage
public void onMessage(String message) {
System.out.println("Received from server: " + message);
}
@OnClose
public void onClose() {
System.out.println("Connection closed.");
}
public static void main(String[] args) throws Exception {
WebSocketContainer container = ContainerProvider.getWebSocketContainer();
container.connectToServer(WebSocketClient.class, new URI("ws://localhost:8080/ws"));
}
}
폴링(Polling)
폴링은 클라이언트가 일정 주기로 HTTP 요청을 서버에 보내는 방식입니다.
폴링(Polling)
폴링은 클라이언트가 일정 주기로 HTTP 요청을 서버에 보내는 방식입니다.
폴링 - 서버
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import java.time.LocalDateTime;
@RestController
public class PollingController {
@GetMapping("/polling")
public String getPollingData() {
return "Current server time: " + LocalDateTime.now();
}
}
폴링 - 클라이언트
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.Scanner;
public class PollingClient {
public static void main(String[] args) throws InterruptedException {
while (true) {
try {
URL url = new URL("http://localhost:8080/polling");
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
connection.setRequestMethod("GET");
Scanner scanner = new Scanner(connection.getInputStream());
while (scanner.hasNext()) {
System.out.println(scanner.nextLine());
}
scanner.close();
connection.disconnect();
} catch (Exception e) {
e.printStackTrace();
}
// 5초마다 요청
Thread.sleep(5000);
}
}
}
롱 폴링(Long Polling)
롱 폴링에서는 클라이언트가 요청을 보내면 서버가 새로운 데이터가 생길 때까지응답을 지연합니다.
롱폴링- 서버
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.concurrent.CompletableFuture;
@RestController
public class LongPollingController {
@GetMapping("/long-polling")
public CompletableFuture<String> getLongPollingData() {
// 새로운 데이터가 생길 때까지 응답 지연 (예: 10초 후에 데이터 반환)
return CompletableFuture.supplyAsync(() -> {
try {
Thread.sleep(10000); // 10초 지연
} catch (InterruptedException e) {
e.printStackTrace();
}
return "New data available at: " + System.currentTimeMillis();
});
}
}
롱폴링 - 클라이언트
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.Scanner;
public class LongPollingClient {
public static void main(String[] args) {
while (true) {
try {
URL url = new URL("http://localhost:8080/long-polling");
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
connection.setRequestMethod("GET");
Scanner scanner = new Scanner(connection.getInputStream());
while (scanner.hasNext()) {
System.out.println(scanner.nextLine());
}
scanner.close();
connection.disconnect();
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
8. 웹소켓과 REST API를 언제 사용해야 하나요?
웹소켓 사용 시점:
데이터가 실시간으로 교환되어야 하는 경우.
이벤트 기반 시스템 (ex. 채팅, 주식 시세).
REST API 사용 시점:
요청-응답 기반의 정적인 데이터 전송.
CRUD 작업 (ex. 사용자 정보 조회, 데이터 저장).
9. 웹소켓 보안을 어떻게 보장하나요?
TLS 사용: wss://를 사용하여 데이터 암호화.
인증: 핸드셰이크 시 인증 토큰이나 API 키를 포함.
CORS 설정: 허용된 도메인에서만 접근 가능하도록 설정.
DoS 공격 방지: 연결 수 제한, 시간 초과 설정.
10. 웹소켓 연결 상태 코드
웹소켓의 연결 종료 시 사용되는 상태 코드:
1000: 정상 종료.
1001: 서버 종료.
1002: 프로토콜 에러.
1003: 데이터 형식 에러.
11. 웹소켓의 대안 기술은 무엇인가요?
Server-Sent Events (SSE):
서버에서 클라이언트로 단방향 스트리밍.
브라우저 지원이 좋고, HTTP 기반.
폴링/롱 폴링:
간단한 구현으로 주기적인 서버 데이터 요청 가능.
12. 웹소켓을 활용한 채팅 프로젝트
1) 문제: accept 블로킹
1) 해결: accept 블로킹 - 역할 분리
블로킹이 되는 부분은 별도의 스레드로 나누어 실행
2) 문제: 읽기&쓰기 기다림
채팅은 실시간으로 대화를 주고 받아야한다.
그러나 입력이 있을때까지 무한 대기해야한다.
고객
public class ClientV6 {
private static final int PORT = 12345;
public static void main(String[] args) throws IOException {
log("클라이언트 시작");
try (Socket socket = new Socket("localhost", PORT);
DataInputStream input = new DataInputStream(socket.getInputStream());
DataOutputStream output = new DataOutputStream(socket.getOutputStream())) {
log("소캣 연결: " + socket);
Scanner scanner = new Scanner(System.in);
while (true) {
System.out.print("전송 문자: ");
String toSend = scanner.nextLine();
// 서버에게 문자 보내기
output.writeUTF(toSend);
log("client -> server: " + toSend);
if (toSend.equals("exit")) {
break;
}
// 서버로부터 문자 받기
String received = input.readUTF();
log("client <- server: " + received);
}
} catch (IOException e) {
log(e);
}
}
}
서버
package network.tcp.v6;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import static util.MyLogger.log;
public class ServerV6 {
private static final int PORT = 12345;
public static void main(String[] args) throws IOException {
log("서버 시작");
SessionManagerV6 sessionManager = new SessionManagerV6();
ServerSocket serverSocket = new ServerSocket(PORT);
log("서버 소켓 시작 - 리스닝 포트: " + PORT);
// ShutdownHook 등록
ShutdownHook shutdownHook = new ShutdownHook(serverSocket, sessionManager);
Runtime.getRuntime().addShutdownHook(new Thread(shutdownHook, "shutdown"));
try {
while (true) {
Socket socket = serverSocket.accept(); // 블로킹
log("소켓 연결: " + socket);
SessionV6 session = new SessionV6(socket, sessionManager);
Thread thread = new Thread(session);
thread.start();
}
} catch (IOException e) {
log("서버 소켓 종료: " + e);
}
}
static class ShutdownHook implements Runnable {
private final ServerSocket serverSocket;
private final SessionManagerV6 sessionManager;
public ShutdownHook(ServerSocket serverSocket, SessionManagerV6 sessionManager) {
this.serverSocket = serverSocket;
this.sessionManager = sessionManager;
}
@Override
public void run() {
log("shutdownHook 실행");
try {
sessionManager.closeAll();
serverSocket.close();
Thread.sleep(1000); // 자원 정리 대기
} catch (Exception e) {
e.printStackTrace();
System.out.println("e = " + e);
}
}
}
}
