Spring整合RabbitMQ-01-RabbitAdmin使用

RabbitAdmin

使用

1. autoStartup 必需要設爲 true ，不然Spring容器不會加載RabbitAdmin類
2. RabbitAdmin底層實現就是從Spring容器中獲取Exchange,Binding,RoutingKey以及Queue的@Bean申明
3. RabbitTemplate的execute方法執行對應的申明,修改,刪除等一系列RabbitMQ基礎功能操做

代碼示例

RabbitConfig

package com.wyg.rabbitmq.springamqp;

import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitAdmin;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * RabbitAdmin
 * 
 * @author wyg0405@gmail.com
 * @date 2019-11-25 15:11
 * @since JDK1.8
 * @version V1.0
 */

@Configuration
public class RabbitConfig {

    @Bean
    public ConnectionFactory connectionFactory() {
        CachingConnectionFactory cachingConnectionFactory = new CachingConnectionFactory();
        cachingConnectionFactory.setAddresses("localhost:5672");
        cachingConnectionFactory.setUsername("guest");
        cachingConnectionFactory.setPassword("guest");
        cachingConnectionFactory.setVirtualHost("/");
        return cachingConnectionFactory;
    }

    @Bean
    public RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory) {
        RabbitAdmin rabbitAdmin = new RabbitAdmin(connectionFactory);

        /*
         *  autoStartup 必需要設爲 true ，不然Spring容器不會加載RabbitAdmin類
         */
        rabbitAdmin.setAutoStartup(true);
        return rabbitAdmin;
    }
}

RabbitConfigTest

package com.wyg.rabbitmq.springamqp;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.core.*;
import org.springframework.amqp.rabbit.core.RabbitAdmin;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest
public class RabbitConfigTest {
    @Autowired
    RabbitAdmin rabbitAdmin;

    @Test
    public void testRabbitAdmin() {
        // 申明一個direct Exchange
        rabbitAdmin.declareExchange(new DirectExchange("testRabbitAdmin.exchage.direct", false, false));
        // 申明一個fanout Exchange
        rabbitAdmin.declareExchange(new FanoutExchange("testRabbitAdmin.exchage.fanout", false, false));
        // 申明一個topic Exchange
        rabbitAdmin.declareExchange(new TopicExchange("testRabbitAdmin.exchange.topic", false, false));

        // 申明 name 一個queue
        rabbitAdmin.declareQueue(new Queue("testRabbitAdmin.queue.direct", false, false, false));
        // 申明 name 一個queue
        rabbitAdmin.declareQueue(new Queue("testRabbitAdmin.queue.fanout", false, false, false));
        // 申明 name 一個queue
        rabbitAdmin.declareQueue(new Queue("testRabbitAdmin.queue.topic", false, false, false));

        // 綁定
        rabbitAdmin.declareBinding(new Binding("testRabbitAdmin.queue.direct", Binding.DestinationType.QUEUE,
            "testRabbitAdmin.exchage.direct", "direct.abc", null));
        // 使用BindingBuilder綁定
        rabbitAdmin.declareBinding(BindingBuilder.bind(new Queue("testRabbitAdmin.queue.topic", false, false, false))
            .to(new TopicExchange("testRabbitAdmin.exchange.topic", false, false)).with("topicKey.#"));
        
        // 清空隊列,先手工插入一條數據到testRabbitAdmin.queue.fanout
        rabbitAdmin.purgeQueue("testRabbitAdmin.queue.fanout", true);

    }

}

測試結果

Exchange

Queue

綁定關係