问题标签 [pika]

我需要一个节点发送消息而另一个节点开始等待获取消息的场景。

每个节点收到消息后变成监听器，收到消息后又变成发布者。

我尝试了解 AMQP 协议的某些方面。目前我有 RabbitMQ 项目并使用 python pika 库。所以问题是关于确认和消息预取。

1. 考虑我们有一个只有消费者的队列（确保这个队列被声明为独占）。那么我是否理解正确：无论我是否使用 ack 标志消费？无论如何，我不应该能够同时处理多条消息，并且没有其他消费者可以接收一些其他仍在排队的消息。最好不要打开确认，因为这可能会减少 AMQP 服务器负载。

2. 如果没有确认，预取计数没有任何意义。正确的？

3. 我不确定预取是如何工作的。我有一个关于新消息的回调，在它的finally声明中我确认或拒绝了该消息。这是唯一的功能，无论预取计数有多大 - 无论如何，在当前消息完成之前不会处理另一条消息。那么为什么我需要改变 prefetch_count 值呢？

提前致谢。

当尝试使用 pika 和 rabbitmq 从笔记本电脑向另一台笔记本电脑发送消息时，出现此错误。任何想法如何解决这个问题？

进程以退出代码 1 结束

使用的代码在这里：

我正在为 android 开发库存控制系统客户端，对 python 的经验很少，而且对 java 一无所知，我决定使用 SL4A Python。

我使用 rabbitmq 和 pika 库作为我的基础。我让 pika 库在 android 下工作。

问题是，如果我的代码即使在几个小时内都失败了，也会对我们的项目造成致命的伤害。SL4A是否认为足够可靠？

使用 buildozer 将其制成 APK 是否会使其或多或少稳定？

我有一个基于 RabbitMQ send.py示例的简单 python 脚本。原始的send.py在我的设置上运行良好，但是当我使用添加的用户和虚拟主机时，脚本在执行时挂起connection.channel()

当我运行它时，我看到了这个：

此时脚本挂起大约 10 分钟。然后打印：

然后pika.exceptions.ChannelClosed异常崩溃。

我的猜测是该频道实际上并不存在，但没有迹象表明该频道connection.channel()失败了。

我有一些简单的代码使用来自多个rabbitmq 队列的消息。

如果它开始时队列中没有消息，它工作正常。

但是，如果启动时其中一个队列中有一条消息，它会在为该队列调用 basic_consume 后立即处理该消息，并且不会通过循环继续到其他 basic_consume 调用。

我怎样才能防止它这样做？

我正在使用“hello world”教程：http ://www.rabbitmq.com/tutorials/tutorial-two-python.html 。 worker.py看起来像这样

我已经使用此代码在我的工作中实现。一切顺利，直到队列中出现打印后引发异常的点[x] Done

我不明白连接是如何在进程之间自动关闭的。对于队列中的 100 条消息，进程运行良好，然后突然出现此错误。任何帮助表示赞赏。

我想使用rabbitmq实现rpc客户端。我的代码主要看起来像

什么是阻止这个客户的正确方法？现在我channel.basic_cancel(self.on_cancel, self.consumer_tag)从另一个线程制作。然而鼠兔常见问题解答说 It is not safe to share one Pika connection across threads.

取消消费的首选方式是什么？

我正在使用 pika python 库连接到本地主机上的 rabbitmq-server。

出于某种原因，经过一段时间（比如几天）后，我遇到了错误。

Rabbitmq 服务器日志

它在 ubuntu 13.10 上运行。兔MQ 3.1.3

我不明白发生了什么。你可以解释吗？

我在 linux OS 环境中使用 python 和 pika。当 RabbitMQ 未运行时，消息/主题接收器不断崩溃。我想知道有没有办法让消息/主题接收器在 RabbitMQ 不运行时保持运行，因为 RabbitMQ 不会与消息/主题接收器位于同一虚拟机上。

这涵盖了 RabbitMQ 因某种原因崩溃但消息/主题接收器应该继续运行的情况。无需再次启动/重新启动消息/主题接收器。