当前位置: 首页 > 知识库问答 >
问题:

需要spring rabbitmq向所有客户发送消息-禁用一个队列的循环

南宫阳冰
2023-03-14

我有两个队列,我需要对其中一个队列执行以下操作:生产者应该向这个队列发送一条消息,但所有消费者都应该接收它。因此,如果我在这个队列中有5个spring侦听器,那么每个侦听器都应该接收消息,而不是生产者。我这样做是因为我有一个tomcat集群和rabbitmq异步消息,如果我从工作者那里得到响应,我不知道如何将它分派到正确的tomcat节点。所以我决定将所有工作者回复广播给所有tomcat节点。每个tomcat集群节点侦听相同的输出队列。然后,如果它是一个正确的tomcat实例,它将被处理,所有其他副本都将丢失,这就OK了。如何落实?如何让Tomcat端的消费者同时接收到相同的消息

共有1个答案

贺劲
2023-03-14

好的,在这里找到了解决方案:RabbitMQ/AMQP:单个队列,同一消息的多个消费者?这在rabbitmq中是不可能的,需要为每个消费者创建几个队列。

 类似资料:
  • 问题内容: 这段代码一切正常(将其缩短以便更好地阅读)。 当向服务器发送请求时,服务器会立即响应他。但是,其他客户端看不到响应消息。 因此,我想进一步说明:当客户端向服务器发送请求时,服务器将响应所有客户端,以便所有客户端都能看到消息。 我怎样才能做到这一点?有任何示例或不错的入门教程吗? 提前致谢! 服务器: 问题答案: 您必须使用连接池将消息广播到所有连接。您可以将其用作教程/示例http:/

  • 我刚开始使用Firebase云消息。我建了一个IOS应用来接收推送通知。应用程序运行良好。我从Firebase控制台发送消息,它们会正确显示。 我的问题是:我可以向所有设备发送一条消息吗(就像我可以在控制台中做的那样)?我是的,怎么会这样? 提前道谢!

  • 问题内容: 所以现在,我正在制作一个基于客户端服务器应用程序的多线程。在服务器端,我为接受的每个连接创建了一个线程。 在线程类中,我创建了一种将命令发送到客户端的方法。我只想要的是如何将参数发送到所有正在运行的客户端?为简单起见,我只想使此服务器向所有连接的客户端发送消息。 我已经阅读了这篇文章,并从此链接中找到方法。但是,当我尝试使用自己的代码时,中没有类似的方法。 好的,这是我的服务器和线程示

  • 我有两个独立实例(p1、p2)的生产者应用程序和两个独立实例(c1、c2)的消费者应用程序。 生产者p1连接到exchange,主题为t1,队列名称为name1。 使用者c1连接到exchange,主题为t1,队列名称为name1。 生产者p2连接到exchange,主题为t2,队列名称为name1。 使用者c2连接到exchange,主题为t2,队列名称为name1。 我在RabbitMQ GU

  • 我知道我们可以通过聊天聊天=muc2.create私人聊天(“myroom@conference.jabber.org /johndoe”);chat.send消息(“你好”);在留档中给出。 但是我没有找到公开和群里所有用户聊天的方法。任何想法? 提前谢谢。

  • 我正在通过Spring集成设置一个TCP客户端,以字符串作为有效负载发送消息,不期望返回。也许序列化器/反序列化器不能正常工作?对不起,我正在学习Spring集成。 我可以通过oepnssl连接到外部TCP服务器: 我需要发送的命令是“sessions.list\n。\n”。 现在我构建了一个试图连接到服务器的tcp客户端: spring上下文。xml 因此,在这个repo之后,字符串应该转换为字