带有setRollbackOnly的JMS和MDB

Question

我有一个java类，它使用来自队列的消息，向一些URL发送HTTP调用。我已经在google和stackoverflow上做了一些搜索（如果我错过了提到这个问题的任何来源，我真的很抱歉），但是没有找到关于setRollbackOnly调用的任何细节。

我的问题是...在回滚的情况下，从队列中消耗的消息将阻塞队列的其余部分，并且将循环直到它被成功处理，或者在当前队列的末尾重新使用？

下面是我用于从队列消费和发送HTTP调用的代码，整个应用程序运行在Glassfish服务器上：

public class RequestSenderBean implements MessageListener
{
  @Resource
  private MessageDrivenContext mdbContext;

  public RequestSenderBean(){}

  public void onMessage(final Message message)
  {
    try
    {
      if(message instanceof ObjectMessage)
      {

          String responseOfCall=sendHttpPost(URL, PARAMS_FROM_MESSAGE);

          if(responseOfCall.startsWith("Success"))
          {
            //Everything is OK, do some stuff
          }
          else if(responseOfCall.startsWith("Failure"))
          {
            //Failure, do some other stuff
          }

    }
    catch(final Exception e)
    {
      e.printStackTrace();
      mdbContext.setRollbackOnly();
    }
  }
}

Answer 1

这是基本的JMS/消息传递知识。

队列实现了“负载平衡”场景，即消息到达队列并被分配给一个使用者处理。增加使用者的数量会增加队列处理的潜在吞吐量。队列中的每条消息将由一个且仅一个使用者处理。

主题提供发布-订阅语义：主题的所有使用者都将接收推送到主题的消息。

消息消耗

消息传递产品本质上是异步的：消息的产生和使用之间没有基本的时序依赖关系。但是，JMS规范在更精确的意义上使用了这个术语。可以通过以下两种方式使用消息：

同步：订阅者或接收者通过调用receive方法显式地从目标获取消息。receive方法可以阻塞直到消息到达，或者如果消息没有在指定的时间限制内到达，则可以超时。

使用会话bean生成和同步接收消息

生成消息或同步接收消息的应用程序可以使用会话bean来执行这些操作。在一个应用程序中使用JMS API和会话Bean的示例使用一个无状态会话Bean将消息发布到一个主题。

因为阻塞的同步接收会占用服务器资源，所以在企业bean中使用这样的接收调用不是一个好的编程实践。相反，使用定时同步接收，或者使用消息驱动的bean异步接收消息。有关阻塞和定时同步接收的详细信息，请参见编写同步接收示例的客户端。

消息驱动的bean类MessageBean.java实现了方法setMessageDrivenContext、ejbCreate、onMessage和EJBRemove。onMessage方法几乎与TextListener.java的方法相同，它将传入消息强制转换为TextMessage并显示文本。唯一显著的区别是，它在发生异常时调用MessageDrivenContext.SetRollBackOnly方法。此方法回滚事务，以便重新传递消息。

我建议您阅读Java EE教程以及Enterprise Integration Patterns book，这本书详细介绍了消息传递概念，这也是与产品/技术无关的。