Bitronix 事务不适用于 JMS 队列

Question

我的目标是使用Bitronix交易，其中我应该使用两个资源：

1. 数据库
2. 联合医务处

我有以下 java 代码：

package com.mycompany.app;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.Enumeration;
import javax.annotation.Resource;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.QueueBrowser;
import javax.jms.QueueReceiver;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.transaction.TransactionManager;
import javax.transaction.UserTransaction;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.broker.BrokerFactory;
import org.apache.activemq.broker.BrokerService;
import org.apache.activemq.transaction.Transaction;
import org.apache.xbean.spring.context.ClassPathXmlApplicationContext;
import org.springframework.context.ApplicationContext;
import org.springframework.transaction.jta.JtaTransactionManager;
import bitronix.tm.BitronixTransactionManager;
import bitronix.tm.TransactionManagerServices;
public class JMSExample {
static String serverUrl = "tcp://localhost:61616"; // values changed
static String userName = "admin";
static String password = "admin";
static TextMessage message;
public static void sendTopicMessage(String topicName, String messageStr) {
Connection connection = null;
try {
BitronixTransactionManager btm = TransactionManagerServices.getTransactionManager();
btm.begin();
System.out.println("Publishing to destination '" + topicName + "'n");
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(serverUrl);
connection = connectionFactory.createConnection();
Session session = connection.createSession(true, Session.SESSION_TRANSACTED);
Queue queue = session.createQueue(topicName);
Message msg = session.createTextMessage(messageStr);
msg.setJMSCorrelationID("correlationID1");
MessageProducer producer = session.createProducer(queue);
producer.send(msg);
System.out.println("Published message: " + messageStr);
session.commit();
session.close();
connection.close();
btm.rollback();
} catch (Exception e) {
e.printStackTrace();
}
}
public static void main(String[] args) throws Exception {
JMSExample.sendTopicMessage("test", "Hi");
}
}

当我运行上述程序时，我能够看到队列中的消息。 但是我希望JMS事务与Bitronix事务一起嵌套。换句话说，如果Bitronix回滚，队列中也不应该有任何消息。

Answer 1

如果你想在一个事务中原子地处理 2 个资源，那么你需要从每个资源管理器(即 JMS 代理和数据库(获取javax.transaction.xa.XAResource实现。一旦你有了这些，你就可以在你从事务管理器开始的JTA事务中登记它们。然后，任何提交或回滚都将使用登记的 XA 资源以原子方式执行。

要从JMS获得XAResource，请查看javax.jms.XAConnectionFactory。您可以使用createXAConnection()获取javax.jms.XAConnection的实例，然后使用createXASession()获取javax.jms.XASession，最后使用getXAResource()。

要从 JDBC 获得XAResource，请查看javax.sql.XADataSource。您可以使用getXAConnection()获取javax.sql.XAConnection的实例，然后使用getXAResource()。

然后，可以在事务管理器上调用getTransaction()，并使用返回的javax.transaction.Transaction通过 XAResources 调用enlistResource()。然后，当您调用commit()或rollback()事务管理器将处理所有XAResource实现，并确保所有内容都以原子方式执行。

Answer 2

删除 session.commit(( 而 btm.rollback(( 完成了这项工作