在使用Executor服务创建的线程中使用声明性事务

Question

我有一个服务层类，它有annotation@Controller和我在线程中生成的服务调用，它正在更新数据库中的某些内容。我在thread的方法中使用了@transaction注释。但我遇到了hibernate异常“找不到会话”。我需要为线程添加任何注释吗？

lient.runHibernateException：在lient.java:222没有找到当前线程的Session 4. SpringSessionCjava.util.concurrent.会话（SpringSessionCdapter.call）在xecutors.java:471SessionFactoryIjava.util.concurrent.货币会话（SessionFactoryIync.inner）在ask.java:334BaseRjava.util.concurrent.货币会话（BaseRask.run）在ask.java:166AgencyRjava.util.concurrent.ById（AgencyRxecutor.run）在com.mediaiq.mail.client.AgencyLookupReportByDayClient.emailAgencyLookupConfirming（AgencyLookupReportByDayClient.java:84）在com.mediaiq.mail.client.AgencyLookupReportByDayClient.sendemailreport（AgencyLookupReportByDayClient.java:67）在com.mediaiq.mail.client.BaseMailCorg.hibernate.（BaseMailCorg.springframework.orm.hibernate）在ontext.currentExectors$RunnableAontext.java:97（Eorg.hibernate.internal.）在mpl.getFutureTask$Smpl.java:978运行（FutureTcom.mediaiq.commons.persistence.）在epository.getFutureTepository.java:30（FutureTcom.mediaiq.cms.persistence.）在epository.getThreadPoolEepository.java:20工作者（ThreadPoolExector. java： 1145）在java. util. concurrent. ThreadPoolExecececle

@Repository
public class BaseMailClient implements Runnable {

    public BaseMailClient() {

    }

    public BaseMailClient(PlacementsRepository placementsRepository, SessionFactory sessionFactory, String sessionID) {
    this.placementsRepository = placementsRepository;
    this.sessionFactory = sessionFactory;
    this.sessionID = sessionID;
    }

    public BaseMailClient(AgencyRepository agencyRepository, SessionFactory sessionFactory, String sessionID) {

    this.agencyRepository = agencyRepository;
    this.sessionFactory = sessionFactory;
    this.sessionID = sessionID;
    }

    private String      sessionID        = null;

    @Autowired
    private SessionFactory  sessionFactory;


    @Autowired
    private PlacementsRepository  placementsRepository;
    @Autowired
    private AgencyRepository      agencyRepository;



    final static Logger    logger          =LoggerFactory.getLogger(BaseMailClient.class);



    @Override
    public void run()
    {

        sendemailreport();

    }

@Transactional
    public void sendemailreport()
    {
        checkSessionID();
        try {
        emailAgencyLookupConfirmation();
        emailAgencyLookup();
        }
        catch (IOException | FailedToCreateTempFile e) {
        logger.info("Failed To mail due to exception :" + e.getMessage());
        }
        catch (Throwable e) {
        logger.info("Failed To mail due to exception :" + e.getMessage());
        }
    }

}

服务等级：

@Transactional
@Controller
@RequestMapping(URLEndPoints.EMAIL)
public class SendMailService {

    @Autowired
    PlacementsRepository       placementsRepository;
    @Autowired
    AgencyRepository       agencyRepository;
    /**
     * 
     */
    @Autowired
    private SessionFactory   sessionFactory;

    @Autowired
    private ThreadPoolTaskExecutor mailJobExecutor;

    final static Logger     logger = LoggerFactory.getLogger(SendMailService.class);
 @RequestMapping(method = RequestMethod.POST, value = URLEndPoints.EMAIL_AGENCY_LOOKUP_BY_DAY, produces = "application/json")
    @ResponseBody
    public String emailAgencyLookupByDay(ServletRequest request,@PathVariable("agencyID") Integer agencyID,
              @PathVariable("startDate") @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) Date startDate,
              @PathVariable("endDate") @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) Date endDate )
    {
        logger.debug("POST:SendEmail:AgencyLookup");
        String sessionId = getSessionIDFromCookie(request);
        BaseClient mailServiceClient = new BaseClient(getAgencyRepository(), getSessionFactory(), sessionId);
        logger.debug("Getting Executor Instance");
        mailJobExecutor.submit(mailServiceClient);
        logger.debug("Submitted to Executor");
        return "SUCCESS";
    }
}

Answer 1

在Spring之外创建的线程不会附加hibernate会话。您需要手动将新的hibernate会话附加到线程；

Session session = SessionFactoryUtils.openSession(sessionFactory);
try
{
    TransactionSynchronizationManager.bindResource(sessionFactory, new SessionHolder(session));
}
catch(Exception e)
{
    Logger.debug("Session already bound");
}

（需要注入sessionFactory）。

确保线程结束前会话已解除绑定；

public static void closeSession(Session se)
{
    try
    {
        try
        {
            TransactionSynchronizationManager.unbindResource(sessionFactory);
        }
        finally
        {
            if (se != null && se.isOpen() && se.isConnected())
            {
                SessionFactoryUtils.closeSession(se);
            }
        }
    }
    catch (HibernateException e)
    {
        Logger.fatal("Could not close session", e);
    }
}

Answer 2

这里有几件事不对劲。

首先，您自己创建BaseClient对象，因此Spring无法添加@Transactional行为。

BaseClient mailServiceClient = new BaseClient(getAgencyRepository(), getSessionFactory(), sessionId);

相反，您应该让Spring为您创建这种类型的bean。使用原型范围。

其次，您需要仔细阅读Spring留档中关于Spring代理机制的此条目。不幸的是，当从同一类内的非事务性方法调用@Transactional方法时，您不能期望任何事务性行为，这就是您在这里所做的

@Override
public void run()
{
    sendemailreport();
}

@Transactional
public void sendemailreport()
{

sendmailreport在此引用上调用，该引用是对象本身，而不是代理。因此，它不会有任何事务行为。

考虑在异步执行的同时查看@Async注释。