Dropwizard+Hibernate使用ThreadPoolExecutor出现No session绑定上下文错误

Dropwizard 的 @UnitOfWork 注解依赖 AOP 切面实现 Hibernate 会话绑定，仅对容器管理的 Bean 生效。你自己手动实例化的 CallbackTask 属于非容器托管对象，注解不会被切面拦截，加上子线程默认不会继承父线程的 Hibernate Session，所以会报没有绑定会话的错误。另外你在 run 方法上加的 @Transactional 注解也不适用 Dropwizard Hibernate 场景，原生 Dropwizard 用 @UnitOfWork 统一管理会话和事务生命周期。

方案1：使用官方提供的UnitOfWork代理工厂（推荐） #

Dropwizard 自带 UnitOfWorkAwareProxyFactory 工具类，专门用于给异步任务创建代理，让自定义 Runnable/Callable 的 @UnitOfWork 注解生效：

1. 首先在你提交异步任务的容器托管类（比如资源类、Service类）中注入 UnitOfWorkAwareProxyFactory 和线程池实例
2. 创建 CallbackTask 实例后，通过代理工厂生成带 UnitOfWork 能力的代理对象，再提交到线程池：

// 注入实例
@Inject
private UnitOfWorkAwareProxyFactory proxyFactory;
@Inject
private ExecutorService asyncThreadPool;

// 提交任务的逻辑
CallbackTask realTask = new CallbackTask(baseSnapshot, processorResponse, job, esDao, orchestratorJobService, snapshot, restoreHelper, indexName);
Runnable proxyTask = proxyFactory.create(Runnable.class, realTask);
asyncThreadPool.submit(proxyTask);

3. 修改你的 CallbackTask 的 run 方法注解，把 @Transactional 换成 @UnitOfWork：

@Override
@UnitOfWork
public void run() {
    // 原有业务逻辑保持不变
}

方案2：手动绑定会话（适合不想改线程提交逻辑的场景） #

直接在 run 方法中手动打开 Session 并绑定到当前线程上下文，自行管理事务生命周期：
首先需要给 CallbackTask 增加 SessionFactory 构造参数，然后修改 run 方法逻辑：

@Override
public void run() {
    Session session = sessionFactory.openSession();
    Transaction transaction = null;
    try {
        // 绑定会话到当前线程
        ManagedSessionContext.bind(session);
        transaction = session.beginTransaction();

        // 原有业务逻辑不变
        int retryCount = job.getRetrialCount()==null ? 0: job.getRetrialCount();
        if(retryCount< JOB_RETRY_COUNT){
            job.setRetrialCount(++retryCount);
        }else{
            snapshot.setSoftDelete(true);
        }
        orchestratorJobService.persistData(job, snapshot);

        // 提交事务
        transaction.commit();
    } catch (Exception e) {
        // 异常回滚
        if (transaction != null && transaction.isActive()) {
            transaction.rollback();
        }
        throw new RuntimeException("异步任务执行失败", e);
    } finally {
        // 解绑会话，避免内存泄漏
        ManagedSessionContext.unbind(sessionFactory);
        if (session.isOpen()) {
            session.close();
        }
    }
}

内容的提问来源于stack exchange，提问作者user8830835