rabbitmq 之 无法自动创建队列的问题_rabbitmq匿名队列不能自己创建

背景

子项目中使用了rabbitmq，但是只用了发送到队列的功能，没有监听，所以当项目启动时，并未自动创建队列

通过GPT，找到了如下解决方法，测试可用。

思路是：配置队列信息时，手动调用连接rabbitmq一次，就会自动将队列创建好。

//以下代码添加到rabbitmq配置类中即可

@Value("${rabbitmq.registerQueueName:DefaultQueue}")
private String registerQueueName;

@Value("${rabbitmq.registerExchangeName:DefaultExchange}")
private String registerExchangeName;

@Resource
private ConnectionFactory connectionFactory;
/**
 * 队列
 *
 * @return
 */
@Bean
public Queue imageQueue() {
	return new Queue(registerQueueName, true);
}

/**
 * 交换机
 *
 * @return
 */
@Bean
public FanoutExchange imageExchange() {
	return new FanoutExchange(registerExchangeName, true, false);
}

/**
 * 绑定交换机和队列
 *
 * @return
 */
@Bean
public Binding bindingExchange() {
	return BindingBuilder.bind(imageQueue()).to(imageExchange());
}

//关键代码，手动连接rabbitmq一次，自动创建队列
@Bean
public ApplicationRunner runner() {
	return args -> connectionFactory.createConnection().close();
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45