[RabbitMQ] rabbitmq 설치 및 설정, spring 3.0이상 연동

728x90

1. docker로 Rabbit MQ 설치

컨테이너 이름 : rabbitmq

백그라운드로 실행

docker run -d --name rabbitmq -p 5672:5672 -p 8080:15672 --restart=unless-stopped rabbitmq:management

2. management url 접속

# default username, password는 둘다 guest로 입력
http://localhost:15672/

3. admin, vhost 추가 (옵션)

4. Queue, Exchange 생성

queue : SKT, KT, LG,emailbroker1, emailbroker2라는 이름의 총 5개의 큐 생성

exchange : SKT, KT, LG 3개의 큐는 각자의 exchage 생성 / emailbroker1, emailbroker2는 동일한 1개의 exchange 생성후 바인딩

5. Build.gradle dependency 추가

implementation 'org.springframework.boot:spring-boot-starter-amqp'
testImplementation 'org.springframework.amqp:spring-rabbit-test'

6. application.yml 수정

spring:
  rabbitmq:
    host: localhost
    port: 5672
    # username: guest
    # password: guest
    username: gutsandgun # 3. admin, vhost 추가한 경우
    password: gutsandgun # 3. admin, vhost 추가한 경우
    virtual-host: gutsandgun # 3. admin, vhost 추가한 경우
    
rabbitmq:
  api:  # rabbit MQ API 호출을 위해 작성
    port: 5672
    queue: /api/queues
    queue-detail: /api/queues/
  queue:  # queue 연동을 위해 작성
    queue1:
      name: SKT
      exchange: SKT-exchange
    queue2:
      name: KT
      exchange: KT-exchange
    queue3:
      name: LG
      exchange: LG-exchange
    queue4:
      name: emailbroker1
      exchange: email-exchange
    queue5:
      name: emailbroker2
      exchange: email-exchange
    routing:
      key:  # exchange
        queue1: SKT
        queue2: KT
        queue3: LG
        queue5: broker1
        queue6: broker2

7. rabbitmqConfing 파일 생성

EnableRabbit 어노테이션 추가
yml에 작성한 값 변수 선언(queue name, exchange, routing key)

@Configuration
@EnableRabbit
public class RabbitmqConfig {

	@Value("${spring.rabbitmq.host}")
    private String host;

    @Value("${spring.rabbitmq.virtual-host}")
    private String vhost;

    @Value("${spring.rabbitmq.port}")
    private int port;

    @Value("${spring.rabbitmq.username}")
    private String username;

    @Value("${spring.rabbitmq.password}")
    private String password;
    
}

1. 큐 선언

	// queue name
    @Value("${rabbitmq.queue1.name}")
    private String queue1;

    @Value("${rabbitmq.queue2.name}")
    private String queue2;

    @Value("${rabbitmq.queue3.name}")
    private String queue3;

    @Value("${rabbitmq.queue4.name}")
    private String emailQueue1;

    @Value("${rabbitmq.queue5.name}")
    private String emailQueue2;


    @Bean
    Queue queue1() {
        return new Queue(queue1, true);
    }
    @Bean
    Queue queue2() {
        return new Queue(queue2, true);
    }
    @Bean
    Queue queue3() {
        return new Queue(queue3, true);
    }

2. exchange 선언

	// exchange
    @Value("${rabbitmq.queue1.exchange}")
    private String exchange1;

    @Value("${rabbitmq.queue2.exchange}")
    private String exchange2;

    @Value("${rabbitmq.queue3.exchange}")
    private String exchange3;

    @Value("${rabbitmq.queue4.exchange}")
    private String emailExchange;

    @Bean
    DirectExchange directExchange1() {
        return new DirectExchange(exchange1);
    }
    
    @Bean
    DirectExchange directExchange2() {
        return new DirectExchange(exchange2);
    }

    @Bean
    DirectExchange directExchange3() {
        return new DirectExchange(exchange3);
    }

    @Bean
    DirectExchange emailDirectExchange1() {
        return new DirectExchange(emailExchange);
    }

3. 라우팅 키 선언

    @Value("${rabbitmq.routing.key.queue1}")
    private String routingKey1;

    @Value("${rabbitmq.routing.key.queue2}")
    private String routingKey2;

    @Value("${rabbitmq.routing.key.queue3}")
    private String routingKey3;

    @Value("${rabbitmq.routing.key.queue4}")
    private String emailRoutingKey1;

    @Value("${rabbitmq.routing.key.queue5}")
    private String emailRoutingKey2;

4. 바인딩

	@Bean
    Binding binding1() {
        return BindingBuilder.bind(queue1()).to(directExchange1()).with(routingKey1);
    }

    @Bean
    Binding binding2() {
        return BindingBuilder.bind(queue2()).to(directExchange2()).with(routingKey2);
    }

    @Bean
    Binding binding3() {
        return BindingBuilder.bind(queue3()).to(directExchange3()).with(routingKey3);
    }

    @Bean
    Binding emailBinding1() {
        return BindingBuilder.bind(emailQueue1()).to(emailDirectExchange1()).with(emailRoutingKey1);
    }

    @Bean
    Binding emailBinding2() {
        return BindingBuilder.bind(emailQueue2()).to(emailDirectExchange1()).with(emailRoutingKey2);
    }

