JMS-一个队列和多个接收器（消费者）

Question

我有一个由第三方发布的JMS队列。我想在不同的机器上设置多个使用者，只有一台特定机器的使用者确认该队列上的消息。简而言之，如果特定机器的使用者没有接收到消息，那么该消息不应从队列中删除。这是可以实现的吗？

Answer 1

好吧，你可能有你的理由设置，这是很容易实现的。

我将使用本地会话事务。根据某些规则提交或回滚事务是相当容易的，例如哪个服务器正在使用消息。如果回滚，消息将再次排在队列的第一位。

示例代码可能如下所示：

public class MyConsumer implements MessageListener{ 
  Session sess;

  public void init(Connection conn, Destination dest){
    // connection and destination from JNDI, or some other method.
    sess = conn.createSession(true, Session.AUTO_ACKNOWLEDGE);
    MessageConsumer cons = sess.createConsumer(dest);
    cons.setMessageListener(this);
    conn.start();
  }

  @Override
  public void onMessage(Message msg) {
    // Do whatever with message
    if(isThisTheSpecialServer()){
       sess.commit();
    }else{
       sess.rollback();
    }
   }

   private boolean isThisTheSpecialServer(){
      // figure out if this server should delete messages or not
   }
}

本主题的摘要（针对ActiveMQ，但通常是针对JMS编写的）可以在这里找到。http://activemq.apache.org/should-i-use-transactions.html

我不知道这种行为是否与所有的JMS实现一致，但是对于ActiveMQ，如果您尝试使用带有session.client_accelldgement的非事务会话，那么它的行为将不会真正像您期望的那样。已读取但未确认的消息仍在队列中，但不会被“释放”并传递给其他JMS使用者，直到连接中断到第一个使用者（即connection.close()、崩溃或类似的）。

使用本地事务，您可以通过session.commit（）和session.rollback（）显式地控制这一点。我认为不使用事务没有实际意义。确认是为了保证交货。