gpt4 book ai didi

java - 无法让 ActiveMQ 出队

转载 作者:塔克拉玛干 更新时间:2023-11-02 07:53:18 24 4
gpt4 key购买 nike

对此可能有一个愚蠢的简单答案,但我正在尝试使用 ActiveMQ 在生产者和消费者之间传递消息。我会有很多生产者和很多消费者,但我希望每条消息只在消费者之间传递一次。这似乎意味着我不能使用主题,因为它们会将消息传递给所有正在收听的消费者,而我希望只有一个消费者接收每条消息。

我的问题是我能够接收消息,但消息没有出队。因此,如果我重新启动我的消费者进程,所有消息都会重新处理。 This answer似乎相关但似乎并不适用,因为我无法创建持久队列消费者,只能创建持久主题消费者(除非我在 API 文档中遗漏了某些内容)。

我的代码如下。

TopicConnectionFactory factory = new ActiveMQConnectionFactory(props.getProperty("mq.url"));
Connection conn = factory.createConnection();
Session session = conn.createSession(true, Session.CLIENT_ACKNOWLEDGE);
Queue queue = session.createQueue(props.getProperty("mq.source_queue"));
conn.start();
MessageConsumer consumer = session.createConsumer(queue);

然后再说

Message msg = consumer.receive();
msg.acknowledge();
if (!(msg instanceof TextMessage)) continue;
String msgStr = ((TextMessage)msg).getText();

这是我当前的代码。我试过使用 Session.AUTO_ACKNOWLEDGE 而没有使用 msg.acknowledge()。此代码的任何有效排列似乎都可以检索消息,但是当我重新启动我的消费者时,所有消息都会再次收到,即使它们在重新启动之前已经收到。

最佳答案

您将 session 创建为事务处理 session ,因此如果您想通知代理所有消息现在都已使用并且不需要重新传送,则需要调用 session.commit。如果您没有将 createSession 的第一个参数设置为 true,那么将遵循 Ack 模式,否则将忽略它,这恐怕是 JMS API 的一个奇怪之处。如果你这样做:

ConnectionFactory factory = new ActiveMQConnectionFactory(props.getProperty("mq.url"));
Connection conn = factory.createConnection();
Session session = conn.createSession(false, Session.CLIENT_ACKNOWLEDGE);
Queue queue = session.createQueue(props.getProperty("mq.source_queue"));
conn.start();
MessageConsumer consumer = session.createConsumer(queue);

那么这会起作用:

Message msg = consumer.receive();
msg.acknowledge();

否则你需要做:

Message msg = consumer.receive();
session.commit();

但是请记住,对于单个消息,事务对客户端来说并没有真正的意义,没有事务是更好的选择。

关于java - 无法让 ActiveMQ 出队,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/11276862/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com