메세지큐 톺아보기

🔍메세지큐란?

메시지 큐(Message Queue)는 소프트웨어 시스템 간에 데이터를 비동기적으로 전송하는 데 사용되는 중간 매개체

이를 통해 시스템 간에 데이터를 안전하게 전달하고 처리할 수 있다. 메시지 큐는 일반적으로 분산 시스템에서 사용되며, 시스템 간의 결합도를 낮추고 확장성을 높이는 데 도움을 준다.

 

📌메시지 큐의 주요 구성 요소:

1. 메시지: 메시지 큐를 통해 전송되는 데이터 단위로 요청 그 자체. 메시지는 텍스트, JSON, 바이너리 등 다양한 형식으로 구성될 수 있다.
2. 큐: 메시지가 저장되는 공간입니다. 일반적으로 FIFO(선입선출) 방식으로 동작하며, 먼저 도착한 메시지가 먼저 처리된다.
3. 생산자(Producer): 메시지를 생성하고 큐에 전송하는 역할을 합니다. 예를 들어, 데이터베이스에서 새로운 레코드를 생성하고 이를 메시지로 큐에 보낼 수 있다.
4. 소비자(Consumer): 큐에서 메시지를 가져와서 처리하는 역할을 합니다. 예를 들어, 소비자는 메시지를 읽고 데이터베이스에 저장하거나, 특정 작업을 수행할 수 있다.
5. 브로커(Broker): 전체를 지칭하는 시스템, 메시지 큐 시스템을 관리하고 메시지를 중계하는 중간 매개체입니다. 브로커는 다양한 프로토콜을 통해 생산자와 소비자 간의 통신을 도와줍니다. ex) RebbitMQ와 카프카 ⇒ 내부에 생산자,소비자 기능

📌메시지 큐의 장점:

1. 비동기 통신: 생산자와 소비자는 독립적으로 작동하며, 시간적 제약 없이 메시지를 처리할 수 있습니다.
2. 탄력성과 확장성: 시스템 간의 결합도가 낮아져, 하나의 시스템이 장애가 발생하더라도 다른 시스템에 영향을 미치지 않습니다. 또한, 필요에 따라 브로커나 큐를 교체,확장하여 처리 능력을 향상시킬 수 있습니다. (#결합도는 A를 하면서 B를 못하는 엮어있는 것을 말함)
3. 비동기 처리와 효율성: 일부 작업이 오랜 시간이 걸리는 경우, 메시지 큐를 통해 생산자는 메시지를 전송한 뒤 다른 작업을 계속할 수 있습니다. 소비자는 나중에 메시지를 처리할 수 있음
4. 데이터 복제와 안정성: 메시지 큐 시스템은 일반적으로 메시지를 안전하게 저장하고 복제하여 데이터 손실을 방지함

📌실제 메세지 큐 사용 시:

메세지 큐로 선입선출로 DB쪽에 하나씩 보낼 수 있디.

• DB 동시성 문제를 해결할 수 있다. 요청 처리를 서버가 감당할 수 있는 속도로 조절합니다.
• 하나의 메시지 큐로 개별 DB를 통합해서 관리할 수 있습니다.
• 여러 마이크로서비스에서 하나의 DB와 연결됬을 때 하나만 설치해도 여러 마이크로서비스에 대한 처리 가능

톰캣 내부 메모리 큐

• 요청 유실을 막습니다. 톰캣의 큐는 메모리임으로 유실 가능성이 있지만 메세지 큐를 사용하면 디스크에 저장할 수 있어 DB에 문제가 생겼을 때 메세지 큐 내부에 적재해두고 전달하지 않는 방식으로 유실을 막을 수 있습니다.
• 대기했다가 다음 작업을 진행할 수 있어 바로 400번오류가 아닌 불안정한 서버를 잠시 기다려줌

 

 

 

 

대표적인 메시지 큐 시스템으로는 RabbitMQ, Apache Kafka, ActiveMQ, Redis 등

 

스프링부트에서 RabbitMQ 메세지 큐 사용 사례는 아래 포스팅을 참고해주세요.

[SpringBoot] - 스프링부트에서 RabbitMQ 메세지 큐로 사용

스프링부트에서 RabbitMQ 메세지 큐로 사용

 

 

현업 큐 시스템 실제 사용 사례는 영상을 참고해주세요.

https://www.youtube.com/watch?v=MTSn93rNPPE