AI 이미지 생성 응답 큐 DLQ 및 재시도 메커니즘 추가

src/main/java/hanium/modic/backend/common/amqp/config/RabbitMqConfig.java

@@ -9,6 +9,7 @@
 import org.springframework.amqp.core.Queue;
 import org.springframework.amqp.core.TopicExchange;
 import org.springframework.amqp.rabbit.annotation.EnableRabbit;
+import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
 import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
 import org.springframework.amqp.rabbit.core.RabbitAdmin;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
@@ -38,6 +39,14 @@ public class RabbitMqConfig {
 	public static final String AI_IMAGE_REQUEST_DLQ_ROUTING_KEY = "ai.image.request.dlq";
 	public static final String AI_IMAGE_REQUEST_RETRY_ROUTING_KEY = "ai.image.request.retry";
 
+	// DLQ (Dead Letter Queue) 및 재시도 관련 상수 - AI Image Created
+	public static final String AI_IMAGE_CREATED_DLX = "ai.image.created.dlx";
+	public static final String AI_IMAGE_CREATED_DLQ = "ai.image.created.dlq";
+	public static final String AI_IMAGE_CREATED_RETRY_EXCHANGE = "ai.image.created.retry.exchange";
+	public static final String AI_IMAGE_CREATED_RETRY_QUEUE = "ai.image.created.retry.queue";
+	public static final String AI_IMAGE_CREATED_DLQ_ROUTING_KEY = "ai.image.created.dlq";
+	public static final String AI_IMAGE_CREATED_RETRY_ROUTING_KEY = "ai.image.created.retry";
+
 	// Similarity Check Request
 	public static final String VOTE_SIMILARITY_REQUEST_QUEUE = "vote.similarity.request.queue";
 	public static final String VOTE_SIMILARITY_REQUEST_EXCHANGE = "vote.similarity.request.exchange";
@@ -72,7 +81,10 @@ public Binding aiImageRequestBinding(Queue aiImageRequestQueue, TopicExchange ai
 
 	@Bean
 	public Queue aiImageCreatedQueue() {
-		return new Queue(AI_IMAGE_CREATED_QUEUE, true);
+		Map<String, Object> args = new HashMap<>();
+		args.put("x-dead-letter-exchange", AI_IMAGE_CREATED_DLX);
+		args.put("x-dead-letter-routing-key", AI_IMAGE_CREATED_RETRY_ROUTING_KEY);
+		return new Queue(AI_IMAGE_CREATED_QUEUE, true, false, false, args);
 	}
 
 	@Bean
@@ -87,6 +99,60 @@ public Binding aiImageCreatedBinding(Queue aiImageCreatedQueue, TopicExchange ai
 			.with(AI_IMAGE_CREATED_ROUTING_KEY);
 	}
 
+	// DLX (Dead Letter Exchange) - AI Image Created
+	@Bean
+	public TopicExchange aiImageCreatedDlx() {
+		return new TopicExchange(AI_IMAGE_CREATED_DLX, true, false);
+	}
+
+	// 최종 실패 메시지 저장소
+	@Bean
+	public Queue aiImageCreatedDlq() {
+		return new Queue(AI_IMAGE_CREATED_DLQ, true);
+	}
+
+	// DLX에서 최종 DLQ로의 바인딩
+	@Bean
+	public Binding aiImageCreatedDlqBinding(Queue aiImageCreatedDlq, TopicExchange aiImageCreatedDlx) {
+		return BindingBuilder.bind(aiImageCreatedDlq)
+			.to(aiImageCreatedDlx)
+			.with(AI_IMAGE_CREATED_DLQ_ROUTING_KEY);
+	}
+
+	// 재시도용 Exchange
+	@Bean
+	public TopicExchange aiImageCreatedRetryExchange() {
+		return new TopicExchange(AI_IMAGE_CREATED_RETRY_EXCHANGE, true, false);
+	}
+
+	// 재시도 대기 Queue (TTL 60초 설정, 만료 시 원래 exchange로 재전송)
+	@Bean
+	public Queue aiImageCreatedRetryQueue() {
+		Map<String, Object> args = new HashMap<>();
+		args.put("x-message-ttl", 60000); // 60초
+		args.put("x-dead-letter-exchange", AI_IMAGE_CREATED_EXCHANGE);
+		args.put("x-dead-letter-routing-key", AI_IMAGE_CREATED_ROUTING_KEY);
+		return new Queue(AI_IMAGE_CREATED_RETRY_QUEUE, true, false, false, args);
+	}
+
+	// 재시도 Exchange와 Queue 바인딩
+	@Bean
+	public Binding aiImageCreatedRetryBinding(Queue aiImageCreatedRetryQueue,
+		TopicExchange aiImageCreatedRetryExchange) {
+		return BindingBuilder.bind(aiImageCreatedRetryQueue)
+			.to(aiImageCreatedRetryExchange)
+			.with(AI_IMAGE_CREATED_RETRY_ROUTING_KEY);
+	}
+
+	// DLX에서 재시도 Exchange로의 바인딩
+	@Bean
+	public Binding aiImageCreatedDlxToRetryBinding(TopicExchange aiImageCreatedRetryExchange,
+		TopicExchange aiImageCreatedDlx) {
+		return BindingBuilder.bind(aiImageCreatedRetryExchange)
+			.to(aiImageCreatedDlx)
+			.with(AI_IMAGE_CREATED_RETRY_ROUTING_KEY);
+	}
+
 	// DLX (Dead Letter Exchange) - 실패한 메시지를 받아서 재시도 또는 최종 처리로 라우팅
 	@Bean
 	public TopicExchange aiImageRequestDlx() {
@@ -186,14 +252,33 @@ public CachingConnectionFactory connectionFactory() {
 
 		connectionFactory.setRequestedHeartBeat(120); // 2분
 
-		try {
-			connectionFactory.getRabbitConnectionFactory().useSslProtocol("TLSv1.2");
-		} catch (Exception e) {
-			throw new RuntimeException("RabbitMQ SSL 설정 실패", e);
+		// AWS AmazonMQ는 포트 5671에서 자동으로 SSL을 사용
+		// 포트 5671일 경우에만 SSL 프로토콜 활성화
+		if (rabbitMqProperties.getPort() == 5671) {
+			try {
+				connectionFactory.getRabbitConnectionFactory().useSslProtocol();
+			} catch (Exception e) {
+				throw new RuntimeException("RabbitMQ SSL 설정 실패", e);
+			}
 		}
 		return connectionFactory;
 	}
 
+	@Bean
+	public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(
+		CachingConnectionFactory connectionFactory) {
+		SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
+		factory.setConnectionFactory(connectionFactory);
+		factory.setMessageConverter(jackson2JsonMessageConverter());
+
+		// 리스너에서 예외 발생 시 메시지를 다시 큐로 반환하지 않음
+		// DLQ가 설정된 큐는 x-dead-letter-exchange를 통해 DLX로 라우팅되고
+		// DLQ에서 실패해도 무한 루프가 발생하지 않음
+		factory.setDefaultRequeueRejected(false);
+
+		return factory;
+	}
+
 	@Bean
 	public AmqpAdmin amqpAdmin(CachingConnectionFactory connectionFactory) {
 		return new RabbitAdmin(connectionFactory);

src/main/java/hanium/modic/backend/domain/ai/aiServer/enums/AiImageStatus.java

@@ -4,5 +4,6 @@ public enum AiImageStatus {
 	REQUEST, // 요청 상태 및 요청 완료 상태
 	REQUEST_PENDING, // AI 요청 대기 상태
 	REQUEST_FAILED, // AI 요청 실패 상태
-	RESPONSE // 응답을 의미
+	RESPONSE, // 응답을 의미
+	RESPONSE_FAILED // 응답 처리 실패 상태
 }

src/main/java/hanium/modic/backend/domain/ai/aiServer/listener/AiImageCreatedDlqListener.java

@@ -0,0 +1,71 @@
+package hanium.modic.backend.domain.ai.aiServer.listener;
+
+import static hanium.modic.backend.common.amqp.config.RabbitMqConfig.*;
+
+import java.util.Optional;
+
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+import hanium.modic.backend.domain.ai.aiChat.entity.AiChatMessageEntity;
+import hanium.modic.backend.domain.ai.aiChat.repository.AiChatMessageRepository;
+import hanium.modic.backend.domain.ai.aiServer.dto.AiImageResponseMessageDto;
+import hanium.modic.backend.domain.ai.aiServer.enums.AiImageStatus;
+import hanium.modic.backend.domain.ai.aiServer.enums.SenderType;
+import hanium.modic.backend.domain.ai.aiServer.service.AiResponseSseService;
+import hanium.modic.backend.web.ai.aiChat.dto.response.ChatMessageResponse;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class AiImageCreatedDlqListener {
+
+	private final AiChatMessageRepository aiChatMessageRepository;
+	private final AiResponseSseService aiResponseSseService;
+
+	/**
+	 * AI 이미지 생성 응답 처리 최종 실패 메시지 처리
+	 * - 메시지 상태를 RESPONSE_FAILED로 변경
+	 * - SSE 연결이 있으면 클라이언트에 실패 알림
+	 * @param messageDto AI 이미지 응답 메시지
+	 * @param message RabbitMQ 메시지 메타데이터
+	 */
+	@Transactional
+	@RabbitListener(queues = AI_IMAGE_CREATED_DLQ)
+	public void handleFinalFailedMessage(AiImageResponseMessageDto messageDto, Message message) {
+		log.error("[최종 실패] AI 이미지 생성 응답 처리 최종 실패: requestId={}", messageDto.requestId());
+
+		// 1. 요청 메시지 조회
+		Optional<AiChatMessageEntity> chatMessageOpt = aiChatMessageRepository
+			.findByRequestIdAndSenderType(messageDto.requestId(), SenderType.USER);
+
+		if (chatMessageOpt.isEmpty()) {
+			log.error("[데이터 오류] requestId={}에 해당하는 채팅 메시지를 찾을 수 없습니다", messageDto.requestId());
+			return;
+		}
+
+		AiChatMessageEntity requestChatMessage = chatMessageOpt.get();
+
+		// 2. 메시지 상태를 RESPONSE_FAILED로 변경
+		requestChatMessage.updateStatus(AiImageStatus.RESPONSE_FAILED);
+		aiChatMessageRepository.save(requestChatMessage);
+		log.info("[상태 업데이트] requestId={} 메시지 상태를 RESPONSE_FAILED로 변경", messageDto.requestId());
+
+		// 3. SSE 연결이 있으면 클라이언트에 실패 알림
+		try {
+			ChatMessageResponse errorResponse = ChatMessageResponse.createErrorResponse(
+				requestChatMessage,
+				"이미지 생성 응답 처리에 실패했습니다. 잠시 후 다시 시도해주세요."
+			);
+			aiResponseSseService.sendToClient(messageDto.requestId(), errorResponse);
+			log.info("[SSE 알림] requestId={} 클라이언트에 실패 알림 전송", messageDto.requestId());
+		} catch (Exception e) {
+			log.warn("[SSE 알림 실패] requestId={} SSE 연결이 없거나 전송 실패: {}",
+				messageDto.requestId(), e.getMessage());
+		}
+	}
+}

src/main/java/hanium/modic/backend/web/ai/aiChat/dto/response/ChatMessageResponse.java

@@ -35,4 +35,17 @@ public static ChatMessageResponse from(AiChatMessageEntity entity, String imageU
 	public static ChatMessageResponse from(AiChatMessageEntity entity) {
 		return from(entity, null);
 	}
+
+	public static ChatMessageResponse createErrorResponse(AiChatMessageEntity entity, String errorMessage) {
+		return new ChatMessageResponse(
+			entity.getId(),
+			entity.getMessageOrder(),
+			SenderType.AI,
+			errorMessage,
+			entity.getRequestId(),
+			null,
+			entity.getCreateAt(),
+			AiImageStatus.RESPONSE_FAILED
+		);
+	}
 }