1

我对 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);
    }

}

JMS 代码：

@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 Connection Factory 配置（一切都是 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;

它没有用。

4

1 回答 1

3

将 RuntimeException 放入 sendMsg() 方法后，您正在捕获它。异常不会触发事务回滚，除非它被抛出堆栈。使用容器管理的事务时，容器会在方法调用中添加拦截器，以设置事务并在引发未经检查的异常时处理回滚。如果异常没有从方法中抛出，则拦截器不知道它需要将事务返回。

编辑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();
    }
}
于 2014-03-22T17:06:41.043 回答