한 프로젝트에서 두 개의 MQ Connection 정보 사용하고 싶을 때

MQ Broker는 같이 사용중인데, vHost를 분리하고 싶었다.

검색을 해봤는데 amqp에서 일단 이런 케이스 지원을 안하는 것 같았고, 어케 할지 고민하고 찾아보다가

RabbitConfig 설정 파일 만들어 놓은 곳에 기존엔 구냥 rabbitTemplate Autowired 한걸 사용했으나,

원하는 두 connectionFactory와 rabbitTemplate를 새로 bean을 각각 만들어서 구현해줬다.

약간 똑똑하게 해주는걸 멍청하게 다시 바꿔버린 느낌이자만 일단은 구분을 하는게 목적이었으니..

---

• 설정 부분

@Configuration
public class RabbitMqConfig {

    @Resource
    private Environment environment;

    public final static String QUEUE_NAME = "queue.name.name";
    
    //기존 코드 주석
//  private RabbitTemplate rabbitTemplate;
//
//	public RabbitMqConfig(RabbitTemplate rabbitTemplate) {
//		this.rabbitTemplate = rabbitTemplate;
//	}

//    @PostConstruct
//    protected void afterPropertiesSet() {
//
//    	rabbitTemplate.setChannelTransacted(false);
//    	rabbitTemplate.setMessageConverter(new Jackson2JsonMessageConverter());
//    }

    @Primary
    @Bean(name = "aConnectionFactroy")
    public ConnectionFactory aConnectionFactroy() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setUri(environment.getProperty("a.spring.rabbitmq.addresses"));
        connectionFactory.setPort(environment.getProperty("a.spring.rabbitmq.port"));
        connectionFactory.setUsername(environment.getProperty("a.spring.rabbitmq.username"));
        connectionFactory.setPassword(environment.getProperty("a.spring.rabbitmq.password"));
        connectionFactory.setVirtualHost(environment.getProperty("a.spring.rabbitmq.virtualhost"));
        return connectionFactory;
    }

    @Primary
    @Bean(name="aRabbitTemplate")
    public RabbitTemplate aRabbitTemplate(@Qualifier("aConnectionFactroy") ConnectionFactory connectionFactory) {
        RabbitTemplate template = new RabbitTemplate(connectionFactory);
        template.setChannelTransacted(false);
        template.setMessageConverter(new Jackson2JsonMessageConverter());
        return template;
    }


    @Bean(name = "cConnectionFactroy")
    public ConnectionFactory cConnectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setUri(environment.getProperty("c.spring.rabbitmq.addresses"));
        connectionFactory.setPort(environment.getProperty("c.spring.rabbitmq.port"));
        connectionFactory.setUsername(environment.getProperty("c.spring.rabbitmq.username"));
        connectionFactory.setPassword(environment.getProperty("c.spring.rabbitmq.password"));
        connectionFactory.setVirtualHost(environment.getProperty("c.spring.rabbitmq.virtualhost"));

        return connectionFactory;
    }

    @Bean(name="cRabbitTemplate")
    public RabbitTemplate cRabbitTemplate(@Qualifier("cConnectionFactroy") ConnectionFactory connectionFactory) {
        RabbitTemplate template = new RabbitTemplate(connectionFactory);
        template.setChannelTransacted(false);
        template.setMessageConverter(new Jackson2JsonMessageConverter());
        return template;
    }

 

• 실제 사용하는 부분

@Service
@Slf4j
@RequiredArgsConstructor
public class CostRecommendService {
	
    @Resource(name="cRabbitTemplate")
    private final RabbitTemplate cRabbitTemplate;

    public void execute(JSONObject param) {

        try {
            cRabbitTemplate.convertAndSend(RabbitMqConfig.QUEUE_NAME, param);
        } catch (Exception e) {
            log.error("error", e);
        } 

    }

	
	
}

---

기존에 사용하던 녀석을 그냥 @Primary로 줘서 특별히 명시 안하면 aRabbitTemplate 찾게 해놨다.
property에서 땡겨와서 처리하는 걸로 바꾸고 다시 확인하고 끝내야지

일단 테스트 했을 때는 제대로 동작하는 것 같긴 한데 맞는 방법인지는 잘 몰겄다
나같은 경우엔 vHost만 달라서 해당 경우를 구현했던거였는데 이런 방식이면 vHost, user, host 다 달라도 가능해보인다.