JMS 不回滚 XA 事务(或不参与 XA 事务)

Question

我对XA事务比较陌生。几天来，我一直在努力使一个简单的XA事务工作，但无济于事。

首先，我尝试使用两个不同的数据库。我设置了2个XA数据源，并且在第二个数据库操作失败时成功回滚了第一个数据库操作。到目前为止，一切顺利。但后来我试图用JMS connectionFactory替换第二个数据源，无法重现相同的行为。

相关代码如下:

数据库逻辑

:

@Stateless
public class FirstDB implements FirstDBLocal {
    @PersistenceContext(unitName = "xaunit")
    private EntityManager em;
    public void doSomething() {
        SomeEntity someEntity = em.find(SomeEntity.class, 1234L);
        someEntity.setSomeFlag(false);
    }
}

<<p> JMS代码/strong>:

@Stateless
public class SecondJMS implements SecondJMSLocal {
    @Resource(mappedName = "java:/JmsXA")
    private ConnectionFactory connFactory;
    @Resource(mappedName = "queue/Some.Queue")
    private Queue q;
    @Override
    @TransactionAttribute(TransactionAttributeType.MANDATORY)
    public void sendMsg() {
        Session session = null;
        Connection conn = null;
        MessageProducer producer = null;
        try {
            conn = connFactory.createConnection("guest", "guest");
            session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
            producer = session.createProducer(q);
            // Not sure if I need this, but I found it in the sample code
            conn.start();
            TextMessage tm = session.createTextMessage(new Date().toString());
            producer.send(tm);
            throw new RuntimeException("Fake exception");
        } catch (JMSException e) {
            e.printStackTrace();
        } catch (RuntimeException e) {
            e.printStackTrace();
        } finally {
            // close all resources
        }
    }
}

胶水代码:

@Stateless
public class TestDBandJMS implements TestDBandJMSLocal {
    @EJB
    private FirstDBLocal firstDBLocal;
    @EJB
    private SecondJMSLocal secondJMSLocal;
    public void doStuff() {
        firstDBLocal.doSomething();
        secondJMSLocal.sendMsg();
    }
}

XA连接工厂配置(所有内容都是JBoss默认的，除了注释掉的安全设置):

<tx-connection-factory>
      <jndi-name>JmsXA</jndi-name>
      <xa-transaction/>
      <rar-name>jms-ra.rar</rar-name>
      <connection-definition>org.jboss.resource.adapter.jms.JmsConnectionFactory</connection-definition>
      <config-property name="SessionDefaultType" type="java.lang.String">javax.jms.Topic</config-property>
      <config-property name="JmsProviderAdapterJNDI" type="java.lang.String">java:/DefaultJMSProvider</config-property>
      <max-pool-size>20</max-pool-size>
      <!-- <security-domain-and-application>JmsXARealm</security-domain-and-application> -->
      <depends>jboss.messaging:service=ServerPeer</depends>
   </tx-connection-factory>

我还有一个非常简单的MDB，它只是将收到的消息打印到控制台(不打算发布代码，因为它是微不足道的)。

问题是，当在JMS代码中抛出异常时，MDB仍然接收到消息，并且SomeEntity在数据库代码中成功更新(而我期望它回滚)。

这是JMS日志。我看到的一个可疑的东西是:

received ONE_PHASE_COMMIT request

就像我说的，我还不太熟悉XA，但我希望在这里看到TWO_PHASE_COMMIT，因为应该有2个资源参与活动事务。

任何帮助都将非常感激。

在我尝试了@djmorton的建议后，它最终起作用了。在使用JBoss 5.1时要记住的另一件重要的事情是，XA JMS ConnectionFactory的查找名称是"java:/JmsXA"。我对

也做了同样的尝试

@Resource(mappedName = "XAConnectionFactory")
private ConnectionFactory connFactory;

Answer 1

在sendMsg()方法中抛出RuntimeException后，您正在捕获它。Exception将不会触发事务回滚，除非它被抛出堆栈。当使用Container管理事务时，容器将拦截器添加到方法调用中，以便在抛出未检查的异常时设置事务并处理回滚。如果异常没有从方法中抛出，那么拦截器就不知道它需要将事务重新定位。

编辑1:

注意，只有抛出RuntimeException或RuntimeException的子类才会导致事务回滚。检查异常(扩展了exception而不是RuntimeException)不会导致回滚，除非它被注释为@ApplicationException(rollback=true)。

另一种方法是注入EJBContext对象，并调用.setRollbackOnly()来强制事务在方法超出作用域时回滚:

@Stateless
public class SomeEjb {    
    @Resource
    private EJBContext context;
    @TransactionAttribute(TransactionAttributeType.MANDATORY)
    public void rollMeBack() {
        context.setRollbackOnly();
    }
}