feat: 1:1 실시간 채팅 시스템 구현

build.gradle

@@ -61,6 +61,8 @@ dependencies {
     implementation 'org.redisson:redisson-spring-boot-starter:3.27.2'
     // OAuth
     implementation 'org.springframework.boot:spring-boot-starter-oauth2-client:3.5.0'
+    // WebSocket
+    implementation 'org.springframework.boot:spring-boot-starter-websocket'
 }
 
 tasks.named('test') {

src/main/java/hanium/modic/backend/common/error/ErrorCode.java

@@ -76,6 +76,12 @@ public enum ErrorCode {
 	AI_IMAGE_PERMISSION_NOT_FOUND(HttpStatus.FORBIDDEN, "A-004", "AI 이미지 생성 권한이 없습니다."),
 	AI_REQUEST_TICKET_PROCESSING_FAIL_EXCEPTION(HttpStatus.INTERNAL_SERVER_ERROR, "A-005", "티켓 처리에 실패했습니다."),
 	AI_REQUEST_TICKET_NOT_ENOUGH_EXCEPTION(HttpStatus.BAD_REQUEST, "AI-006", "티켓이 부족합니다."),
+
+	// Chat
+	CHAT_ROOM_NOT_FOUND_EXCEPTION(HttpStatus.NOT_FOUND, "CH-001", "해당 채팅방을 찾을 수 없습니다."),
+	CHAT_MESSAGE_NOT_FOUND_EXCEPTION(HttpStatus.NOT_FOUND, "CH-002", "해당 채팅 메시지를 찾을 수 없습니다."),
+	CHAT_SELF_ROOM_CREATION_EXCEPTION(HttpStatus.BAD_REQUEST, "CH-003", "자기 자신과는 채팅방을 만들 수 없습니다."),
+	CHAT_ROOM_ACCESS_DENIED_EXCEPTION(HttpStatus.FORBIDDEN, "CH-004", "해당 채팅방에 접근할 권한이 없습니다."),
 	;
 
 	private final HttpStatus status;

src/main/java/hanium/modic/backend/common/websocket/config/WebSocketConfig.java

@@ -0,0 +1,47 @@
+package hanium.modic.backend.common.websocket.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.messaging.simp.config.ChannelRegistration;
+import org.springframework.messaging.simp.config.MessageBrokerRegistry;
+import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
+import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
+import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;
+
+import hanium.modic.backend.common.jwt.JwtTokenProvider;
+import hanium.modic.backend.common.websocket.interceptor.StompChannelInterceptor;
+import hanium.modic.backend.common.websocket.interceptor.WebSocketAuthInterceptor;
+import lombok.RequiredArgsConstructor;
+
+@Configuration
+@EnableWebSocketMessageBroker
+@RequiredArgsConstructor
+public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
+
+	private final JwtTokenProvider jwtTokenProvider;
+	private final StompChannelInterceptor stompChannelInterceptor;
+
+	@Override
+	public void configureMessageBroker(MessageBrokerRegistry config) {
+		config.enableSimpleBroker("/topic"); // 브로커가 발행한 메세지를 클라이언트가 구독
+		config.setApplicationDestinationPrefixes("/app"); // 클라이언트가 보낼 메세지를 Controller로 전달
+	}
+
+	@Override
+	public void registerStompEndpoints(StompEndpointRegistry registry) {
+		registry.addEndpoint("/ws/chat")
+			.setAllowedOriginPatterns("*") // TODO: 실제 도메인으로 변경 필요
+			.addInterceptors(webSocketAuthInterceptor()) // 핸드세이크 과정 인터셉터, 인증용
+			.withSockJS();
+	}
+
+	@Override
+	public void configureClientInboundChannel(ChannelRegistration registration) {
+		registration.interceptors(stompChannelInterceptor);
+	}
+
+	@Bean
+	public WebSocketAuthInterceptor webSocketAuthInterceptor() {
+		return new WebSocketAuthInterceptor(jwtTokenProvider);
+	}
+}

src/main/java/hanium/modic/backend/common/websocket/interceptor/StompChannelInterceptor.java

@@ -0,0 +1,67 @@
+package hanium.modic.backend.common.websocket.interceptor;
+
+import static hanium.modic.backend.common.error.ErrorCode.*;
+
+import java.security.Principal;
+import java.util.Optional;
+
+import org.springframework.messaging.Message;
+import org.springframework.messaging.MessageChannel;
+import org.springframework.messaging.simp.stomp.StompCommand;
+import org.springframework.messaging.simp.stomp.StompHeaderAccessor;
+import org.springframework.messaging.support.ChannelInterceptor;
+import org.springframework.messaging.support.MessageHeaderAccessor;
+import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
+import org.springframework.stereotype.Component;
+
+import hanium.modic.backend.common.error.exception.AppException;
+import hanium.modic.backend.common.jwt.JwtTokenProvider;
+import hanium.modic.backend.domain.user.entity.UserEntity;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class StompChannelInterceptor implements ChannelInterceptor {
+
+	private final JwtTokenProvider jwtTokenProvider;
+
+	@Override
+	public Message<?> preSend(Message<?> message, MessageChannel channel) {
+		StompHeaderAccessor accessor = MessageHeaderAccessor.getAccessor(message, StompHeaderAccessor.class);
+
+		// STOMP CONNECT 명령어가 아닌 경우, 메시지를 그대로 반환
+		if (accessor == null || !StompCommand.CONNECT.equals(accessor.getCommand())) {
+			return message;
+		}
+
+		// Authorization 헤더에서 Bearer 토큰 추출
+		String token = Optional.ofNullable(accessor.getFirstNativeHeader("Authorization"))
+			.filter(auth -> auth.startsWith("Bearer "))
+			.map(auth -> auth.substring(7))
+			.orElse(null);
+
+		if (token == null) {
+			log.warn("StompChannelInterceptor - STOMP 연결 실패 - Authorization 헤더 누락 또는 형식 오류");
+			return null;
+		}
+
+		// 토큰 유효성 검사 및 사용자 정보 추출
+		try {
+			jwtTokenProvider.validateToken(token);
+
+			UserEntity user = jwtTokenProvider.getUser(token)
+				.orElseThrow(() -> new AppException(USER_NOT_FOUND_EXCEPTION));
+
+			Principal principal = new UsernamePasswordAuthenticationToken(user.getId().toString(), null);
+			accessor.setUser(principal);
+
+			log.debug("StompChannelInterceptor - STOMP 연결 인증 성공 - 사용자 ID: {}", user.getId());
+			return message;
+		} catch (Exception e) {
+			log.warn("StompChannelInterceptor - STOMP 연결 인증 실패: {}", e.getMessage());
+			return null;
+		}
+	}
+}

src/main/java/hanium/modic/backend/common/websocket/interceptor/WebSocketAuthInterceptor.java

@@ -0,0 +1,85 @@
+package hanium.modic.backend.common.websocket.interceptor;
+
+import static hanium.modic.backend.common.error.ErrorCode.*;
+
+import java.security.Principal;
+import java.util.Map;
+
+import org.springframework.http.server.ServerHttpRequest;
+import org.springframework.http.server.ServerHttpResponse;
+import org.springframework.web.socket.WebSocketHandler;
+import org.springframework.web.socket.server.HandshakeInterceptor;
+
+import hanium.modic.backend.common.error.ErrorCode;
+import hanium.modic.backend.common.error.exception.AppException;
+import hanium.modic.backend.common.jwt.JwtTokenProvider;
+import hanium.modic.backend.domain.user.entity.UserEntity;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+@RequiredArgsConstructor
+public class WebSocketAuthInterceptor implements HandshakeInterceptor {
+
+	private final JwtTokenProvider jwtTokenProvider;
+
+	// WebSocket 핸드세이킹 허용 여부 결정 메서드
+	@Override
+	public boolean beforeHandshake(
+		ServerHttpRequest request,
+		ServerHttpResponse response,
+		WebSocketHandler wsHandler,
+		Map<String, Object> attributes
+	) throws Exception {
+		String token = extractTokenFromRequest(request);
+
+		if (token != null) {
+			try {
+				jwtTokenProvider.validateToken(token);
+
+				UserEntity user = jwtTokenProvider.getUser(token)
+					.orElseThrow(() -> new AppException(USER_NOT_FOUND_EXCEPTION));
+				attributes.put("userId", user.getId());
+				log.debug("WebSocket 연결 인증 성공 - 사용자 ID: {}", user.getId());
+				return true;
+			} catch (Exception e) {
+				log.error("WebSocket 토큰 파싱 실패: {}", e.getMessage());
+			}
+		}
+
+		log.warn("WebSocket 연결 인증 실패");
+		return false;
+	}
+
+	@Override
+	public void afterHandshake(
+		ServerHttpRequest request,
+		ServerHttpResponse response,
+		WebSocketHandler wsHandler,
+		Exception exception
+	) {
+		// 핸드셰이크 후 처리 로직
+	}
+
+	// 추출된 토큰을 요청에서 가져오는 메서드
+	private String extractTokenFromRequest(ServerHttpRequest request) {
+		// 헤더에서 Bearer 토큰 추출 시도
+		String token = request.getHeaders().getFirst("Authorization");
+		if (token != null && token.startsWith("Bearer ")) {
+			return token.substring(7);
+		}
+
+		// 실패 시 쿼리 파라미터에서 token 추출
+		String queryToken = request.getURI().getQuery();
+		if (queryToken != null && queryToken.contains("token=")) {
+			String[] params = queryToken.split("&");
+			for (String param : params) {
+				if (param.startsWith("token=")) {
+					return param.substring(6);
+				}
+			}
+		}
+
+		return null;
+	}
+}

src/main/java/hanium/modic/backend/domain/chat/entity/ChatMessageEntity.java

@@ -0,0 +1,60 @@
+package hanium.modic.backend.domain.chat.entity;
+
+import hanium.modic.backend.common.entity.BaseEntity;
+import hanium.modic.backend.domain.user.entity.UserEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.FetchType;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.JoinColumn;
+import jakarta.persistence.Lob;
+import jakarta.persistence.ManyToOne;
+import jakarta.persistence.Table;
+import lombok.AccessLevel;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Table(name = "chat_messages")
+@Entity
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class ChatMessageEntity extends BaseEntity {
+
+	@Id
+	@Column(name = "id")
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	private Long id;
+
+	@Column(name = "message_id", unique = true, nullable = false)
+	private String messageId;
+
+	@Column(name = "chatRoom_id", nullable = false)
+	private Long chatRoomId;
+
+	@Column(name = "sender_id", nullable = false)
+	private Long senderId;
+
+	@Lob
+	@Column(name = "message", nullable = false)
+	private String message;
+
+	@Column(name = "is_read", nullable = false)
+	private Boolean isRead = false;
+
+	@Builder
+	private ChatMessageEntity(String messageId, ChatRoomEntity chatRoom, UserEntity sender, String message) {
+		this.messageId = messageId;
+		this.chatRoomId = chatRoom.getId();
+		this.senderId = sender.getId();
+		this.message = message;
+		this.isRead = false;
+	}
+
+	// 메시지 읽음 처리
+	public void markAsRead() {
+		this.isRead = true;
+	}
+}

src/main/java/hanium/modic/backend/domain/chat/entity/ChatRoomEntity.java

@@ -0,0 +1,78 @@
+package hanium.modic.backend.domain.chat.entity;
+
+import hanium.modic.backend.common.entity.BaseEntity;
+import hanium.modic.backend.domain.user.entity.UserEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.Table;
+import lombok.AccessLevel;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Table(name = "chat_rooms")
+@Entity
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class ChatRoomEntity extends BaseEntity {
+
+	@Id
+	@Column(name = "id")
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	private Long id;
+
+	@Column(name = "user1_id", nullable = false)
+	private Long user1Id;
+
+	@Column(name = "user2_id", nullable = false)
+	private Long user2Id;
+
+	@Column(name = "user1_deleted", nullable = false)
+	private Boolean user1Deleted = false;
+
+	@Column(name = "user2_deleted", nullable = false)
+	private Boolean user2Deleted = false;
+
+	@Builder
+	private ChatRoomEntity(UserEntity user1, UserEntity user2) {
+		this.user1Id = user1.getId();
+		this.user2Id = user2.getId();
+		this.user1Deleted = false;
+		this.user2Deleted = false;
+	}
+
+	// 유저 소프트 삭제
+	public void deleteForUser(Long userId) {
+		if (user1Id.equals(userId)) {
+			this.user1Deleted = true;
+		} else if (user2Id.equals(userId)) {
+			this.user2Deleted = true;
+		}
+	}
+
+	// 상대방 유저 반환
+	public Long getOpponent(Long userId) {
+		if (user1Id.equals(userId)) {
+			return user2Id;
+		}
+		return user1Id;
+	}
+
+	// 채팅방을 모든 유저가 삭제했는지 확인
+	public boolean isDeleted() {
+		return user1Deleted && user2Deleted;
+	}
+
+	// 특정 유저가 채팅방을 삭제했는지 확인
+	public boolean isDeletedForUser(Long userId) {
+		if (user1Id.equals(userId)) {
+			return user1Deleted;
+		} else if (user2Id.equals(userId)) {
+			return user2Deleted;
+		}
+		return false;
+	}
+}