《rabbitmq》专题

我有一个项目，其中Rabbit被启动： 然后我做了另一个连接到这个队列的项目。没有doker，我只是使用localhost作为主机和端口号5672。 我想在docker中用数据库运行另一个项目: 现在我无法连接到Rabbit。我尝试使用相同的名称创建不同的网络，但每次我都会遇到相同的错误： 连接: 其中 host 是容器名称 rabbitmq。是否可以执行此操作，或者是否有必要以其他方式将程序放入

我试图从localhost:5000上托管的python服务器向RabbitMQ服务器发送消息（使用RabbitMQ的docker映像），但我收到以下错误： 插座gaierro:gaierro:[Errno-2]名称或服务未知 我正在使用命令运行RabbitMQ的docker映像，其中“rabbithost”是我正在使用的主机名： sudo docker run-d——主机名rabbithost—

我做错了什么？ 作为命令运行docker run-d-name rabbit MQ _ awr-p 5672:5672-p 5673:5673-p 15672:15672 rabbit MQ:3-管理 但http://localhost:15672/没有在浏览器中启动 下面日志

我有一个RabbitMQ设置，其中作业被发送到交换，交换将它们传递到队列。使用者依次正确地执行队列中的作业。但是，这些作业都是长流程（至少几分钟）。对于可伸缩性，我需要能够让多个使用者从队列顶部选择一个作业并执行它。 使用者正在一个叫做“队列”的Heroku dyno上运行。当我缩放dyno时，它似乎为每个dyno创建了额外的消费者（我可以在RabbitMQ仪表板上看到这些）。但是，队列中的任务数

我有以下场景： 一次生产性服务 消费者服务的动态数量 消息包含特定产品的任务，因此一旦使用者x处理产品Y的消息。将来，x应该处理产品Y的所有消息。理想情况下，生产者服务应该将产品x的所有消息发送到一个队列中，只有消费者x才能从中读取。 为了平均分配工作负载，应该有一种方法，即一旦需要管理新产品，下一个可用使用者就会使用它。（我假设是所有使用者都在读取的队列） 我的方法： exchange发送“Ne

我正在使用RabbitMQ，我对使用扇出交换和类的（或)方法感到困惑。 例如，我有两个持久队列的使用者QUEUE-01和QUEUE-02，它们绑定到持久扇出交换fanout-01。并将1个发布服务器发送到FANOUT-01。我理解当消息使用（或)方法发布时会发生什么，消息将被复制到每个队列并由每个使用者处理。但我不确定如果我将调用方法会发生什么？我会从哪位消费者那里得到回复？有什么特别的行为吗？我

我最近一直在用芹菜，我不喜欢它。它的配置是混乱的，过于复杂的，并且没有很好的文档记录。 我想从一个生产者向多个消费者发送带有芹菜的广播消息。使我困惑的是芹菜术语和底层传输rabbitMQ的术语之间的差异。 在RabbitMQ中,您可以使用单个扇出交换和多个队列来广播消息： 但在Celery中，术语都搞乱了：这里可以有一个广播队列，它向多个消费者发送消息： 我甚至不明白Celery广播队列应该如何工

RabbitMQ Java客户端有以下概念： -与RabbitMQ服务器实例的连接 -？？？ 使用者线程池-使用RabbitMQ服务器队列中的消息的线程池 队列-按FIFO顺序保存消息的结构 我试图理解他们之间的关系，更重要的是，他们之间的联系。 我仍然不太清楚是什么，除了这是您发布和使用的结构，并且它是从一个开放的连接创建的。如果有人能向我解释一下“通道”代表什么，可能有助于澄清一些问题。 通道

我能够使用Publish/SubscribeRabbitMQ Java教程创建扇出交换，任何连接的使用者都将收到一个消息的副本。我想在连接任何使用者之前创建交换和绑定，而不是动态/编程地声明交换和绑定。我已经通过RabbitMQ管理控制台完成了这一点。然而，由于某种原因，我的消费者以循环方式接收消息，而不是全部接收消息的副本。我错过了什么？下面是一些代码片段： 发布者： 消费者： ...在Rabb

我正在寻求一些关于如何最好地配置我的rabbitMQ交换的建议。 我试着用循环系统的方法来交换话题。每个使用者都有自己的（唯一的）命名队列连接到主题交换。我希望交换为“相同”主题循环消息到每个使用者队列-比如。 我尝试了多个组合，但似乎只能同时将消息传递到使用者队列，这实际上意味着我要处理两次消息，每个使用者一次。 为了清楚起见，我还有一个扇出交换，我用它来“控制”消费者（启动、停止等）。这应该在

我刚刚开始使用RabbitMQ和AMQP。 我有一个消息队列 我有多个消费者，我想用相同的消息做不同的事情。 RabbitMQ的大部分文档似乎都集中在循环（round-robin）上，即单个消息由单个消费者使用，负载在每个消费者之间分散。这的确是我目击的行为。 例如：生产者只有一个队列，每2秒发送一次消息： 这里有一个消费者： 如果我启动消费者两次，我可以看到每个消费者都在以循环行为消费交替消息。

我已经用MassTransit实现了一个简单的发布者/使用者集，我想让使用者从同一个队列中读取消息。但是，当我运行它时，我看到很大一部分消息被发送到错误队列，而不是被消耗。从我看到的讨论（所以，论坛）来看，对于RabbitMQ来说，这应该非常非常简单（只需指向相同的队列），但它并不起作用。是否有应该设置的附加配置？ 这是我的出版商 还有我的消费者

我尝试了不同的版本，我总是得到同样的错误。

我正在构建一个使用微服务架构的系统，使用RabbitMQ作为消息传递服务。我有一个2个服务之间通信的用例，并面临使用RabbitMQ实现它的困难。 购物车服务需要从产品服务获取数据。在这种情况下，购物车服务可以发送消息，产品服务订阅该消息。但是我找不到产品服务将数据发回购物车服务的方法。 你能让我知道我在这种情况下使用RabbitMQ的方法是否正确吗？在这个用例中，我还应该应用其他方法吗？提前感谢

Spring WebSocket的留档状态为： 应用程序可以发送针对特定用户的消息，为此，Spring的STOMP支持识别前缀为“/user/”的目的地。例如，客户端可能订阅目的地"/user/队列/位置更新"。该目的地将由UserDestinationMessageHandler处理，并转换为用户会话独有的目的地，例如"/队列/位置-更新-用户123"。这提供了订阅通用命名目的地的便利，同时确保