- c - 在位数组中找到第一个零
- linux - Unix 显示有关匹配两种模式之一的文件的信息
- 正则表达式替换多个文件
- linux - 隐藏来自 xtrace 的命令
我在让 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);
关于c# - 为什么我的兔子队列不会死?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/26307472/
我有几个系统使用 docker-compose 并且没有问题。 但是,我在这里有一个“向下”根本不做任何事情的地方。 'up'虽然完美。这是在 MacOS 上。 该项目的昵称是“ Storm ”,脚本
解释起来确实很奇怪,所以就这样...... 我正在从 phpmyadmin 获取包含未转义单引号的数据。我正在尝试转换'至'通过使用Content-Type: text/html;在 php
伙计们?在这里需要一些帮助。我使用委托(delegate)协议(protocol)将一些字符串从“第二个 View Controller ”传回给它的前一个。 我的数组附加了我在委托(delegate
我有以下 eval() 东西: c = Customer() eval("c.name = row.value('customer', '{c}')".format(c=column_name), {
我写了这个测试类: @ContextConfiguration(locations = { "classpath:/test/BeanConfig.xml" }) public class Candi
我这样写代码: @ContextConfiguration(locations = { "classpath:/test/BeanConfig.xml" }) @RunWith(SpringJUnit
假设我更改了文件,然后进行 pull 。 Git 会报错,因为本地仓库还没有保存,将被覆盖。如果我然后删除该添加并使文件与以前相同(与远程 repo 相同),那么会发生 pull 吗? 最佳答案 是的
我正在阅读《Java for Dummies》一书,但遇到了问题。我不明白为什么 @Override 不起作用。我确信这与我的代码有关,因为我之前已经获得了一个多态数组来使用覆盖,但它对我来说太简单了
我从我的项目中提取了这段代码,因为我试图找到我犯的一个错误,该错误使我的 BeginStoryboard 无法自行停止。我尽可能地简化了代码,但仍然没有发现问题。你认为它可能是什么?
这个问题在这里已经有了答案: Difference between char[] and char * in C [duplicate] (3 个答案) 关闭 7 年前。 我想我知道自己问题的答案,
我一直在使用 java 的 Scanner 类时遇到问题。我可以让它很好地读取我的输入,但问题是当我想要输出一些东西时。给定多行输入,我想在完全读取所有输入后只打印一行。这是我用来读取输入的代码:
对于这个问题,我已经用最简单的术语表达了这一点。 如果元素被点击,'active'类被添加到元素,'active'类从其他元素中移除。 但是,如果该元素是“事件的”并且它被第二次单击,则“事件”类不应
这会在桌面上创建一个新文件夹,但不会将文件夹 .pfrom 的内容 move 到文件夹 .pTo。 int main() { SHFILEOPSTRUCT sf = {0}; TCHA
我有一个关于多线程调试 DLL (/MDd) 和多线程调试 (/MTd) 设置的问题。它们之间的区别很明显:一个是使用动态库,一个是使用静态库。当我使用/MDd 编译我的程序时,一切都进行得很好。但是
我的问题是,如果我在页面加载时创建一个克隆变量,jQuery 只会 append 它一次。奇怪! Click to copy This is an element! $(document)
所以...我是一个开发 django 应用程序的新手,但是当我尝试通过 virtualbox heroku 运行 heroku run python manage.py syncdb 时,它一直在下面
我在 Spring Boot 初始化时遇到了问题。我在一个简单的 Spring Boot 项目中有这个结构。 com.project.name |----App.java (Annoted with
我在 www.7hermanosmx.com/menu.php 页面上有以下代码 - 一切正常,除了黄色框(类 menuholder)应该每行三个相互 float 。他们坚决拒绝这样做!我知道我做错了
我正在尝试在我正在构建的小型网站上添加一个下拉菜单。出于某种原因,我可以获得我想要向下滑动到 fadeOut() 的 div 并执行其他类似的操作,但我无法将它获取到 slideDown()。我不知道
我有一个不能正确 float 的 div。当您切换可见性时,它会覆盖一些当前文本,但我可以稍后移动它。只是好奇为什么它不能正确 float ! Simple Tabs with CSS &am
我是一名优秀的程序员,十分优秀!