Класс RabbitAdmin может очень хорошо работать с rabbitMQ, и его можно внедрить непосредственно в Spring.
!!! 注意，autoStartup 必须设置为 true，否则 Spring 容器不会加载 RabbitAdmin 类。
Базовая реализация класса RabbitAdmin состоит в том, чтобы получить объявления @bean для обмена, Bingding, routingkey и очереди из контейнера Spring, а затем использовать метод execute RabbitTemplate для выполнения ряда основных функций rabbitMQ, таких как объявление, изменение и удаление. . Например добавление переключателя, удаление привязки, очистка очереди сообщений и т.д.
Пример кода:
Кодовый адрес:GitHub.com/HMI использует ОС/например, AB…В рамках проекта rabbitmq-api
Использование класса RabbitAdmin выглядит следующим образом.
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, чтобы убедиться в правильности обменов, очередей и привязок.
Анализ исходного кода:
Базовая реализация класса RabbitAdmin состоит в том, чтобы получить объявления @bean для обмена, Bingding, routingkey и очереди из контейнера Spring, а затем использовать метод execute RabbitTemplate для выполнения ряда основных функций rabbitMQ, таких как объявление, изменение и удаление. . Например добавление переключателя, удаление привязки, очистка очереди сообщений и т.д.
Декларативный с Spring AMQP
Просмотр конфигурации потребителя
1. 设置交换机类型
2. 将队列绑定到交换机
交换机类型：
FanoutExchange 类型: 将消息分发到所有的绑定队列，无 routingkey 的概念
HeadersExchange 类型：通过添加属性 key-value 匹配
DirectExchange :按照 routingkey 分发到指定队列
TopicExchange : 多关键字匹配
Код для объявления Exchange, очереди и привязки в базовом API Rabbit выглядит следующим образом.
Декларация Spring AMQP предназначена для объявления обмена, Bingding и очереди в базовом API кролика. Чтобы использовать SpringAMQP для объявления, вам нужно использовать метод объявления @bean.
-
Настроен для потребителей
-
- установить тип переключателя
-
- Привязать очередь к обмену
-
-
FanoutExchange: распространение сообщений по всем связанным очередям без использования ключа маршрутизации.
-
HeadersExchange : Сопоставьте, добавив ключ-значение атрибута
-
DirectExchange: распространение в указанную очередь в соответствии с ключом маршрутизации.
-
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() прямо сейчас, запустить модульный тест, а затем перейти к также контролировать, чтобы проверить обмен, Bingding, успешна ли очередь
С тех пор была завершена демонстрация простого использования RabbitAdmin и декларативной конфигурации.