用于n核处理器的Perl fork队列
我正在编写类似于建议的应用程序与为每个核心简单地使用队列系统相比，最终需要花费更多的精力来估计运行时间并适当地组合它们.最终，我希望每个核心都在尽可能少地停机的情况下进行处理，直到完成所有工作为止.是否有首选的算法或机制可以做到这一点?我认为这是一个常见的问题/用途，所以我不想重新发明轮子，因为我的轮子可能不如正确的方法. ' 作为一个未成年人，我宁愿不必导入其他模块(例如 Parallel
..
queue相关内容
如何在Mule中创建独占队列使用者?
在ActiveMQ中，您可以为队列配置独占使用者，例如: Queue_Name_Here?consumer.exclusive = true 如何在Mule中配置像上面一样的排他消费者? 解决方案 您需要对队列名称进行URL编码，因为Mule可能会尝试将参数解码为Mule传输选项，而并非如此.
..
使用JScript窥视MSMQ外发队列
我创建了一个脚本来监视一组队列，尽管该脚本与远程专用队列完美配合，但不适用于发送队列.我通过从脚本中删除除基本内容以外的所有内容进行了实验，并创建了以下测试脚本: var info = new ActiveXObject("MSMQ.MSMQQueueInfo"); info.FormatName = /**/; // 0x80 = MQ_ADMIN_ACCESS
..
MSMQ慢队列读取
我正在使用一个开源的.Net库，该库在下面使用MSMQ.大约一周或两周后，服务速度会降低(不是准确计时，而是一般猜测).似乎正在发生的情况是，每10秒仅准确读取一次来自MSMQ的消息.通常，它们是即时读取的.因此，它们将在T + 10秒，T + 20秒，T + 30秒等时间进行读取，而与发送消息的时间无关(即有时读取消息需要3秒钟，而其他时候需要9秒钟). 我目前恢复正常的方法只是删除&重新
..
如何检查php脚本是否仍在运行
我有一个PHP脚本，它在队列上侦听.从理论上讲，它永远不会消失.是否需要检查其是否仍在运行?像Ruby's God ( http://god.rubyforge.org/ )代表PHP一样? 上帝与语言无关，但是拥有一种在Windows上也可以使用的解决方案会很好. 解决方案 我遇到了同样的问题-想检查脚本是否正在运行.所以我想出了这一点，并将其作为cron工作来运行.它以数组的形式
..
MongoDB作为队列服务?
我很想听到更多有关MongoDB作为队列服务的真实应用程序体验的信息，如果您为此目的使用MongoDB，您能否分享您的想法以及使用它的环境? 解决方案 我正在将mongodb用作发送电子邮件的队列服务. 很快它将以以下方式工作: 收到新消息时，我会将其存储在mongodb中. 然后，后台作业通过原子操作 findAndModify 从mongodb加载消息并将标志Processin
..
如何在Java中排队和调用实际方法(而不是立即评估)?
有一些对时间敏感的任务列表(但是在这种情况下，“时间"对于另一个程序告诉我的是任意的-它更像是“滴答声"而不是时间).但是，我不希望上述方法立即进行评估.我要一个在另一个完成后执行.我在队列中使用的是链表，但我不确定如何/不访问立即评估类的情况下如何访问类中的实际方法. 代码看起来像... LinkedList l = new LinkedList();
..
RabbitMQ等待多个队列完成
好，这是正在发生的事情的概述: M
..
流处理和消息处理之间的区别
流处理和传统消息处理之间的基本区别是什么?正如人们所说的，kafka是流处理的不错选择，但从本质上来说，kafka是类似于ActivMQ，RabbitMQ等的消息传递框架. 为什么我们通常不说ActiveMQ同样适用于流处理. 使用者消耗消息的速度是否确定它是否为流? 解决方案 在传统的消息处理中，您对消息应用简单的计算-在大多数情况下，每条消息都是单独进行的. 在流处理
..
Bull Queue尚未完成
是Bull的新手.我曾尝试根据他们的文档代码来运行bull.该流程正在启动，但是我的工作尚未完成，或者不确定它是否触发了完成事件?不确定在哪里犯错 在下面附加我的代码 const Queue = require('bull'); const myFirstQueue = new Queue('my-first-queue', { redis: { port: Co
..
ActiveMQ:一条待处理消息，但队列为空
我对ActiveMQ有一个奇怪的问题.我的队列似乎有待处理的消息，但是当我打开队列时，没有消息. 这是怎么了?是否真的有待处理的消息?如何将消息带回或至少看到内容? 未决消息的屏幕截图: 打开队列时的屏幕截图，该队列为空: 编辑: 刚发现ActiveMQ 5.6.0的这两个bug.这可能是这个问题的根源吗? 与未确认的重新连接后，持久子项的pendingQueueSize的报告不
..
连接时出现rabbitmq错误
当我尝试使用php-amqp连接时出现此错误: 致命错误:找不到类'AMQPConnection' $credentials =array('host' => 'localhost','port' => 5672); $cnn = new AMQPConnection($credentials); $cnn->connect(); 解决方案 您似乎没有 AMQP PECL扩展已安装.该
..
RabbitMQ使用者崩溃时，提取的消息会如何处理?
如果我有一个RabbitMQ使用者可以批量检索100条消息，但是在将这些消息标记为已处理之前它崩溃了，这些消息会丢失吗?我希望队列中的每条消息至少被处理一次.建议使用什么方法来处理在确认消息之前崩溃的消费者? RabbitMQ是否以某种方式将它们重新放置在队列中，或者我需要做些什么才能使其实现? 解决方案 与崩溃的消费者打交道的推荐方法是什么 在他们确认消息之前? 让Rab
..
从RabbitMQ队列中检索消息
我希望在我的PHP应用程序中实现RabbitMQ，并且正在使用php-amqp扩展.我唯一的问题是，如何在PHP中轻松查询以返回队列的内容? php-amqp似乎无法使我做到这一点.如果我做错了，请在这里帮助我:) 解决方案 詹姆斯，你能在rabbitmq-discuss上问这个问题吗?您的问题涉及“查询"队列以获取消息的含义.在RabbitMQ中，您将使用队列中的消息，并使用队列绑
..
如何在任何MQ平台上实现此单个并发分布式队列?
我目前正在努力寻找实现特定队列的解决方案，该解决方案具有以下特征: 所有队列必须遵守添加作业的顺序. 整个队列的并发性为1，这意味着每个队列一次只能执行一个作业，而不是工人. 将有数千个这样的队列. 它需要分发并能够扩展(例如，如果我添加一个工作程序) 基本上它是一个单进程FIFO队列，这正是我尝试不同的消息队列软件(例如ActiveMQ或RabbitMQ)时想要的，但是一旦我将
..
RabbitMQ AMQP队列设计
下面是该队列的理想设计: P生产者.插入数据的应用程序 X交流. C1-C3消费者.从队列读取的应用程序 队列详细信息: A.就像队列日志一样，如果没有客户端绑定，则消息将被丢弃. B.这是一个工作队列.如果符合条件，它将执行某些操作. C.也是一个工作队列.它将转换数据 A是可选的，但B. C.将始终在队列中，直到某些客户端进程将其连接为止. 问题在于确定我
..
使用表排队
我需要使用表来实现队列. 业务要求是只有一个队列，该队列将由5-10个框访问，以获取下一个作业.每天最多不会有5000个工作.另外，一批作业应一次“出队". 只是想知道我以前没有遇到过哪些问题领域和问题.如果以前有人遇到过/已经做到这一点，您能否请我指出设计/示例实现或需要注意的问题. 谢谢 解决方案 有很多通用排队或消息传递服务.即使您想实现自己的系统，也可以尝试看看其他一些
..
PHP + MySQL队列
我需要一个充当队列的简单表. 我的MySQL服务器限制是我不能使用InnoDB表，只能使用MyISAM. 客户/工人将同时工作，并且每次都需要获得不同的工作. 我的想法是执行以下操作(伪代码): $job
..
需要一个线程安全的异步消息队列
我正在寻找一个Python类(最好是标准语言的一部分，而不是第3方库)来管理异步“广播样式"消息. 我将有一个线程将消息放入队列("putMessageOnQueue"方法不得阻塞)，然后有多个其他线程都将在等待消息，大概调用了一些阻塞的"waitForMessage"函数.当消息放入队列时，我希望每个等待的线程都获得自己的消息副本. 我已经看过内置的Queue类，但是我认为这不合适，
..
消息传递，队列和ESB-我知道我想去哪里，但不知道如何到达那里
总而言之，我正在一个项目中，出于所有通常的原因，我们正在重写一个大型Web应用程序.重写的主要目的是将在单个服务器上运行的大型单个应用程序分离为许多较小的，已解耦的应用程序，这些应用程序可以在多个服务器上运行. 好，这就是我想要的: 我希望HTTP是主要的运输机制.当一个应用程序(例如CMS)已更新时，它将通过http与经纪人联系并说 "I've changed" ，然后经纪人将发回
..