step7 DLX와 DLQ를 이용한 재처리 (manual 모드 세팅)

villainscode · villainscode · commit c5a6f20ddfa9 · 2024-12-25T12:50:33.000+09:00
diff --git a/src/main/java/net/harunote/hellomessagequeue/step7/MessageConsumer.java b/src/main/java/net/harunote/hellomessagequeue/step7/MessageConsumer.java
@@ -13,16 +13,14 @@ public class MessageConsumer {
     private static final int MAX_RETRIES = 3;
     private int retryCount = 0; // 재시도 횟수 관리
 
+    // RabbitMQManualConfig에서 선언한 containerFactory 설정 추가
     @RabbitListener(queues = RabbitMQConfig.ORDER_COMPLETED_QUEUE, containerFactory = "rabbitListenerContainerFactory")
     public void processMessage(String message, Channel channel, @Header("amqp_deliveryTag") long tag) {
-        System.out.println("[Order Queue Received]: " + message);
-
         try {
             // 실패를 강제로 유발
             if ("fail".equalsIgnoreCase(message)) {
-                System.out.println("### retryCount = " + retryCount);
-
-                if (retryCount < MAX_RETRIES -1) {
+                if (retryCount < MAX_RETRIES) {
+                    System.err.println("# fail & retry = " + retryCount);
                     retryCount++;
                     throw new RuntimeException("- Processing failed. Retry count: " + retryCount);
                 } else {
@@ -32,7 +30,6 @@ public void processMessage(String message, Channel channel, @Header("amqp_delive
                     return;
                 }
             }
-
             // 성공 처리
             System.out.println("+ Message processed successfully: " + message);
             channel.basicAck(tag, false); // Ack 전송
@@ -41,7 +38,7 @@ public void processMessage(String message, Channel channel, @Header("amqp_delive
         } catch (Exception e) {
             System.err.println("# Error processing message: " + e.getMessage());
             try {
-                // 실패 시 Nack 처리하여 메시지를 다시 처리
+                // 실패 시 basicReject 처리하여 메시지를 다시 처리
                 channel.basicReject(tag, true); // 재처리 가능하도록 Reject
             } catch (IOException ioException) {
                 System.err.println("# Failed to reject message: " + ioException.getMessage());
diff --git a/src/main/java/net/harunote/hellomessagequeue/step7/OrderController.java b/src/main/java/net/harunote/hellomessagequeue/step7/OrderController.java
@@ -25,6 +25,6 @@ public OrderController(OrderProducer orderProducer) {
     public ResponseEntity<String> sendMessage(@RequestParam String message) {
 
         orderProducer.sendShpping(message);
-        return ResponseEntity.ok("# Order Completed Message sent: " + message);
+        return ResponseEntity.ok("Order Completed Message sent: " + message);
     }
 }
diff --git a/src/main/java/net/harunote/hellomessagequeue/step7/OrderProducer.java b/src/main/java/net/harunote/hellomessagequeue/step7/OrderProducer.java
@@ -18,6 +18,6 @@ public void sendShpping(String message) {
                 RabbitMQConfig.ORDER_EXCHANGE,
                 "order.completed.shipping",
                 message);
-        System.out.println("[주문 완료. 배송 지시 메시지 생성 : " + message);
+        System.out.println("[주문 완료. 배송 지시 메시지 생성 : " + message + "]");
     }
 }
diff --git a/src/main/java/net/harunote/hellomessagequeue/step7/RabbitMQManualConfig.java b/src/main/java/net/harunote/hellomessagequeue/step7/RabbitMQManualConfig.java
@@ -7,15 +7,20 @@
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
+/**
+ * RabbitMQ 리스너의 설정을 커스터마이징 한다.
+ */
 @EnableRabbit
 @Configuration
 public class RabbitMQManualConfig {
 
     @Bean
     public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
+        // RabbitMQ 리스너 컨테이너를 생성하는 팩토리 클래스
         SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
         factory.setConnectionFactory(connectionFactory);
-        factory.setAcknowledgeMode(AcknowledgeMode.MANUAL); // 수동 Ack 모드 설정
+        // 수동 Ack 모드 설정, 개발자는 메시지 처리 로직에서 명시적으로 메시지를 확인하거나 거부 처리 가능
+        factory.setAcknowledgeMode(AcknowledgeMode.MANUAL);
         return factory;
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -25,6 +25,6 @@ public OrderController(OrderProducer orderProducer) {`
`25`	`25`	`public ResponseEntity<String> sendMessage(@RequestParam String message) {`
`26`	`26`
`27`	`27`	`orderProducer.sendShpping(message);`
`28`		`- return ResponseEntity.ok("# Order Completed Message sent: " + message);`
	`28`	`+ return ResponseEntity.ok("Order Completed Message sent: " + message);`
`29`	`29`	`}`
`30`	`30`	`}`
Original file line number	Diff line number	Diff line change
`@@ -18,6 +18,6 @@ public void sendShpping(String message) {`
`18`	`18`	`RabbitMQConfig.ORDER_EXCHANGE,`
`19`	`19`	`"order.completed.shipping",`
`20`	`20`	`message);`
`21`		`- System.out.println("[주문 완료. 배송 지시 메시지 생성 : " + message);`
	`21`	`+ System.out.println("[주문 완료. 배송 지시 메시지 생성 : " + message + "]");`
`22`	`22`	`}`
`23`	`23`	`}`