웹소켓

websocket에 대해 공부하고 정리한 글입니다.

 

 

웹소켓 통신의 시작

 

웹소켓 통신은 시작은 HTTP request 입니다.

이때 HTTP request 헤더에는 Connection : "Upgrade", Upgrade : "websocket"을 포함하고 있습니다.

GET /spring-websocket-portfolio/portfolio HTTP/1.1
Host: localhost:8080
Upgrade: websocket 
Connection: Upgrade 
Sec-WebSocket-Key: Uc9l9TMkWGbHFD2qnFHltg==
Sec-WebSocket-Protocol: v10.stomp, v11.stomp
Sec-WebSocket-Version: 13
Origin: http://localhost:8080

 

 

웹소켓 서버가 web server 뒤에서 실행된다면?

 

👽웹소켓 서버가 nginx와 같은 web server 뒤에서 실행되고 있다면 웹소켓의 upgrade request를 웹소켓 서버로 전송하기 위한 설정이 필요합니다.

 

nginx의 경우에 아래 처럼 Upgrade와 Connection 헤더를 반드시 명시해야 합니다.

$vi /etc/nginx/sites-available/proxy.conf

# 아래 부분 추가
      location /api/stomp {
               proxy_pass http://00.00.00.000:8080; # WebSocket Server

               proxy_http_version 1.1;
               proxy_set_header Upgrade $http_upgrade;
               proxy_set_header Connection "Upgrade";
               proxy_set_header Host $host;
       }

Connection과 Upgrade를 설정해주는 것을 볼 수 있습니다.

 

 

HTTP vs WebSockt

• 웹소켓은 HTTP와 다르게 처음 연결을 위한 하나의 URL만 사용합니다.
• 웹소켓은 HTTP와 다르게 전송된 메시지에 형식이 없습니다. 따라서 클라이언트와 서버간 형식을 서로 약속해서 통신해야 합니다.
  • STOMP를 사용해서 메시지 형식이 없다는 문제를 해결할 수 있습니다.
  • STOMP는 커스텀 헤더를 사용할 수 있습니다.
  • 커스텀 헤더를 사용해서 JWT토큰을 관리할 수 있습니다.

 

구현방법

 

1. WebSocketHandler

WebSocketHandler를 구현해서 웹소켓 서버를 생성할 수 있습니다.

이때 AbstractWebSocketHandler를 extends한 TextWebsocketHandler 또는 BinaryWebSocketHandler를 사용할 수 있습니다.

public class MyHandler extends TextWebSocketHandler {

	@Override
	public void handleTextMessage(WebSocketSession session, TextMessage message) {
		// ...
	}

}

이때 AbstractWebSocketHandler는 WebSocketHandler를 implements 하고 있는 것을 볼 수 있습니다.

 

2. WebSocketConfigurer

WebSocketConfigurer를 작성해서 WebSocketHandler를 등록하고 WebSocketRequest를 핸들링 하기 위한 콜백 메소드를 작성합니다.

@Configuration
@EnableWebSocket
public class WebSocketConfiguration implements WebSocketConfigurer {

    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry
                .addHandler(echoWebSocketHandler(), "/ws")
                .setAllowedOrigins("*");
    }

    @Bean
    public WebSocketHandler echoWebSocketHandler() {
        return new WebSocketHandler();
    }

}

 

작성중..

 

 

 

참고자료

 

https://docs.spring.io/spring-framework/reference/web/websocket.html

WebSockets :: Spring Framework

https://velog.io/@hanblueblue/%EB%B2%88%EC%97%AD-Spring-4-Spring-WebSocket