从 QueueBrowser 确认消息的替代方案

Question

我对 JMS 比较陌生。我有这样的要求：

事件被发布到队列中。每个事件都有一个与其关联的 UserID，并且必须按顺序处理给定 UserID 的事件。有时事件无法立即处理，因此我们希望暂时忽略来自该 UserID 的事件，同时继续使用队列中其他 UserID 的事件。

最初我认为 QueueBrowser 可能会有所帮助，a la：

Session session = connection.createSession(true, Session.CLIENT_ACKNOWLEDGE);
QueueBrowser queueBrowser = session.createBrowser(eventQueue);
Enumeration messages = queueBrowser.getEnumeration();
HashSet<Integer> busylist = new HashSet<Integer>(); // Keeps track of busy users
while (messages.hasNextElement())
{
  t.begin()
  Message msg = (Message) messages.getNextElement();
  Integer userId = msg.getIntProperty("UserID");
  if (busylist.contains(userId))
    continue;
  boolean userIsBusy = process(msg);
  if (userIsBusy)
  {
    busylist.add(userId);
    continue;
  }
  msg.acknowledge();
  t.commit();
}

这个想法是消耗队列中的所有内容，但是当用户忙碌时，将其记录在繁忙列表中并继续处理下一条消息。上面的代码可能每分钟调用一次。 在测试了与上述代码类似的内容后，我发现来自队列浏览器的消息上的acknowledge()消息按设计没有执行任何操作。

我的问题是，我怎样才能实现与上述类似的目标？我看到的一个解决方案是为我想要确认的每条消息创建一个 MessageConsumer，使用消息选择器来选择单个消息......对我来说这似乎有点低效。还有其他方法可以做到这一点吗？

我认为每个用户一个队列是不可接受的解决方案。有数百万用户。

Answer 1

不要立即偏离您的方法，但是您可以在发送消息时设置消息的生存时间吗？这样，如果用户没有在指定时间内消费他们的消息，他们的消息将被JMS引擎自动清除。

或者，采用您的方法，而不是为每个空闲用户的每条消息创建一个消息使用者，而是将消息 ID 批处理为 n 条消息集。当批次已满或浏览器到达消息集末尾时，指示消息使用者使用指定所有空闲消息ID的选择器并使用它们。