我目前正在学习如何使用RabbitMQ来调度和分派作业到不同的虚拟机。我现在在工作人员端工作。VM上的worker需要执行一些硬加载作业，如果成功完成，则返回到服务器。但我只是想知道是否有更好和线程更安全的方法来做这件事。
浏览 26提问于2019-05-30得票数 0
在我的MuleESB应用配置中，我有一个RabbitMQ队列，我希望使用多线程来使用消息，而顺序并不重要。" port="${rabbitmq_port}" fallbackAddresses="${rabbitmq_fallback_addresses}" virtualHost="${rabbitmq_virtual_host}" username="
浏览 4提问于2018-11-02得票数 0
1回答
我使用这个连接器连接到RabbitMQ： QAMQP::MessagePtr message; s.queue->ack(this->message);};
在一些消息中，RabbitMQ会说：“未确认的10条消息”。这10条<em
浏览 5提问于2014-08-26得票数 2
4回答
设计问题：例子：我的解决方案：
在服务器和消息处理程序之间添加一个线程安全组件( buffer )，缓冲区将从服务器以多线程<e
浏览 7提问于2009-12-23得票数 3
回答已采纳
2回答
我正在使用symfony2和facebook SDK为我的IPhone和安卓应用程序设置web服务。问题是后台工作可能需要相当长的时间。用户首先被重定向到facebook登录页面，在那里他可以接受我的facebook应用程序权限。因此，应该立即通知用户一切正常，而不是等待我的服务完成后台工作。这是控制器操作的相关部分：
...解决此类问题的最佳实践是什么？
浏览 0提问于2013-12-27得票数 4
回答已采纳
2回答
我有三个码头集装箱：
使用者和生产者都能够连接到rabbitmq队列，但是从生产者发送的消息永远无法到达使用者。我尝试了许多不同的组合来连接到兔子码头实例：0.0.0.0
浏览 3提问于2016-05-11得票数 0
我使用的是RabbitMQ和PHP。在使用来自RabbitMQ的消息时，我们在这段代码中拥有魔力： try {Exception $e) { }这是一个无限循环，可以接收预期的消息，但是如果我
浏览 1提问于2017-12-05得票数 1
回答已采纳
我有一个应用程序，它使用rabbitmq为生态系统的其他部分排队消息。我想做一些性能测试和调优，但只是在我的部分(程序)。因此，我想我想以某种方式“模拟”掉rabbitmq服务器，但不更改我的应用程序。
有没有像虚拟rabbitmq服务器这样的东西，可以接受所有消息并立即丢弃它们？或者我能用这种方式配置实际的rabbitmq吗？
浏览 4提问于2018-11-02得票数 0
2回答
根据我使用消息代理的经验，RabbitMq在高负载下有更好的性能。但是，为了简单起见，最好在浏览器中使用AtiveMQ。我想知道是否可以同时使用这两种方法？此外，有没有办法在浏览器中使用ActiveMQ发送消息，在服务器端使用RabbitMQ接收相同的消息？如果有人建议我一个有用的示例代码，我将不胜感激。
浏览 2提问于2015-12-14得票数 6
1回答
我正在开发一个金融应用程序，它(间接地)使用websocket-client每秒从NseIndia接收实时提要。所有这些任务都需要并发的各种符号的实时提要。每个符号都是一个Python对象，其中包含请求该符号的任务列表。为了实现这种并行性
浏览 2提问于2020-05-28得票数 1
我认为消息处理的逻辑不是幂等的。因此，在执行它之前，我让每个传入的消息通过一个特殊的数据库表检查重复项。例如，在RabbitMQ的情况下，如果消息被递送到消费者，然后被重新排队，那么当消息被再次递送时，RabbitMQ将在其上设置“已重新递送”标志。有没有办法知道在一次失败的尝试后，是什么rebus再次发送了消息，或者需要检查每条重复的<
浏览 0提问于2018-01-27得票数 2
我想使用Spark structured来聚合从RabbitMQ消费的数据。我知道与apache kafka有官方的spark结构化流媒体集成，我想知道是否也存在与RabbitMQ的集成？由于我不能切换现有的消息传递系统(RabbitMQ)，我想使用kafka-connect在消息传递系统(Rabbit to kafka)之间移动数据，然后使用Spark structured st
浏览 0提问于2018-04-16得票数 0
2回答
我们有一个windows服务，它侦听单个RabbitMQ队列并处理消息。由于我是非常新的多线程，需要高水平的指导方针，以下几点，这将帮助我开始建立原型。是否可以使用线程侦听单个应用程序中的多个队列？
如何处
浏览 1提问于2014-02-18得票数 15
我们正在用Ruby构建一个基于AMQP的消息传递系统。然而，我们在错误处理方面有一个问题。
我们维护了一个安全的异常白名单，RabbitMQ中的消息可以不被确认，并由另一个工作人员重试。这意味着，当出现未知错误时，我们需要捕获它，将其记录在某个地方(当前是MySQL)，然后向RabbitMQ发送一个ACK调用以从队列中删除该消息。目前一切都是使用amqp gem构建的，这是通过EventMachine实现的<
浏览 0提问于2011-01-14得票数 4
1回答
多线程和信号量与事件
、、、
我正在尝试执行一些来自RabbitMQ的命令。大约5毫升/秒。因此，由于有太多的msg，我必须发送到一个线程来执行，但是我没有那么多线程，所以我设置了10的限制。因此，想法是，消息会到达工人那里，放入队列，10个线程中的任何一个都将达到峰值并执行。所有这些都是用信号量。经过一些实验，我不知道为什么，但我的线程只执行3或4个项目，然后它就停止了，没有错误…
我认为问题在于事件调用方法执行时的逻辑，无法以<em
浏览 1提问于2018-05-17得票数 1
回答已采纳
我有一个目前，我正试图在上面的堆栈中使用rabbitmq。因此，对于上述情况，我希望为每个进程创建单个rabbitmq连接，并使用多个通道来支持多
浏览 2提问于2021-01-16得票数 0
RabbitMQ是否有消息优先级的概念？我有一个问题，一些更重要的消息正在减慢，因为队列中不太重要的消息位于它之前。我希望高优先级的优先，并移动到队列的前面。我知道我可以使用两个队列，一个是“快速”队列，一个是“慢”队列，但这似乎是一个技巧。
有没有人知道使用RabbitMQ的更好的解决方案？
浏览 9提问于2012-05-25得票数 46
回答已采纳
我有一个运行在多个处理器上并写入sqlite数据库的网络爬行器。因为Sqlite不是用来处理并发写入的，所以我想使用一个队列系统，它可以处理多个输入，并且只有一个对象写入数据库 我检查了RabbitMQ hello world示例，得到了一个错误。我的send.py文件： from models import TestCan
浏览 25提问于2019-03-03得票数 0
回答已采纳
我是RabbitMQ的新手，所以我查看了教程()在本教程中，我们使用pika连接通道的basic_consume函数来消费消息。正如basic_consume()的文档所述，它显然消耗了消息，但我的问题是，回调函数是以什么方式执行的？在教程的下一部分()中，我们可以检查单个线程不能同时调用两个回调函数(在我们运行示例代码时，休眠消息在每个线程中逐个出现)。但在任何文档中都不能保证这
浏览 0提问于2018-09-01得票数 0
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
