java - 交易在 Jetty 中不及时持久化

Question

我继承了一些代码，在尝试添加某些功能时，这些代码无法正常工作。我不是 Java web 方面的专家，所以如果我需要任何额外的帮助来为您提供所需的信息，我提前表示歉意。

我正在开发一个 GWT 应用程序，它在后端使用 Hibernate 和 Guice-Persist 来持久化到 MySQL。不幸的是，我遇到了一个奇怪的问题——在一台服务器上——put 事务没有及时保存到数据库中，无法被后续的 get 识别交易。 在 Windows 中嵌入了 GWT Eclipse 插件(可能是 6.1.11？)的任何版本的 Jetty 和 Linux 中的 Tomcat6 中，一切都完美运行，但是当我尝试在 Linux 中使用 jetty-maven- plugin 版本 8.1.0(也在 8.1.5 中，我尝试过的唯一两个版本)，我遇到了交易未完成的问题(或者，我会很高兴有一个解决方案，它只允许我使用 Jetty 以外的东西在 Maven 中正确运行我的集成测试，以一起回避这个问题。看起来代码确实可以在我尝试过的所有其他服务器上下文)。

这是我用来持久化对象的代码:

public T put(T entity) {
    EntityManager entityManager = entityManager();
    EntityTransaction transaction = entityManager.getTransaction();        
    transaction.begin();
    try {
        entity = entityManager.merge(entity);
        entityManager.persist(entity);
        transaction.commit();

    } catch (Exception e) {
        //do exception handling, including rollback
    }


    return entity;
}

获取代码:

public List<T> getAll() {
    Query query = entityManager().createQuery("select c from " + clazz.getSimpleName() + " c");

    return (List<T>) query.getResultList();
}

同样，发生的事情是我对 getAll() 进行(间接)调用以允许客户端查看数据。然后，如果他们做出选择，则从客户端进行 put 调用。然后，一旦我收到响应，就调用 getAll() 来更新显示给用户的数据。不幸的是，我从数据库中取回的数据并没有反射(reflect)更新后的数据，而是反射(reflect)了 put() 调用之前存在的数据。数据库最终确实会更新，当我自己检查数据库时，它似乎是即时更新的。如果我重新加载数据几次，Web 应用程序最终也会更新以显示正确的数据。所以我怀疑某些缓存层可能会在没有实际检查数据库的情况下响应我的 getAll() 请求，但我真的不确定如何继续 - Transactions 和 EntityManagers 对我来说是相当新的.

我已经尝试 flush()ing 和 close()ing 我的实体管理器而不是提交我的事务并且没有任何行为变化。

我在构造函数中注入(inject)我的 EntityManager Provider:

private final Class<T> clazz;
private final Provider<EntityManager> entityManagerProvider;

public BaseDao(final Class<T> clazz, final Provider<EntityManager> entityManagerProvider) {
    this.clazz = clazz;
    this.entityManagerProvider = entityManagerProvider;
}

并像这样获得一个实体管理器:

protected EntityManager entityManager() {
    return entityManagerProvider.get();
}

谢谢!

为了后代，这是我的 GuiceServletContextListener:

public class GuiceServletConfig extends GuiceServletContextListener {
@Override
protected Injector getInjector() {
    DispatchServletModule dispatchServletModule = new DispatchServletModule();
    Injector injector = Guice.createInjector(new ServerModule(), new JpaPersistModule(getPersistenceUnit()),
            dispatchServletModule);

    PersistService persistService = injector.getInstance(PersistService.class);
    persistService.start();

    BootStrapper bootStrapper = injector.getInstance(BootStrapper.class);
    bootStrapper.init();



    return injector;
}

private String getPersistenceUnit() {
    InputStream inputStream = getClass().getResourceAsStream("/database.properties");

    if (inputStream == null) {
        throw new RuntimeException();
    }

    try {
        Properties properties = new Properties();
        properties.load(inputStream);

        return properties.getProperty("persistenceUnit");
    } catch (IOException e) {
        throw new RuntimeException(e);
    }
}


}

还有我的 ServletModule:

public class DispatchServletModule extends ServletModule {      
  @Override
  public void configureServlets() {
    serve("/" + ActionImpl.DEFAULT_SERVICE_NAME + "*").with(DispatchServiceImpl.class);
  }
}

我尝试在 configureServlets() 中添加一个过滤器，而不是手动启动持久性 session ，以尝试使用 session-per-http-request(根据 this page)，但没有成功。

Answer 1

首先，您可能应该回滚 catch block 中的事务，而不是忽略异常(至少记录它)。但是 guice-persist 支持 @Transactional 注释，所以实际上您根本不需要进行手动事务管理。参见 Transactions - google-guice .