0

我正在保留一个包含与其他几个实体的关系的节点实体。当我一次做一个时，这种持久性很好，但是如果我同时运行它，我会在 org.neo4j.ogm.mapper.EntityGraphMapper 获得 NPE

java.lang.NullPointerException: null
at org.neo4j.ogm.mapper.EntityGraphMapper.updateRelationship(EntityGraphMapper.java:618) ~[neo4j-ogm-1.1.2.jar:na]
at org.neo4j.ogm.mapper.EntityGraphMapper.mapRelationshipEntity(EntityGraphMapper.java:481) ~[neo4j-ogm-1.1.2.jar:na]
at org.neo4j.ogm.mapper.EntityGraphMapper.link(EntityGraphMapper.java:330) ~[neo4j-ogm-1.1.2.jar:na]
at org.neo4j.ogm.mapper.EntityGraphMapper.mapEntityReferences(EntityGraphMapper.java:265) ~[neo4j-ogm-1.1.2.jar:na]
at org.neo4j.ogm.mapper.EntityGraphMapper.mapEntity(EntityGraphMapper.java:158) ~[neo4j-ogm-1.1.2.jar:na]

这是我的节点实体的症结所在：

@NodeEntity
public class Post {
   @Relationship(type = "POST_BY_USER", direction = Relationship.INCOMING)
   User poster;

   @Relationship(type = "POST_TO_STORE", direction = Relationship.OUTGOING)
   Store toStore;

   @Relationship(type = "POST_PRODUCT", direction = Relationship.INCOMING)
  Product product;

  @Relationship(type = "POST_INSPIRATION", direction = Relationship.INCOMING)
  Product_Inspiration productInspiration;
}

我尝试同时使用带有 (@Transactional) 的 GraphRepository 以及使用带有事务的会话，在这两种情况下，我都遇到了同样的并发问题。

有人可以让我知道如何解决这个问题吗？由于我在轰炸并发请求时遇到了这个问题，所以我不确定这是否与代码流本身有关。

根据 Vince 关于如何发送并发请求的代码的要求，我正在使用带有 Play 的 axon cqrs 框架，并向我的 Play 应用程序的 rest API 发送多个并发请求，该 API 通过 axon 通过 postProduct 方法调用对 Neo4j 的并发写入。这是我编写代码的样子。

   def postProduct(productId: ProductId, product2Post: Product2Post):     Post = workNLogOnFail(
  doPost(productId, product2Post),
  "postProduct"
  )

  private def doPost(productId: ProductId, product2Post: Product2Post): Post = {
  val product: Product = configureDomainEntity(productId, product2Post)
  val storeId: StoreId = storeService1.findOrCreateStore(product2Post.host)
  val post: Post = commonService.configurePost(product2Post.commonData2Post.relationInfo, isProduct = true) { (x: Post) =>
  x.setToStore(storeService1.updateStoreForProductPost(x, storeId))
  x.setProduct(product)
}
val persistedPost = xtPostProduct(product, post)
commonService.addUrlMapping(product2Post.commonData2Post, productId.identifier)
persistedPost
}
private def xtPostProduct(product: Product, post: Post): Post = {
Try {
  val tx: Transaction = session.beginTransaction()
  logger.debug(s"saving product")
  //      session.save(product)
  logger.debug(s"updating user")
  //      session.save(post.getPoster)
  logger.debug(s"posting product")
  session.save(post)
  tx.commit()
  post
  }.get
  }

我在 xtPostProduct 方法中尝试了 @Transanctional 和 GraphRepository 以及会话。

4

1 回答 1

0

弄清楚了。问题是由于 spring DI 接线，我的会话或存储库使用的会话不是每个工作单元。由于我通过 Axon 调用数据库操作，因此使用具有“会话”范围的会话 Bean 的正常方式将不起作用。我已恢复为我需要处理的每个轴突事件手动创建会话。因为基本上对我来说，那是我的工作单位！

于 2015-09-17T12:49:55.167 回答