java - Guice 在多线程应用程序中注入(inject) EntityManager

Question

我正在使用 Java SE 7 开发桌面应用程序。该应用程序使用多个线程，并且在创建的每个线程中注入(inject)一个 DAO 类以获取对我的数据库的访问权限。作为持久层，我使用 EclipseLink 和 JPA。 EntityManager 是使用构造函数注入(inject)注入(inject)到我的 DAO 类中的，因为它不是线程安全的，所以我采用了这样的 Provder 方法:

public PluginInstanceJpaController implements IPluginInstanceDao {

    private EntityManager em;

    @Injected
    public PluginInstanceJpaController(Provider<EntityManager> emp) {
        this.em = emp.get();
    }

    @Transactional 
    public void create(PluginInstance foo) throws Exception {
        em.persist(foo);
    }
}

但是，相同的 EntityManager 实例被注入(inject)到每个 DAO 中。为了进行设置，我使用了 guice 提供的 JpaPersistModule，我确信到目前为止我的设置中没有单例。

有谁知道如何告诉 guice 在注入(inject)时创建 EntityManager 的新实例？

在另一种方法中，我尝试为 EntityManagerFactory 和 EntityManager 自定义提供程序，并将 JpaPersistModule 排除在我的业务之外。这导致每个 DAO 都有一个 EntityManager 实例，但是 @Transactional 注释的方法当时没有被拦截。

如果能解决此问题，我将不胜感激。到目前为止谢谢!

--- 编辑 ---

DAO 类被注入(inject)到使用它们的 Runnable 中。 Runnable 也是通过 Provider 提供的。我的模块配置看起来像这样:

public class RepositoryModule extends AbstractModule {

    @Override
    protected void configure() {

        // DAO bindings
        bind(IObjectStoreDao.class).to(ObjectStoreJpaController.class);
        bind(IPluginInstanceDao.class).to(PluginInstanceJpaController.class);
    }

    @Provides
    public PluginMonitor newMonitor(IPluginInstanceDao plugDao, IObjectStoreDao osDao) {
        PluginMonitor m = new PluginMonitor();
        m.setPluginInstanceDao(plugDao);
        m.setObjectStoreDao(osDao);
        return m;
    }
}

这里 PluginMonitor 是我的 Runnable。 Injector 本身是在我的主线程中创建的……这可能是问题所在吗？

Answer 1

这是一个非常相似的问题:How Guice injects singletons and non-singletons into multiple threads

对于您的 DAO，这应该可行。

public PluginInstanceJpaController implements IPluginInstanceDao {

    private Provider<EntityManager> emProvider;

    @Injected
    public PluginInstanceJpaController(Provider<EntityManager> emp) {
        this.em = emp;
    }

    @Transactional 
    public void create(PluginInstance foo) throws Exception {
        em.get().persist(foo);
    }
}

你应该使用 Jpa Persistence Module或创建自定义 EntityManager 提供程序，它将为每个 get() 调用返回新的 EntityManager，也可以使用 ThreadLocal 实现以确保 EntityManager 将跨线程共享。