【问题标题】:one message getting consumed by 2 consumer一条消息被 2 个消费者消费
【发布时间】:2013-09-11 18:49:09
【问题描述】:

我配置了两个订阅主题的消费者。现在,当我收到有关该主题的消息时,两个消费者都在使用相同的消息。在我从某个进程中得到确认之前,我不会删除该消息,这样我就不会丢失任何消息。

我打算做的是,当我有 2 条消息时,每个消费者应该单独处理第一条消息的前第一个消费者和第二条消息的第二个消费者的消息。

我所有的代码(生产者、消费者)都是用 java 写的(没有使用 spring maven 等框架。)

我怎样才能做到这一点?

【问题讨论】:

    标签: java activemq


    【解决方案1】:

    Topic 发布消息供多个消费者使用,而Queue 发布消息仅供一个消费者使用。所以我相信你需要使用Queue 而不是Topic。

    阅读有关主题和队列差异的更多信息:

    http://activemq.apache.org/how-does-a-queue-compare-to-a-topic.html

    【讨论】:

    • 我了解主题和队列之间的差异,如果我有一个生产者一次向 activemq 队列发送两条消息。如何由两个消费者并行处理两条消息? 注意:我不能有两个差异队列,因为那样我需要两个生产者。
    • 如果您有多个消费者在自己的线程中运行,那么消费者可以选择多条消息并一次处理。
    猜你喜欢
    • 1970-01-01
    • 2020-08-11
    • 2021-05-01
    • 1970-01-01
    • 2018-06-04
    • 2017-09-23
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多