多线程应用中的Guice注入EntityManager

Question

我正在使用JavaSE7开发一个桌面应用程序。应用程序使用多个线程，在创建的每个线程中，都会注入一个DAO类来访问我的数据库。作为持久层，我使用EclipseLink和JPA。EntityManager是使用构造函数注入注入注入到我的DAO类中的，因为它不是线程安全的，所以我使用了如下验证程序：

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实例被注入到每个DAO中。为了进行设置，我使用了由guice提供的JpaPersistModule，我确信到目前为止，我的设置中没有单例。

有人知道如何告诉guice在注入时创建EntityManager的新实例吗？

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

如果能解决这个问题，我将不胜感激。非常感谢！

---编辑---

DAO类被注入到正在使用它们的Runnable中。Runnable也通过提供者提供。我的模块配置如下所示：

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。注射器本身是在我的主线程中创建的。。。这可能就是问题所在吗？

Answer 1

我对JPA不太熟悉，但希望我仍能帮上忙：-）

如果您查看EntityManagerProvider的源代码，您可以看到有一个ThreadLocal

此外，您可以将构造函数编写为：

@Inject
public FooDao(EntityManager emp) {
    this.em = emp;
}

Guice将为您发挥神奇的作用，确定EntityManager Provider提供了EntityManager实例，并将调用EntityManager Provider实例上的get（），以获得一个EntityManager提供给您的构造函数。

Answer 2

这是一个非常相似的问题：Guice如何将单例和非单例注入多个线程

对你的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持久性模块或创建自定义EntityManager提供程序，它将为每个get（）调用返回新的EntityManager，还可以使用ThreadLocal实现，以确保EntityManager在线程之间共享。