gpt4 book ai didi

c# - 为什么我的兔子队列不会死?

转载 作者:太空狗 更新时间:2023-10-30 01:35:18 25 4
gpt4 key购买 nike

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

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

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

| 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 问题,这就是我正在尝试做的事情。我们有一个保存工作任务的主队列。我们有大量的 worker 来完成一项任务;运行并保存计算;然后重复那个循环。 worker 时不时会拉一个任务,但不会完成。我们需要任务在一段时间后重新排队,以便其他工作人员可以尝试处理它。

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

如果工作人员未能拉取副本,副本将过期并被重定向回主工作队列。

整体方法可行,但问题是它会创建大量空重试队列。我希望删除那些重试队列。


相关代码片段。
如果相关,我可以提供启动代码,但它只是一个 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);

最佳答案

“MainQueue”队列未被删除,因为您正在设置第 4 个参数,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”声明它,它控制消息 过期,而不是队列 过期。发送到该队列的消息应在 30 秒后过期,但该队列将保留。您还在队列绑定(bind)参数中传递“x-expires”,据我所知,它在那里没有任何效果。如果您希望队列本身在 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

关于c# - 为什么我的兔子队列不会死?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/26307472/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com