为什么我的兔子队列不会死？

Question

我在让我的 RabbitMQ 队列过期时遇到问题。
我正在使用 RabbitMQ 3.2.4；服务器在 Windows 上运行，我的客户端代码是 C#。

我尝试通过x-expire 设置队列的自动删除参数和queue's TTL 值。我尝试使用虚拟消息启动队列以伪造消费者的外观，我什至尝试改变交换的持久性参数。

在五种可能的组合中，没有一种会导致队列被删除。在最后一个连接关闭后，我已经等了几个小时（几天？），但队列并没有消失。

| auto-delete | x-expires | Prime |
| ----------- | --------- | ----- |
| false       | false     | false |  // Don't care; no delete possible
| false       | false     | true  |  // Don't care; no delete possible
| false       | true      | false |
| false       | true      | true  |
| true        | false     | false |  // Fails consumer requirement
| true        | false     | true  |
| true        | true      | false |
| true        | true      | true  |

_{除非有至少一个消费者，否则队列不会自动删除，否则队列会在声明后立即自动删除。}

我做错了什么/我需要做什么才能使队列过期并被删除？

---

如果我提出 XY 问题，这就是我想要做的。我们有一个包含工作任务的主队列。我们有大量的工人来完成一项任务；运行并保存计算；然后重复该循环。时不时有一个工人会拉一个任务，但不会完成。我们需要任务在一段时间后重新排队，以便其他工作人员可以尝试处理它。

我已经看到许多站点/博客/任何建议使用重试队列以及 RabbitMQ 的 dead-letter-exchange 功能来重新排队任务。简化的工作流程是：
拉任务
将任务副本推送到重试队列
执行工作
从重试队列中拉取任务副​​本以防止重新排队。

如果工作人员无法拉取副本，则副本将过期并被重定向回主工作队列。

整体方法可行，但问题是它创建了很多空的重试队列。我想删除那些重试队列。

---

相关代码sn-ps。
如果相关，我可以提供启动代码，但它只是 BasicPublish 后跟 BasicGet

private ConnectionFactory factory;
private IConnection connection;
private IModel channel;

private static string MainExchange = "MainExchange";
private static string RetryExchange = "RetryExchange";
private static string MainQueue = "MainQueue";

private static int messageRequeueTTL = 30000;
private static int requeueQueueTTL = messageRequeueTTL + 15000;

factory = new ConnectionFactory() { ... }

connection = factory.CreateConnection();
channel = connection.CreateModel();

channel.ExchangeDeclare(MainExchange, ExchangeType.Topic, true);
channel.ExchangeDeclare(RetryExchange, ExchangeType.Headers, false);

channel.QueueDeclare(MainQueue, true, false, false, null);
channel.QueueBind(MainQueue, MainExchange, "");

// Populate MainQueue with several calls of: channel.BasicPublish(MainExchange, "", null, body);
// ...

// Pull a message
BasicGetResult result = channel.BasicGet(MainQueue, false);

// Logic for requeueing; Foo is my work task class
    string retryQueue = CreateRequeueName(foo.ID);

    Dictionary<string, object> queueArgs = new Dictionary<string, object>
    {
        {"x-dead-letter-exchange", MainExchange}
        ,{"x-message-ttl", messageRequeueTTL} 
    };

    Dictionary<string, object> bindArgs = new Dictionary<string, object>
    {
        {"x-match", "all"}
        ,{"key1", foo.ID}
        ,{"x-expires", requeueQueueTTL}
    };

    // Set auto delete or not here
    channel.QueueDeclare(retryQueue, false, false, false, queueArgs);

    channel.QueueBind(retryQueue, RetryExchange, "", bindArgs);

    PrimeRetryQueue(foo.ID);        

    var body = Encoding.UTF8.GetBytes(Foo.ToXML(foo));
    var props = channel.CreateBasicProperties();
    props.Headers = new Dictionary<string, object>() { { "key1", foo.ID } };

    channel.BasicPublish(RetryExchange, "", props, body);

//Acknowledge original message pulled from MainQueue
channel.BasicAck(result.DeliveryTag, false);        

Answer 1

“MainQueue”队列没有被删除，因为您设置了第四个参数 autoDelete = false。这是方法签名：

QueueDeclareOk QueueDeclare (string queue, bool durable, bool exclusive, bool autoDelete, IDictionary arguments);

如果您希望在连接关闭时删除队列，您需要这样做：

channel.QueueDeclare(MainQueue, true, true, true, null);

在第二种情况下，使用您的 retryQueue，您使用“x-message-ttl”声明它，它控制 message 到期，而不是 queue 到期。发送到该队列的消息应在 30 秒后过期，但该队列将保留。您还在队列绑定参数中传递“x-expires”，并且AFAIK它在那里没有效果。如果您希望队列本身在 30 秒后过期，则应在队列声明参数中设置此项，即代码中的 queueArgs。

Dictionary<string, object> queueArgs = new Dictionary<string, object>
{
    {"x-dead-letter-exchange", MainExchange},
    {"x-expires", messageRequeueTTL} 
};

channel.QueueDeclare(retryQueue, false, false, false, queueArgs);

供您参考：https://www.rabbitmq.com/ttl.html