RabbitMQ , Spring boot - C# 수신 3번에 1번만되는데요.,.

Question

지금 POS연동을 위해 제공된 C#프로그램과 기존의 Spring boot 서버 통신을 RabbitMQ로 전달 하려고 하는데요 포스트맨을 통해서 스프링부트로 주문을 보내면 2번까지는 반응이 없다가 3번째에 C#에서 메시지가 받아집니다..이게 매번 3번째에만 받아저요, 주문 시간으로 구별해도 3번째에만 받아지는데..이게 어떤 이유일까요;기본 흐름은 포스트맨 -> 스프링부트서버 -> RabbitMQ 게스트 -> C# 일텐데... 혹시 몰라 c#받는 코드 공유드립니다 아시는분있으면 조언 부탁드려요 ㅠ 제가 java기반이라 어렵네요 ㅠusing RabbitMQ.Client; using RabbitMQ.Client.Events; using System; using System.Text; using System.Threading.Tasks; using System.Windows.Forms; using Newtonsoft.Json; namespace SampleExternApp_CS2005 { public class MessageDTO { public string name { get; set; } public string content { get; set; } public string timestamp { get; set; } } public class RabbitMQClient { private readonly string _queueName &#61; &#34;pos&#34;; private readonly ConnectionFactory _factory; public RabbitMQClient() { _factory &#61; new ConnectionFactory() { HostName &#61; &#34;localhost&#34; }; } // 메시지 보내기 메서드 public void SendMessage(MessageDTO message) { using (var connection &#61; _factory.CreateConnection()) using (var channel &#61; connection.CreateModel()) { channel.QueueDeclare(queue: _queueName, durable: false, exclusive: false, autoDelete: false, arguments: null); // Serialize MessageDTO object to JSON var jsonMessage &#61; JsonConvert.SerializeObject(message); var body &#61; Encoding.UTF8.GetBytes(jsonMessage); channel.BasicPublish(exchange: &#34;&#34;, routingKey: _queueName, basicProperties: null, body: body); Console.WriteLine(&#34;[x] Sent {0}&#34;, jsonMessage); } } // 메시지 받기 메서드 public void ReceiveMessage() { Console.WriteLine(&#34;ReceiveMessage method called&#34;); var connection &#61; _factory.CreateConnection(); var channel &#61; connection.CreateModel(); // BasicQos 설정을 BasicConsume 호출 이전에 적용 channel.BasicQos(0, 1, false); // prefetchCount를 1로 설정하여 한 번에 한 메시지씩 소비 var consumer &#61; new EventingBasicConsumer(channel); consumer.Received &#43;&#61; (model, ea) &#61;> { var body &#61; ea.Body.ToArray(); var jsonMessage &#61; Encoding.UTF8.GetString(body); try { var messageDTO &#61; JsonConvert.DeserializeObject<MessageDTO>(jsonMessage); Console.WriteLine(&#34;[x] Received Name: {0}, Content: {1}, Timestamp: {2}&#34;, messageDTO.name, messageDTO.content, messageDTO.timestamp); // 수동으로 메시지 확인 (Acknowledge) channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false); MessageBox.Show($&#34;Received Name: {messageDTO.name}, Content: {messageDTO.content}, Timestamp: {messageDTO.timestamp}&#34;, &#34;RabbitMQ Message&#34;); } catch (JsonException ex) { Console.WriteLine(&#34;Failed to deserialize JSON message: &#34; &#43; ex.Message); } }; channel.BasicConsume(queue: _queueName, autoAck: false, // autoAck를 false로 설정 consumer: consumer); Console.WriteLine(&#34;Listening for messages...&#34;); Task.Delay(-1).Wait(); } } }

더미 · Answer

문제의 원인은 RabbitMQ의 prefetch count와 메시지 확인(acknowledgment) 설정과 관련이 있어 보입니다. 다음과 같은 해결 방안을 제시합니다:## 현재 문제점1. 메시지가 3번째에만 받아지는 현상은 prefetch count 설정과 관련이 있습니다[7].2. 현재 코드에서는 BasicQos를 1로 설정했지만, Spring Boot 서버 쪽의 설정도 확인이 필요합니다[4].## 해결 방안*Spring Boot 서버 설정*```yamlspring: rabbitmq: listener: simple: prefetch: 1 acknowledge-mode: manual auto-startup: true default-requeue-rejected: false```*C# 코드 수정*```csharppublic void ReceiveMessage(){ var connection = _factory.CreateConnection(); var channel = connection.CreateModel(); // Queue 선언 추가 channel.QueueDeclare(queue: _queueName, durable: false, exclusive: false, autoDelete: false, arguments: null); // prefetch count 설정 channel.BasicQos(prefetchSize: 0, prefetchCount: 1, global: false); var consumer = new EventingBasicConsumer(channel); consumer.Received += (model, ea) => { try { var body = ea.Body.ToArray(); var jsonMessage = Encoding.UTF8.GetString(body); var messageDTO = JsonConvert.DeserializeObject<MessageDTO>(jsonMessage); Console.WriteLine($"[x] Received {jsonMessage}"); MessageBox.Show($"Received: {jsonMessage}", "Message"); // 메시지 처리 완료 후 확인 channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false); } catch (Exception ex) { // 에러 발생 시 메시지 거부 channel.BasicNack(deliveryTag: ea.DeliveryTag, multiple: false, requeue: true); Console.WriteLine($"Error: {ex.Message}"); } }; // autoAck를 false로 설정 channel.BasicConsume(queue: _queueName, autoAck: false, consumer: consumer);}```## 주의사항1. 연결 관리: connection과 channel은 using 블록으로 관리하거나 명시적으로 닫아주어야 합니다[1].2. 오류 처리: 메시지 처리 중 예외가 발생할 경우 적절한 오류 처리가 필요합니다[3].3. 메시지 순서: prefetch count가 1로 설정되면 메시지가 순차적으로 처리됩니다[7].4. 연결 복구: 연결이 끊어졌을 때 자동으로 재연결되도록 설정이 필요할 수 있습니다[6].이러한 설정들을 적용하면 메시지가 순차적으로 처리되며, 3번째에만 받아지는 현상이 해결될 것입니다.Citations:[1] https://stackoverflow.com/questions/72871049/rabbitmq-message-still-retries-after-throwing-amqprejectanddontrequeueexception[2] https://stackoverflow.com/questions/35592427/how-to-public-message-with-delay-time-rabbitmq-implement-in-spring-boot[3] https://reachmnadeem.wordpress.com/2022/02/20/rabbitmq-sending-scheduled-delayed-messages-using-spring-boot/[4] https://www.rabbitmq.com/docs/consumer-prefetch[5] https://www.cloudamqp.com/blog/what-is-a-delayed-message-exchange-in-rabbitmq.html[6] https://github.com/spring-projects/spring-amqp/issues/823[7] https://www.cloudamqp.com/blog/how-to-optimize-the-rabbitmq-prefetch-count.html[8] https://www.cloudamqp.com/blog/how-to-avoid-the-pitfalls-of-the-delayed-message-exchange.html

RabbitMQ , Spring boot -> C# 수신 3번에 1번만되는데요.,.

1개의 답변

#rabbitmq 목록