7得票1回答
如何让多个celery工作者运行相同的任务?

我有一个任务,需要检查一个url的速度,但我想让不同服务器上的多个celery工作者执行此任务。 我希望同一url由多个工作者进行检查。 我该怎么做?

9得票2回答
没有连接的AMQP/RabbitMQ通道何时会失效?

我有一个简单的RabbitMQ测试程序,随机将消息加入队列,另一个程序则读取这些消息,两个程序都使用Spring-AMQP。如果消费者死亡(例如杀死进程而没有机会关闭它的连接或通道),任何未被确认的消息似乎会一直保持未确认状态。 我看到了许多参考文献(例如这个问题),称当频道没有连接时,该频...

22得票2回答
Spring AMQP转换器问题使用Rabbit Listener

我觉得这里可能有些问题...我正在尝试创建一个简单的rabbit listener,可以接受自定义对象作为消息类型。现在根据文档所说: 在1.6版本之前,必须在消息头中提供类型信息以将JSON转换,或者需要一个自定义的ClassMapper。从1.6版本开始,如果没有类型信息头,则可以从目标...

29得票8回答
在Mac上使用Brew安装AMQP

我想在我的mac sierra上使用pecl安装amqp。 我使用brew安装了php,在运行pecl install amqp时出现错误:checking for amqp using pkg-config... configure: error: librabbitmq not foun...

15得票2回答
AMQP与WebSphere MQ的区别

我们正在开发一个支持AMQP队列的应用程序。一些客户正在使用Websphere MQ。我想知道在功能方面这两种协议在高层次上可互换吗?我正在使用celery,它应该允许我抽象出低级别的东西,只要我能编写一个Websphere MQ后端。我试图弄清楚的是这将是多么困难的挑战。 Webspher...

7得票1回答
何时适合使用AMQP?

在我之前的工作中,我使用了AMQP的好处,但我没有参与rabbitMQ子项目的开发。在我现在的工作中,我想负责集成AMQP实现之一(可能是rabbitMQ)。问题在于我必须说服我的老板使用AMQP。 我正在阅读《RabbitMQ in Action》,Videla先生写道,AMQP可以改进任...

7得票2回答
如何对RabbitMQ服务器进行负载测试(使用JMeter、Python或任何其他工具)?

我被授权访问一个RabbitMQ服务器,以对其进行负载测试。我完全是新手,对服务器和AMQ协议一无所知。我正在在线研究有哪些不同的方法。到目前为止,我正在调查两种方法。 JMeter; 我找到了这个项目:https://github.com/jlavallee/JMeter-Rabbit-...

8得票1回答
死信交换机是指RabbitMQ丢弃消息的情况。

我正在尝试在RabbitMQ中实现dlx队列。 场景非常简单 我有两个队列: 1)alive 2)dead(x-dead-letter-exchange:“immediate”,x-message-ttl:5000) 还有一个交换机“immediate”与1)alive绑定 我尝试运行这个...

11得票4回答
RabbitMQ如何向消费者发送消息?

我是一个RabbitMQ新手,因此需要有一个基本问题的指引: RabbitMQ是按照消息到达的顺序将消息发送给消费者吗?还是在消息可用时将消息发送给消费者? 在消息消耗端点,我正在使用com.rabbitmq.client.QueueingConsumer。通过查看Sprint客户端源代码...

52得票3回答
使用RabbitMQ,有没有一种方法可以在不进行出列操作的情况下查看队列内容?

作为学习RabbitMQ和Python的途径,我正在开发一个项目,可以在多台计算机之间分配h264编码任务。基本功能已经完成,我编写了一个守护进程,在Linux或Mac上运行,连接到队列,接受任务并使用HandBrakeCLI进行编码。一旦编码完成,它会确认消息。我还建立了一个简单的工具来将项...