eh使用Spring@Transactional缓存本地事务

Question

我正在尝试使用Spring@cacheable和@transactional来设置一个事务性的ehcache。

我的缓存与@cacheable一起工作很好，但一旦我将缓存设置为使用本地事务：

<cache name="currencyCodeMaps" maxElementsInMemory="100" overflowToDisk="false" timeToIdleSeconds="5" timeToLiveSeconds="600" memoryStoreEvictionPolicy="LRU" transactionalMode="local"/>

net.sf.ehcache.transaction.TransactionException: transaction not started

org.springframework.orm.jpa.JpaTransactionManager

但这将很难，因为我想要将ehcache事务与DB事务同步，而DB事务是由@Transactional控制的。

有没有办法让本地Ehcache事务与Spring@Transactional一起工作？

Answer 1

是的，有一种方法可以达到你的目标。

>

因为您有2个事务资源（JTA和Ehcache）并且不使用JTA，所以必须使用复合事务管理器，如来自spring-data项目的org.SpringFramework.Data.transaction.ChainedTransactionManager

@Bean
public PlatformTransactionManager transactionManager() {
    return new ChainedTransactionManager(ehcacheTransactionManager(), jpaTransactionManager());
}

@Bean
public EhcacheTransactionManager ehcacheTransactionManager() {
    return new EhcacheTransactionManager(ehcacheManager().getTransactionController());
}

@Bean
public PlatformTransactionManager jpaTransactionManager() {
    return new JpaTransactionManager(entityManagerFactory());
}

您需要指定默认情况下应使用哪个事务管理器：

@Configuration
public class Configuration implements TransactionManagementConfigurer {
...
    @Override
    public PlatformTransactionManager annotationDrivenTransactionManager() {
        return transactionManager();
    }
...
}

import net.sf.ehcache.TransactionController;
import net.sf.ehcache.transaction.local.LocalTransactionContext;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionException;
import org.springframework.transaction.support.AbstractPlatformTransactionManager;
import org.springframework.transaction.support.DefaultTransactionStatus;

    public class EhcacheTransactionManager extends AbstractPlatformTransactionManager {

    private TransactionController transactionController;

    public EhcacheTransactionManager(TransactionController transactionController) {
        this.transactionController = transactionController;
    }

    @Override
    protected Object doGetTransaction() throws TransactionException {
        return new EhcacheTransactionObject(transactionController.getCurrentTransactionContext());
    }

    @Override
    protected void doBegin(Object o, TransactionDefinition transactionDefinition) throws TransactionException {
        int timeout = transactionDefinition.getTimeout();
        if (timeout != TransactionDefinition.TIMEOUT_DEFAULT) {
            transactionController.begin(timeout);
        } else {
            transactionController.begin();
        }
    }

    @Override
    protected void doCommit(DefaultTransactionStatus defaultTransactionStatus) throws TransactionException {
        transactionController.commit();
    }

    @Override
    protected void doRollback(DefaultTransactionStatus defaultTransactionStatus) throws TransactionException {
        transactionController.rollback();
    }

    public class EhcacheTransactionObject {

        private LocalTransactionContext currentTransactionContext;

        public EhcacheTransactionObject(LocalTransactionContext currentTransactionContext) {
            this.currentTransactionContext = currentTransactionContext;
        }

    }

}

null

这对我来说是个问题，所以我用不同的方式实现了这个功能。检查“me.qnox.springframework.cache.tx.txawareCacheManagerProxy”，上面描述的问题已经解决，在同一个存储库中