RabbitMQ 기초

version: '3.7'
services:
  rabbitmq:
    image: rabbitmq:4.0-management
    ports:
      - "5672:5672"
      - "15672:15672"
    environment:
      RABBITMQ_DEFAULT_USER: admin
      RABBITMQ_DEFAULT_PASS: admin
#관리 UI: http://localhost:15672, 기본 계정: admin/admin

/**
 * Queue Bean 등록 
 *
 * @return Queue
 *   - name: 큐 이름 
 *   - durable: false일 경우 브로커 재시작 시 삭제되는 휘발성 큐
 */
@Bean
fun queue(): Queue {
    return Queue("QUEUE_NAME", false)
}

/**
 * DirectExchange Bean 등록 
 *
 * @return DirectExchange
 *   - name: 익스체인지 이름 ("EXCHANGE_NAME")
 *   - durable: true (브로커 재시작 시에도 유지)
 */
@Bean
fun directExchange(): DirectExchange {
    return DirectExchange("EXCHANGE_NAME")
}

/**
 * Queue와 Exchange를 바인딩
 *
 * @param queue 생성된 Queue 빈
 * @param directExchange 생성된 DirectExchange 빈
 * @return Binding
 *   - routingKey: "ROUTING_KEY"와 일치하는 메시지를 해당 큐로 전달하도록 설정
 */
@Bean
fun binding(queue: Queue, directExchange: DirectExchange): Binding {
    return BindingBuilder
        .bind(queue)
        .to(directExchange)
        .with("ROUTING_KEY")
}


/**
 * JSON 메시지 컨버터 Bean 등록
 *
 * - Producer가 전송하는 객체를 JSON 문자열로 직렬화하고,
 *   Consumer가 수신한 JSON 문자열을 객체로 역직렬화하는 데 사용
 *
 * @return MessageConverter 인스턴스
 */
@Bean
fun messageConverter(): MessageConverter {
    return Jackson2JsonMessageConverter()
}

// 지정된 토픽 익스체인지로 메시지를 발행
rabbitTemplate.convertAndSend(
   RabbitMQConfig.TOPIC_EXCHANGE, // 전송 대상 익스체인지 이름
   routingKey,                    // 토픽 패턴 기반의 라우팅 키
   message                        // 전송할 페이로드 object (MessageConverter를 통해 직렬화)
)

/**
* 큐에 바인딩된 메시지를 수신하는 Listener 메서드
*
* @param message SomeObject 타입의 메시지 페이로드
*   - 메시지 컨버터에 의해 객체로 역직렬화된 값
*/
@RabbitListener(queues = ["QUEUE_NAME"])
fun consumeWarn(message: SomeObject) {
   logger.info { "message = $message" }
}