5. 컨버터 및 rabbitTemplate 선언

    @Bean
    MessageConverter messageConverter() {
        return new Jackson2JsonMessageConverter();
    }

    @Bean
    RabbitTemplate rabbitTemplate
    		(ConnectionFactory connectionFactory, MessageConverter messageConverter) {
        RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
        rabbitTemplate.setMessageConverter(messageConverter);
        return rabbitTemplate;
    }

    @Bean
    ConnectionFactory connectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setHost(host);
        connectionFactory.setPort(port);
        connectionFactory.setVirtualHost(vhost);
        connectionFactory.setUsername(username);
        connectionFactory.setPassword(password);
        return connectionFactory;
    }

	// queue name
@Configuration
@EnableRabbit
public class RabbitmqConfig {


    @Value("${spring.rabbitmq.host}")
    private String host;

    @Value("${spring.rabbitmq.virtual-host}")
    private String vhost;

    @Value("${spring.rabbitmq.port}")
    private int port;

    @Value("${spring.rabbitmq.username}")
    private String username;

    @Value("${spring.rabbitmq.password}")
    private String password;

	// queue name
    @Value("${rabbitmq.queue1.name}")
    private String queue1;

    @Value("${rabbitmq.queue2.name}")
    private String queue2;

    @Value("${rabbitmq.queue3.name}")
    private String queue3;

    @Value("${rabbitmq.queue4.name}")
    private String emailQueue1;

    @Value("${rabbitmq.queue5.name}")
    private String emailQueue2;


	// exchange
    @Value("${rabbitmq.queue1.exchange}")
    private String exchange1;

    @Value("${rabbitmq.queue2.exchange}")
    private String exchange2;

    @Value("${rabbitmq.queue3.exchange}")
    private String exchange3;

    @Value("${rabbitmq.queue4.exchange}")
    private String emailExchange;

    @Value("${rabbitmq.routing.key.queue1}")
    private String routingKey1;

    @Value("${rabbitmq.routing.key.queue2}")
    private String routingKey2;

    @Value("${rabbitmq.routing.key.queue3}")
    private String routingKey3;

    @Value("${rabbitmq.routing.key.queue4}")
    private String emailRoutingKey1;

    @Value("${rabbitmq.routing.key.queue5}")
    private String emailRoutingKey2;
    

    @Bean
    Queue queue1() {
        return new Queue(queue1, true);
    }
    @Bean
    Queue queue2() {
        return new Queue(queue2, true);
    }
    @Bean
    Queue queue3() {
        return new Queue(queue3, true);
    }

    @Bean
    Queue emailQueue1() {
        return new Queue(emailQueue1, true);
    }

    @Bean
    Queue emailQueue2() {
        return new Queue(emailQueue2, true);
    }
    

    @Bean
    DirectExchange directExchange1() {
        return new DirectExchange(exchange1);
    }
    
    @Bean
    DirectExchange directExchange2() {
        return new DirectExchange(exchange2);
    }

    @Bean
    DirectExchange directExchange3() {
        return new DirectExchange(exchange3);
    }

    @Bean
    DirectExchange emailDirectExchange1() {
        return new DirectExchange(emailExchange);
    }


    @Bean
    Binding binding1() {
        return BindingBuilder.bind(queue1()).to(directExchange1()).with(routingKey1);
    }

    @Bean
    Binding binding2() {
        return BindingBuilder.bind(queue2()).to(directExchange2()).with(routingKey2);
    }

    @Bean
    Binding binding3() {
        return BindingBuilder.bind(queue3()).to(directExchange3()).with(routingKey3);
    }

    @Bean
    Binding emailBinding1() {
        return BindingBuilder.bind(emailQueue1()).to(emailDirectExchange1()).with(emailRoutingKey1);
    }

    @Bean
    Binding emailBinding2() {
        return BindingBuilder.bind(emailQueue2()).to(emailDirectExchange1()).with(emailRoutingKey2);
    }


    @Bean
    MessageConverter messageConverter() {
        return new Jackson2JsonMessageConverter();
    }

    @Bean
    RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory, MessageConverter messageConverter) {
        RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
        rabbitTemplate.setMessageConverter(messageConverter);
        return rabbitTemplate;
    }

    @Bean
    ConnectionFactory connectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setHost(host);
        connectionFactory.setPort(port);
        connectionFactory.setVirtualHost(vhost);
        connectionFactory.setUsername(username);
        connectionFactory.setPassword(password);
        return connectionFactory;
    }
}

728x90

1. docker로 Rabbit MQ 설치

2. management url 접속

3. admin, vhost 추가 (옵션)

4. Queue, Exchange 생성

5. Build.gradle dependency 추가

6. application.yml 수정

7. rabbitmqConfing 파일 생성

티스토리툴바