springboot整合rabbitmq,创建队列的方式
时间: 2023-06-07 10:11:07 浏览: 297
可以通过在配置类中使用@Bean注解以及RabbitAdmin类的方法来创建队列,具体操作可以参考以下代码:
```
@Configuration
public class RabbitMQConfig {
// 初始化连接工厂
@Bean
public ConnectionFactory connectionFactory() {
CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
connectionFactory.setAddresses("localhost:5672");
connectionFactory.setUsername("guest");
connectionFactory.setPassword("guest");
connectionFactory.setVirtualHost("/");
return connectionFactory;
}
// 初始化rabbitAdmin
@Bean
public RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory) {
return new RabbitAdmin(connectionFactory);
}
// 创建队列
@Bean
public Queue queue() {
return new Queue("myqueue");
}
}
```
以上代码中,我们使用@Bean注解创建了一个连接工厂、RabbitAdmin实例以及一个名为“myqueue”的队列。同时,我们还可以通过RabbitAdmin的其他方法来配置交换机、绑定等其他MQ的相关参数。
阅读全文