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

同一弹性跳闸应用程序的多个实例,但只有 1 个实例使用来自 ActiveMQ 队列的消息

长孙骏
2023-03-14

我正在运行同一个Spring Boot 2.0.4应用程序的多个实例,出于扩展目的,它们使用以下命令消耗来自ActiveMQ队列的消息:@JmsListener(目的地="myQ")

只有第一个消费者接收消息,如果我停止第一个消费者,第二个实例开始接收消息。我希望每个消费者以循环方式使用一条消息,而不是同一条消息。但只有第一消费者消费消息。

共有1个答案

施洛城
2023-03-14

听起来您想要JMS主题而不是队列。在确定设置所需的配置之前,您还应该研究持久订阅、共享订阅和持久主题。

见:

>

  • JMS API 编程模型(搜索 JMS 消息使用者)

    队列vs主题

    持久队列和主题

  •  类似资料:
    • 我有两个经纪人A和B。如果我想将消息从A转发给B,一切都很简单。我只需要代理中的网络连接器,如下所示: 如果我想从其他队列中使用来自代理 B 的消息,我会犹豫不决(让我们将其命名为 QUEUE。自。消费)我只需要做同样的事情,但双工设置为true,只需听队列。自。在代理 A 上消费,如下所示: 但是它不像我预期的那样工作。似乎每一秒钟只有一条信息被转发,其余的都丢失了。令人惊讶的是,这在代理B队列

    • 我有一个ActiveMQ服务器的实例,它运行着几个数据源,如果消息消费失败,它会将数据推送到两个队列中,一个是DLQ。我使用Apache Camel来消费和处理来自这些队列的消息,并想将其写入InfxDB。 然而,到目前为止,我未能让堆栈运行,以使Apache Camel并行消耗所有队列。我总是遇到这种错误: 一个Apache Camel实例如何使用多个队列? 我尝试了两种方法: 每个路由活动MQ

    • 我有一个关于RabbitMQ队列的问题。我想在一个队列上发送两种类型的消息。 我知道,我可以创建两个不同的队列,并使用路由键将不同的消息发送到不同的队列。 但是我希望在一个队列上有两个消费者,并以某种方式将消费者与消息类型绑定。它是通过兔子队列驱动的事件,当客户端和核心是发布者和消费者时。 有可能吗?或者我应该使用不同的队列吗? 数据交换

    • 问题内容: 我想防止在Java中启动应用程序的多个实例。我知道两种方法: 锁定文件 锁紧插座 但是,哪一个是更有效且更易于使用的呢?我应该使用哪一个? 同样欢迎任何其他解决方案。 问题答案: 编辑:我尝试使用Win200864b(版本不重要)和JFrame并通过JFrame在SystemTray中移动到Front()或图标化。DO_NOTHING_ON_CLOSE

    • 我们使用swisscoms应用云,目前正在评估新的Elasticsearch服务。我们设置了包括logstash和Kibana。 我们现在为每个应用程序添加了一个用户提供的服务,这些应用程序应该使用通用的ElasticSearch/LogStash/Kibana实例。当我们第一次登录kibana时,我们看到有一个名为的索引,所有应用程序的所有日志都在这里。 现在我们想要的是为每一个写到elk实例的

    • 我有一个如下所示的MainWindowFx类。它基本上创建了一个简单的GUI。 现在我想在另一个类中使用此对象的实例: 但是当我运行这个时,我遇到了这个错误: 我对此做了一些搜索,并猜测它与线程有关。。。但我还是不知道。有什么建议吗?