同步 JMS 消息队列和 JDBC 事务 - 是否需要事务代理

Question

我们需要在事务中将消息从 JMS 队列持久化到数据库，以确保在 DB 持久化期间抛出任何错误时不会确认 JMS 消息。 基于此处提供的解决方案-Transaction handling while using message driven channel adapter & service activator 以下是我到达的方法

<int-jms:message-driven-channel-adapter id="jmsIn"
    transaction-manager="transactionManager"
    connection-factory="sConnectionFactory"
    destination-name="emsQueue"
    acknowledge="transacted" channel="jmsInChannel"/>

<int:channel id=" jmsInChannel " />

<bean id="dataSource"
    class="org.springframework.jdbc.datasource.DriverManagerDataSource">
    <property name="driverClassName" value="org.hsqldb.jdbcDriver" />
    <property name="url" value="jdbc:hsqldb:mem:testdb" />
</bean>

<!-- Transaction manager for a datasource -->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource" />
</bean>

    <bean id="sconnectionFactory"       class="org.springframework.jms.connection.TransactionAwareConnectionFactoryProxy">
        <property name="targetConnectionFactory">
            <bean class="project.TestConnectionFactory">

            </bean>
        </property>
        <property name="synchedLocalTransactionAllowed" value="true" />
    </bean>

请确认理解是否正确。另外，有以下疑问

1. 在这种情况下是否需要 TransactionAwareConnectionFactoryProxy
2. JMS 队列和 JDBC 是两个独立的事务资源。将 jdbc 事务管理器注入到 JMS 适配器中，如本例所示，相当于使用 ChainedTransactionManager（链接 JMS 事务管理器和 JDBC 事务管理器）

Answer 1

对于TransactionAwareConnectionFactoryProxy，请查阅其JavaDocs：

 * Proxy for a target CCI {@link javax.resource.cci.ConnectionFactory}, adding
 * awareness of Spring-managed transactions. Similar to a transactional JNDI
 * ConnectionFactory as provided by a Java EE server.
 *
 * <p>Data access code that should remain unaware of Spring's data access support
 * can work with this proxy to seamlessly participate in Spring-managed transactions.
 * Note that the transaction manager, for example the {@link CciLocalTransactionManager},
 * still needs to work with underlying ConnectionFactory, <i>not</i> with this proxy.

我不确定这与您对 JMS+DB 事务的请求有何关系，但我认为您应该担心支持这两种事务资源的事务管理器。

为此，Spring 建议使用 JtaTransactionManager 进行 XA 事务。 或者你可以根据 Dave Syer 的文章考虑使用ChainedTransactionManager：http://www.javaworld.com/article/2077963/open-source-tools/distributed-transactions-in-spring--with-and-without-xa.html

更新

如果本地交易适合您，您真的可以继续使用TransactionAwareConnectionFactoryProxy 及其synchedLocalTransactionAllowed 到true。当然，直接从<int-jms:message-driven-channel-adapter> 使用DataSourceTransactionManager。

否则你必须使用ChainedTransactionManager。这个解决方案确实比第一个基于 TransactionAwareConnectionFactoryProxy 的解决方案增加了一些开销。