后台线程抛出 HibernateException - “没有绑定到线程的 Hibernate 会话......”

Question

我需要创建一个进程来查询 Web 服务以提取信息，然后将数据保存在我的数据库中。但是，由于这个过程非常耗时，我想让它在后台运行。

目前，我有一个ProcessHandler，它由 UI 中的按钮调用。此处理程序创建一个Thread，它应该在后台运行该进程。但是，我收到了 HibernateException 和消息 No Hibernate Session bound to thread, and configuration does not allow creation of non-transactional one here。

我在一个配置xml文件（有几个）中定义了ProcessHandler，如下（这是一个非常通用的定义）：

<bean class="com.project.ProcessHandler" parent="parentHandler" />

在ProcessHandler内部，调用这个过程的代码也很通用：

Thread t = new Thread(new WorkerThread(alphaManager, bravoManager, charlieManager));
t.start();

这是WorkerThread的当前实现：

public class WorkerThread implements Runnable {

    private Manager alphaManager;
    private Manager bravoManager;
    private Manager charlieManager;

    public WorkerThread() {
        this.alphaManager = null;
        this.bravoManager = null;
        this.charlieManager= null;
    }

    public WorkerThread(Manager alphaManager, Manager bravoManager, Manager charlieManager) {
        this.alphaManager = alphaManager;
        this.bravoManager = bravoManager;
        this.charlieManager= charlieManager;
    }

    @Override
    public void run() {
        // code to query webservice and extract data...

        saveToDbMethod(data);
    }

    @Transactional(propagation = Propagation.REQUIRED)
    private void saveToDbMethod(String data) {
        // code to process data...

        alphaManager.save(entityA);
        bravoManager.save(entityB);
        charlieManager.save(entityC);
    }
}

默认构造函数是我尝试将 WorkerThread 定义为我的配置 xml 文件（之一）中的 bean 时留下的。

谁能帮我解决这个问题？

Answer 1

问题是您手动创建线程并期望它的行为类似于 spring 托管 bean。

由于ProcessHandler 是一个合法的bean，我要做的就是：

1) 创建一个独立的服务类，它将管理器作为依赖项和 @Transactional 方法：

@Service
public class Service{

    private Manager alphaManager;
    private Manager bravoManager;
    private Manager charlieManager;

    public Service(Manager alphaManager, Manager bravoManager, Manager charlieManager) {
        this.alphaManager = alphaManager;
        this.bravoManager = bravoManager;
        this.charlieManager= charlieManager;
    }

    @Transactional(propagation = Propagation.REQUIRED)
    private void saveToDbMethod(String data) {
        // code to process data...

        alphaManager.save(entityA);
        bravoManager.save(entityB);
        charlieManager.save(entityC);
    }
}

2)将Service注入ProcessHandler：

<bean class="com.project.ProcessHandler" parent="parentHandler">
   <property name="service" ref="service">
</bean>

3) 最后将Service 传递给WorkerThread：

public class WorkerThread implements Runnable {

    private Service service;

    public WorkerThread(Service service) {
        this.service = service;
    }

    @Override
    public void run() {
        // code to query webservice and extract data...

        service.saveToDbMethod(data);
    }
}

和：

Thread t = new Thread(new WorkerThread(service));
t.start();

现在您的操作应该是事务性的并且在会话内。