我是Rabbitmq(和编程)的新手,如果这很明显,请提前对不起.我正在创建一个池来共享正在处理队列的线程,但我不确定是否应该在池中使用连接或通道.
我知道我需要通道来完成实际工作,但每个连接有一个通道(从队列中获得更多吞吐量)是否有性能优势？或者我最好只使用每个应用程序的单个连接并汇集多个渠道？
注意:因为我正在汇集资源,初始成本不是一个因素,因为我知道连接比渠道更昂贵.我对吞吐量更感兴趣.
我想创建一些Producer/Consumer线程应用程序.但我不确定在两者之间实现队列的最佳方法是什么.
所以我有两个想法(两者都可能是完全错误的).我想知道哪个更好,如果它们都吮吸那么什么是实现队列的最佳方式.这主要是我在这些例子中实现的队列,我很关心.我正在扩展一个内部类的Queue类,并且是线程安全的.以下是两个示例,每个示例包含4个类.
主类 -
public class SomeApp
{
private Consumer consumer;
private Producer producer;
public static void main (String args[])
{
consumer = new Consumer();
producer = new Producer();
}
}
消费者类 -
public class Consumer implements Runnable
{
public Consumer()
{
Thread consumer = new Thread(this);
consumer.start();
}
public void run()
{
while(true)
{
//get an object off the queue
Object object = QueueHandler.dequeue();
//do some stuff with the object
}
}
}
制片人类 -
public class …我第一次使用jQuery.queue()并且还没有完全掌握它.有人可以指出我做错了什么吗？
看着firebug,我仍然看到我的POST请求同时被触发 - 所以我想知道我是否在错误的地方调用dequeue().
另外 - 我怎样才能获得队列长度？
我需要对这些请求进行排队的原因是,单击按钮会触发它.并且用户可以快速连续点击多个按钮.
试图剥离我的代码的基本结构:
$("a.button").click(function(){
$(this).doAjax(params);
});
// method
doAjax:function(params){
$(document).queue("myQueueName", function(){
$.ajax({
type: 'POST',
url: 'whatever.html',
params: params,
success: function(data){
doStuff;
$(document).dequeue("myQueueName");
}
});
});
}
我正在使用RabbitMQ,我有一个包含电子邮件的队列.我的消费者服务将消息排队并尝试发送消息.如果由于任何原因,我的消费者无法发送消息,我想重新排队消息再次发送.我意识到我可以做一个basicNack并将requeue标志设置为true,但是,我不想无限期地重新排列该消息(例如,如果我们的电子邮件系统出现故障,我不想连续重新排队未发送的消息).我想定义有限次数,我可以重新排列要再次发送的消息.但是,当我将它出列并发送一个nack时,我无法在电子邮件消息对象上设置字段.更新的字段不存在于队列中的消息上.还有其他方法可以解决这个问题吗？提前致谢.
任何人都可以提出转到容器,简单快速的FIF /队列,Go有3个不同的容器:heap,list和vector.哪一个更适合实现队列？
我该如何清除队列.例如,我在队列中有数据,但由于某种原因,我不需要现有数据,只想清除队列.
有什么办法吗？这会工作:
oldQueue = Queue.Queue()
我需要为我的新项目选择一个新的队列代理.
这次我需要一个支持pub/sub的可伸缩队列,并且必须保持消息排序.
我读过亚历克西斯的评论:他写道:
"事实上,我们认为RabbitMQ比Kafka提供更强的订购"
我在rabbitmq docs中阅读了消息订购部分:
"消息可以使用AMQP方法返回队列,这些方法具有重新排队参数(basic.recover,basic.reject和basic.nack),或者由于在保留未确认的消息时关闭了通道...使用2.7.0及更高版本它仍然有可能为个人消费者,观察消息无序如果队列中有多个用户.这是因为谁可能重新排队消息的其他用户的行为.从队列中的消息总是在发布顺序举行的视角. "
如果我需要按订单处理消息,我只能使用带有独占队列的rabbitMQ给每个消费者吗？
RabbitMQ仍然被认为是有序消息排队的一个很好的解决方案吗？
我正在使用递归图像处理算法(在Java中),该算法以递归方式从中心点向外遍历图像的像素.
不幸的是,这会导致堆栈溢出.所以我决定切换到基于队列的算法.
现在,这一切都很好而且花花公子 - 但考虑到它的队列将在很短的时间内分析成千上万的像素,同时不断地弹出和推动,而不保持可预测的状态(它可以在长度100之间的任何地方,和20000); 队列实现需要具有显着快速的弹出和推送能力.
链表似乎很有吸引力,因为它能够在不重新排列列表中的任何其他内容的情况下将元素推送到自身,但为了使其足够快,它需要轻松访问其头部和尾部(或者第二个 - -last节点,如果它没有双重链接).遗憾的是,虽然我找不到任何与Java中链接列表的底层实现相关的信息,但很难说链接列表是否真的要走了......
这让我想到了我的问题.对于我打算做什么,Java中Queue接口的最佳实现是什么？(我不想编辑甚至访问队列的头部和尾部以外的任何东西 - 我不希望做任何类型的重新排列或任何事情.另一方面,我打算做很多推动和弹出,队列将大大改变大小,因此预分配将是低效的)
我需要在Python代码中使用优先级队列.为了寻找有效的东西,我遇到了堆积.它看起来不错,但似乎只为整数指定.我认为它适用于具有比较运算符的任何对象,但它没有指定它需要哪些比较运算符.
此外,heapq似乎是用Python实现的,所以它并不快.
您是否了解Python中优先级队列的任何快速实现？最理想的情况是,我希望队列是通用的(即适用于具有指定比较运算符的任何对象).
提前致谢
更新:
重新比较heapq,我可以使用(priority, object)查理马丁建议的,或者只是__cmp__为我的对象实现.
我还在寻找比他更快的东西heapq.
我试图比较堆栈和队列操作的增长率(运行时和空间),当实现为数组和链接列表时.到目前为止,我只能找到队列pop()的平均案例运行时间,但没有全面探索这两个数据结构并比较它们的运行时/空间行为.
具体地讲,我想找比较push()和pop()用于两个队列和堆栈,作为实现两个阵列和链表(因此2次操作×2种结构×2个实施方式中,或8个值).
另外,我会欣赏这两者的最佳,平均和最差情况值,以及与它们消耗的空间量有关的任何事情.
我能找到的最接近的是"所有cs作弊表的母亲"pdf,这显然是高级算法和离散函数的主人或博士级备忘单.
我只是在寻找一种方法来确定何时何地应该使用基于数组的实现与基于列表的堆栈和队列实现.