RabbitMQ队列auto_delete配置不生效，消息消费完未自动删除如何解决

问题原因 #

你对RabbitMQ队列的auto_delete参数功能理解存在偏差：

• auto_delete: true的触发规则是最后一个订阅该队列的消费者断开连接时自动删除队列，和队列内是否还有剩余消息无关。只要有消费者保持和队列的订阅关系，哪怕队列完全为空，也不会被自动删除。
• 你当前的消费者进程启动后会持续运行，一直保持和task_queue的订阅连接，所以就算所有消息都消费完成，队列也不会触发自动删除逻辑。

修复方案 #

方案1：消费者检测到队列为空后主动断开连接 #

你可以在每次消费确认完成后，检查队列剩余消息数，确认无剩余消息后主动取消订阅、关闭连接，即可触发auto_delete规则删除队列。

修改消费者的消费逻辑部分即可：

channel.consume(queue, function(msg) {
    var secs = msg.content.toString().split('.').length - 1;

    console.log(" [x] Received %s", msg.content.toString());
    setTimeout(function() {
        console.log(" [x] Done");
        channel.ack(msg);
        // 新增队列状态检查逻辑
        channel.checkQueue(queue, function(err, qInfo) {
            // 确认无剩余消息时关闭连接
            if (qInfo.messageCount === 0) {
                channel.cancel(msg.fields.consumerTag, function() {
                    connection.close();
                    process.exit(0);
                });
            }
        })
    }, secs * 1000);
}, {
    noAck: false
});

方案2：增加队列闲置过期参数 #

如果不需要严格在消费完成后立刻删除，也可以在声明队列时新增expires参数，设置队列在无消费者连接、无消息操作的闲置状态下多久后自动删除，单位为毫秒：

channel.assertQueue(queue, {
    durable: true,
    auto_delete: true,
    expires: 10000 // 队列闲置10秒后自动删除
});

注意事项 #

如果之前测试时已经创建过同名的、不带auto_delete属性的队列，需要先手动删除旧队列，否则会因为队列参数不匹配抛出异常。

内容的提问来源于stack exchange，提问作者Henri