RabbitMQ 向每个消费者发送相同的消息

2023-11-25

我已经实现了 RabbitMQ 网站上的示例:RabbitMQ 示例

我已将其扩展为带有一个用于发送消息的按钮的应用程序。 现在我在两台不同的计算机上启动了两个消费者。 当我发送消息时,第一条消息发送到computer1,然后第二条消息发送到computer2,第三条消息发送到computer1,依此类推。

这是为什么?如何更改将每条消息发送给每个消费者的行为?


为什么是这样

正如 Yazan 所指出的,消息以循环方式从单个队列中消耗。您所看到的行为是设计使然,可以轻松扩大给定队列的消费者数量。

如何更改将每条消息发送给每个消费者的行为?

为了让每个消费者都收到相同的消息,需要为每个消费者创建一个队列,并向每个队列传递相同的消息。

最简单的方法是使用fanout交换。这会将每条消息发送到绑定到交换器的每个队列,完全忽略路由键。

如果您需要对路由进行更多控制,可以使用topic or direct交换和管理路由密钥。

但是,无论您选择哪种类型的交换,您都需要为每个消费者提供一个队列,并将每条消息路由到每个队列。

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

RabbitMQ 向每个消费者发送相同的消息 的相关文章

随机推荐

  • iOS 应用程序的两个版本 - 免费和付费 - 如何有条件地更改 Xcode 中的项目 ID?

    我的应用程序 ID 为 com mydomain AppName 它是paid版本 我决定介绍一下free版本也是如此 通过我的代码 我可以使用简单的 define ifdef 业务轻松添加广告 删除一些功能 但是 我确实需要我的应用程序
  • 使用 SyncAdapter 与 *本地* Gmail 和 Facebook 应用程序数据同步

    对于我需要开发的应用程序 我需要能够使用 SyncAdapter 与 gmail 和 facebook 数据同步 我希望与本地 Facebook 和 Gmail 应用程序 如果可用 同步 而不是与远程服务器同步 与本地应用程序同步意味着更少
  • 即使条件计算结果为 false,if 语句似乎也在计算

    昨晚工作到很晚 我们试图找出出现问题的原因 验证检查在不应该失败的时候失败了 我们最终在这段代码中添加了一条 print 语句 从 Reflector 中反汇编 以检查代码实际上是我们编写的 public static string Red
  • CSS 导入或带有“media”属性的

    在页面中包含 CSS 的最佳方法是什么 为什么 for eg or
  • JQuery旋钮显示数量变化

    我在用着jQuery 旋钮制作一些很酷的图表并且它运行得很好 但我有一个问题 我想让图表之间的显示数字有一个 符号连接 但我似乎无法让它发挥作用 通过 jquery 修改输入是行不通的 我尝试读入库的代码 但没有成功 以前有其他人遇到过这个
  • 当键盘出现时如何使视图控制器滚动到文本字段

    我想让我的uiviewcontroller xib滚动 我的视图控制器有大约 8 个文本字段 所以我的问题是当我想在第五期写点东西时textfield等等我的键盘覆盖了文本字段 我怎样才能摆脱这个问题 并使我的视图控制器滚动 由于我是iPh
  • 如何使用 Spring 4 和注释编写单元测试来验证异步行为?

    如何使用 Spring 4 和注释编写单元测试来验证异步行为 由于我习惯了 Spring 的 旧的 xml 风格 我花了一些时间才弄清楚这一点 所以我想我回答自己的问题是为了帮助别人 首先是公开异步下载方法的服务 Service publi
  • java中的3D Ray-Quad相交测试

    在 3D 空间中 我试图确定射线 直线是否与正方形相交 如果是 则确定它相交的正方形上的 x 和 y 位置 我有一条由两点表示的射线 R1 Rx1 Ry1 Rz1 and R2 Rx2 Ry2 Rz2 正方形由四个顶点表示 S1 Sx1 S
  • 将参与者添加到 XMPP 聊天室

    我想在我的应用程序中实现群聊 为此我使用 MUC 聊天室来实现相同的功能 在这里 我想向房间添加成员列表 我有 JID 我想将它们内部添加到列表中的所有成员中 我如何在不邀请他们的情况下添加他们 添加成员后 我想实现一项功能 每当聊天室的用
  • 是否可以在 Dart 类中将方法声明为 Final?

    在 Java 中 可以在类中声明方法以防止子类覆盖它 例如 class Foo final void bar some code here Dart中有类似的构造吗 package meta提供了一个 nonVirtual注解禁止覆盖方法和
  • 在 SecureRandom 类中使用“SHA1PRNG”

    我有一个基本问题 为什么在 SecureRandom 类中使用 SHA1PRNG 如果有人解释一下 将会很有帮助 提前致谢 前任 SecureRandom getInstance SHA1PRNG Warning 我认为直接依赖这个算法是不
  • 从平面列表创建 java 层次结构树集

    我有对象 T 的列表 它有一个父属性 其中顶部对象的父属性为 null 我想将所有对象放入 TreeSet 或 TreeMap 中 顶级对象将是所有没有父对象 父对象为空 的根对象 并且它们下面将有子对象 像这样的东西 o Ra Rb Rc
  • Ninject 和 ASP.NET Web API

    在我提出问题之前 您应该知道我从此页面获取了当前的代码 http www strathweb com 2012 05 using ninject with the latest asp net web api source 我正在尝试通过使
  • 在模板函数中包装 std::format 无法使用最新的 MSVC 编译器更新进行编译

    我有点困惑为什么这段代码突然停止编译 https godbolt org z hhM5GG78x 但如果我将编译器改回 v19 31 它将编译 https godbolt org z 11j8WbEzG 这是有问题的代码 include
  • 如何使用 LINQ 从字符串中删除字符

    我有一个像这样的字符串 XQ74MNT8244A 我需要删除所有char从字符串中 所以输出会像 748244 这个怎么做 请帮我做到这一点 new string XQ74MNT8244A Where char IsDigit ToArra
  • Redis 和 Membase 之间的主要区别是什么?

    Redis 和 Membase 之间的主要区别是什么 可扩展性 Membase 提供分布式键 值存储 就像 Memcache 一样 因此无论数据集有多大 写入和读取都将始终在可预测的恒定时间内执行 另一方面 Redis 只提供主从复制 可以
  • 当页面为 HTTPS 时 URLReferrer 为 null

    我们使用 URLReferrer 和在查询字符串中传递的代码来生成在线视频 以便只有我们的付费客户才能链接到我们的视频播放页面 该系统已经运行良好一段时间了 我知道 URL 引荐来源网址可能会被欺骗 但谁会告诉他们的客户做这样的事情来访问视
  • 使用字典替换文本文件中的单词

    我正在尝试打开一个文本文件 然后通读它 用存储在字典中的字符串替换某些字符串 根据以下问题的答案如何在 Python 中编辑文本文件 我可以在进行替换之前取出字典值 但循环字典似乎更有效 该代码不会产生任何错误 但也不会进行任何替换 imp
  • Node.js 中的 New Date() 时间错误

    考虑 root ubuntu firma Exotech heart beat heart beat service date Mon Apr 24 17 07 52 CEST 2017 root ubuntu firma Exotech
  • RabbitMQ 向每个消费者发送相同的消息

    我已经实现了 RabbitMQ 网站上的示例 RabbitMQ 示例 我已将其扩展为带有一个用于发送消息的按钮的应用程序 现在我在两台不同的计算机上启动了两个消费者 当我发送消息时 第一条消息发送到computer1 然后第二条消息发送到c