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 加載後進行一些設置回顧一下消費者配置單元測試
1. 設置交換機類型
2. 將隊列綁定到交換機
交換機類型:
FanoutExchange 類型: 將消息分發到全部的綁定隊列,無 routingkey 的概念
HeadersExchange 類型:經過添加屬性 key-value 匹配
DirectExchange :按照 routingkey 分發到指定隊列
TopicExchange : 多關鍵字匹配
複製代碼
在 Rabbit 基礎 API 裏面聲明一個 Exchange、queue、binding 的代碼以下所示 測試
SpringAMQP 聲明即在 rabbit 基礎 API 裏面聲明一個 exchange、Bingding、queue。使用SpringAMQP 去聲明,就須要使用 @bean 的聲明方式。ui
針對消費者配置
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演示完畢