위키득계정 ↗
기술

Apache RocketMQ

Apache RocketMQ기술
시스템 유형
분산 메시징
업무별 묶음
Topic
저장과 전달 단위
MessageQueue
소비 진행 관리
ConsumerOffset
Apache RocketMQ는 생산자와 소비자 사이에서 메시지를 저장하고 전달하는 분산 메시징 시스템이다. 업무별 토픽과 메시지 큐를 사용하고 소비자 그룹별로 처리 진행을 관리한다.

토픽과 메시지의 구성

생산자는 업무 자료와 부가 속성을 메시지로 만들어 브로커에 보낸다. 같은 업무 논리의 메시지는 토픽에 속하며 큐는 메시지를 보관하고 전달한다. 태그는 토픽 안에서 메시지를 더 세밀하게 분류하는 속성이다.

그룹별 소비와 진행 위치

같은 소비 동작을 하는 소비자들은 그룹으로 묶여 부하를 나눈다. 구독 규칙은 그룹이 어떤 메시지를 받을지 결정한다. 메시지를 소비한 뒤 바로 삭제하는 대신 그룹별 진행 위치를 기록해 관리한다.

전달 특성에 따른 메시지 유형

일반 메시지와 FIFO 및 트랜잭션과 지연 메시지 같은 유형을 구분한다. 트랜잭션 메시지 방식에서는 생산자가 트랜잭션 상태를 확인하는 기능을 구현한다. 유형에 따라 요구하는 전달 동작과 응용의 처리 역할이 달라진다.

관련 문서

Apache Kafka / Apache Pulsar / RabbitMQ / NATS 메시징 / AsyncAPI / CloudEvents