SpringAMQP 用戶管理組件 RabbitAdmin 以及聲明式配置

RabbitAdmin 類能夠很好的操做 rabbitMQ,在 Spring 中直接進行注入便可。git

!!! 注意,autoStartup 必須設置爲 true,不然 Spring 容器不會加載 RabbitAdmin 類。
複製代碼

RabbitAdmin 類 的底層實現就是從 Spring 容器中獲取 exchange、Bingding、routingkey 以及queue 的 @bean 聲明,而後使用 rabbitTemplate 的 execute 方法進行執行對應的聲明、修改、刪除等一系列 rabbitMQ 基礎功能操做。例如添加交換機、刪除一個綁定、清空一個隊列裏的消息等等github

代碼示例:spring

代碼地址: github.com/hmilyos/rab… rabbitmq-api 項目下centos

RabbitAdmin 類的使用以下api

rabbitMQ 的基本配置
複製代碼
public interface RabbitMQCommon {

    final static String RABBITMQ_HOST = "www.mycentosserver.com";
    final static int RABBITMQ_PORT = 5672;
    final static String RABBITMQ_DEFAULT_VIRTUAL_HOST = "/";

    public final static String RABBITMQ_USERNAME = "guest";
    public final static String RABBITMQ_PASSWORD = "guest";
}
複製代碼
@Configuration
@ComponentScan({"com.hmily.rabbitmqapi.spring.*"})
public class RabbitMQConfig {

    private static final Logger log = LoggerFactory.getLogger(RabbitMQConfig.class);
    @Bean
    public ConnectionFactory connectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setAddresses(RabbitMQCommon.RABBITMQ_HOST + ":" + RabbitMQCommon.RABBITMQ_PORT);
        connectionFactory.setUsername(RabbitMQCommon.RABBITMQ_USERNAME);
        connectionFactory.setPassword(RabbitMQCommon.RABBITMQ_PASSWORD);
        connectionFactory.setVirtualHost(RabbitMQCommon.RABBITMQ_DEFAULT_VIRTUAL_HOST);
        return connectionFactory;
    }

    @Bean
    public RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory){
        RabbitAdmin rabbitAdmin = new RabbitAdmin(connectionFactory);
        rabbitAdmin.setAutoStartup(true);
        return  rabbitAdmin;
    
}
複製代碼
@RunWith(SpringRunner.class)
@SpringBootTest
public class RabbitmqApiApplicationTests {

    private static final Logger log = LoggerFactory.getLogger(RabbitmqApiApplicationTests.class);

	@Test
	public void contextLoads() {
	}

	@Autowired
	private RabbitAdmin rabbitAdmin;
	
		@Test
	public void testAdmin() throws Exception {
		rabbitAdmin.declareExchange(new DirectExchange("test.direct", false, false));
		rabbitAdmin.declareExchange(new TopicExchange("test.topic", false, false));
		rabbitAdmin.declareExchange(new FanoutExchange("test.fanout", false, false));
		rabbitAdmin.declareQueue(new Queue("test.direct.queue", false));
		rabbitAdmin.declareQueue(new Queue("test.topic.queue", false));
		rabbitAdmin.declareQueue(new Queue("test.fanout.queue", false));

        rabbitAdmin.declareBinding(new Binding("test.direct.queue",
                Binding.DestinationType.QUEUE,
                "test.direct", "direct", new HashMap<>()));

        rabbitAdmin.declareBinding(
                BindingBuilder
                        .bind(new Queue("test.topic.queue", false))        //直接建立隊列
                        .to(new TopicExchange("test.topic", false, false))    //直接建立交換機 創建關聯關係
                        .with("user.#"));    //指定路由Key

        rabbitAdmin.declareBinding(
                BindingBuilder
                        .bind(new Queue("test.fanout.queue", false))
                        .to(new FanoutExchange("test.fanout", false, false)));

        //清空隊列數據
        rabbitAdmin.purgeQueue("test.topic.queue", false);
	}
}
複製代碼

運行單元測試,而後去 rabbitMQ 的管控臺頁面驗證這些交換機、隊列以及綁定關係是否正確。bash

源碼分析:

RabbitAdmin 類 的底層實現就是從 Spring 容器中獲取 exchange、Bingding、routingkey 以及queue 的 @bean 聲明,而後使用 rabbitTemplate 的 execute 方法進行執行對應的聲明、修改、刪除等一系列 rabbitMQ 基礎功能操做。例如添加交換機、刪除一個綁定、清空一個隊列裏的消息等等源碼分析

afterPropertiesSet 方法就是在 咱們的 bean 加載後進行一些設置

SpringAMQP 的聲明式

回顧一下消費者配置單元測試

1. 設置交換機類型

    2. 將隊列綁定到交換機

交換機類型:

    FanoutExchange 類型: 將消息分發到全部的綁定隊列,無 routingkey 的概念

    HeadersExchange 類型:經過添加屬性 key-value 匹配

    DirectExchange :按照 routingkey 分發到指定隊列

    TopicExchange : 多關鍵字匹配
複製代碼

在 Rabbit 基礎 API 裏面聲明一個 Exchange、queue、binding 的代碼以下所示 測試

SpringAMQP 聲明即在 rabbit 基礎 API 裏面聲明一個 exchange、Bingding、queue。使用SpringAMQP 去聲明,就須要使用 @bean 的聲明方式。ui

  • 針對消費者配置

      1. 設置交換機類型
      1. 將隊列綁定到交換機
  • FanoutExchange: 將消息分發到全部的綁定隊列,無routingkey的概念

  • HeadersExchange :經過添加屬性key-value匹配

  • DirectExchange:按照routingkey分發到指定隊列

  • TopicExchange:多關鍵字匹配

具體的代碼實現以下

在 RabbitMQConfig 裏面添加下面的代碼
複製代碼
/**
     *  聲明 TopicExchange 類型的交換機 topic001
     * @return
     */
    @Bean
    public TopicExchange exchange001() {
//    	是否持久化,是否自動刪除
		return new TopicExchange("topic001", true, false);
	}
    
//    聲明 queue001 隊列
    @Bean
    public Queue queue001() {
    	return new Queue("queue001", true); //隊列持久
    }
    
//    將上面的交換機和隊列綁定
    @Bean
    public Binding binding001() {
    	return BindingBuilder.bind(queue001()).to(exchange001()).with("spring.*");
    }
    
    @Bean
    public TopicExchange exchange002() {
    	return new TopicExchange("topic002", true, false);
    }
    
    @Bean
    public Queue queue002() {
    	return new Queue("queue002", true);
    }
    
    @Bean
    public Binding binding002() {
    	return BindingBuilder.bind(queue002()).to(exchange002()).with("rabbit.*");
    }
    
    @Bean
    public Queue queue003() {
        return new Queue("queue003", true); //隊列持久
    }

    @Bean
    public Binding binding003() {
        return BindingBuilder.bind(queue003()).to(exchange001()).with("mq.*");
    }

複製代碼

而後而後在單元測試裏面寫個方法測試一下,也能夠利用剛纔 RabbitAdmin 的單元測試,只要能跑起來就行,例如剛纔的 testAdmin() ,運行單元測試,而後上管控太驗證剛纔聲明的 exchange、Bingding、queue 是否都成功

自此,RabbitAdmin以及聲明式配置的簡單使用demo演示完畢

相關文章
相關標籤/搜索