Rabbit MQ 사용하기

  • Rabbit MQ 의 특성

    • ISO 표준(ISO/IEC 19464) AMQP 구현
    • 비동기처리를 위한 메시지큐 브로커
    • erlang과 java 언어로 만들어짐 (clustering 등을 위한 고속 데이터 전송하는 부분에 erlang이 사용된 것으로 추정)
    • 분산처리를 고려한 MQ ( Cluster, Federation )
    • 고가용성 보장 (High Availability)
    • Publish/Subscribe 방식 지원
    • 다양한 plugin 지원

  • 주요 용어

    • Producer: 메시지를 보내는 Application
    • Queue: 메시지를 저장하는 버퍼 (Queue는 Exchange 에 Biding 된다)
    • Consumer: 메시지를 받는 User Applicagtion
    • Bindings: Exchange 와 Queue 를 연결해주는 것
    • Routing: Exchange 가 Queue 에 메시지를 전달하는 과정
    • RoutingKey: Exchange 가 Queue 에 메시지를 전달하는 기준
    • Exchange: Producer 가 전달한 메시지를 Queue 에 전달하는 역할
      • Exchange Type
type 설명 특징
fanout 알려진 모든 Queue에 메시지 전달 함 Broadcast
direct 지정된 routingKey를 가진 Queue에만 메시지 전달 함 unicast
topic 지정된 패턴 바인딩 형태에 일치하는 Queue에만 메시지 전달. #(여러단어), *(한단어)를 통한 문자열 패턴 매칭 multicast
header 헤더에 포함된 key=value의 일치조건에 따라서 메시지 전달 multicast

  • 기타정보

    • code level 에서 Queue exchange 들을 선언해서 관리하는게 좋다.
    • RabbitMQ 관리자는 사용하지 않는 Queue 는 자동삭제 되게 하는걸 추천함.

  • Consuemr ACK 정보

    • NACK -> 줄 경우 dead letter queue 로 들어감. dead letter queue 가 없다면 requeue 됨

    • ACK -> 정상 처리 되면서 queque 에서 삭제

    • queue 설정에 autoAck 라는 설정이 있는데, 가져가면 바로 메시지가 삭제 됨
    spring amqp 에서의 설정
        org.springframework.amqp.core.AcknowledgeMode 참고
            NONE : autoack true 입니다.
            MANUAL : 코드에서 직접 명시적으로 ack 함
            AUTO : exception 이 발생한다면 NACK 함 (default)

참고링크