java - Hibernate:在不同线程中查找刚刚持久化的对象

Question

我的应用程序中有多个线程 - 其中一个线程正在等待数据库中某些更改的通知。我的问题是，一旦我持久化一些对象并通知另一个线程 - 当它在数据库中查询自上次更改以来的新对象时，找不到持久化的对象。

  @Transactional()
  public void persistMyEntity() {
      // persisting and notifying from first thread
      Entity myEntity = new Entity();
      em.persist(myEntity)
      em.flush();
      someOtherBean.notifyChange();
  }
  ...

应唤醒以下 bean:

  public class SomeOtherBean {

      public void notifyChange() {
          currentThread.interrupt();
      }


      public void run() {
          currentThread = Thread.currentThread();

          while(true) {
              ...
              try {
                  Thread.sleep(VERY_LONG_TIME);
              } catch (InterrupedExcdeption e) {
                  // we don't care
              }

              findNewPersistedObjects();
              // nothing is found
          }
      }
  }

如果我重新启动线程，它会正确找到新对象。

编辑:拆分事务方法没有任何区别:

  public void persistMyEntity() {
      proxy(this).persistMyEntityInternal();
      someOtherBean.notifyChange();
  }

  @Transactional
  public void persistMyEntityInternal() {
      // persisting and notifying from first thread
      Entity myEntity = new Entity();
      em.persist(myEntity)
      em.flush();
  }
  ...

Answer 1

你的问题是事务划分。

您在事务完成之前通知其他线程。数据库中的数据只能在创建数据的事务结束(通过提交)时才能查询(某些数据库有一些异常(exception)，但我不会深入讨论这一点)。

要解决您的问题，您必须在从另一个线程查询事务之前提交事务。