rabbitmq之无法自动创建队列的问题及解决过程

背景

最近在处理一个子项目时，遇到了一个挺有意思的小问题——RabbitMQ只用来发送消息到队列，但没有监听消费端。结果项目启动后，队列并没有像预期那样自动创建出来。

后来跟GPT聊了聊，找到了一个简单有效的解决办法，实测可行。这里分享一下思路和代码。

思路

问题出在：RabbitMQ的队列只有在第一次真正连接时才会自动创建。如果只是声明了队列配置，但没有实际建立连接，那么队列是不会凭空生成的。

解决思路很直接：在配置队列信息的同时，手动触发一次对RabbitMQ的连接，这样队列就会被自动创建出来。相当于“唤醒”一下RabbitMQ。

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

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

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

@Resource
private ConnectionFactory connectionFactory;

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

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

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

// 关键代码：手动连接rabbitmq一次，自动创建队列
@Bean
public ApplicationRunner runner() {
	return args -> connectionFactory.createConnection().close();
}

关键在于最后那个ApplicationRunner，它在项目启动时主动连接一次RabbitMQ，连接成功后立即关闭。这个“虚晃一枪”的动作，足以触发队列的自动创建。

总结

从经验来看，这个问题在只做消息发送、不做监听的场景下很典型。解决方式也足够轻量——不需要额外引入监听器或定时任务，只需在配置中加一个启动时的手动连接即可。

希望对遇到类似问题的朋友有所帮助。