标签：neo4j spring-data-neo4j-4 neo4j-ogm java
我正在编写一个指南服务应用程序,并且正在数字海洋飞沫上运行Neo3j 2.3.1的3个服务器集群.我还使用在Tomcat下运行的JSF Web应用程序中的Spring Data Neo4j 4.0.0.RELEASE来编写和查询我的数据.
我有一个与其他节点可能具有7种不同关系的节点,我已经成功保存了80个实例,但是当我尝试保存该节点时,突然突然开始在实例1主neo4j服务器上遇到内存不足错误.我将Neo4j服务器的内存设置更新为以下内容：
wrapper.java.initmemory=512
wrapper.java.maxmemory=1024
我不再遇到OutOfMemoryError,但是现在尝试保存节点时服务器出现故障.我可以在服务器无法正常运行之前查询数据.我从没在服务器1主数据/log/console.log文件中收到错误消息,但是在服务器2从属数据/log/console.log文件中却收到以下消息：
2015-12-31 15:42:00.405-0500 INFO Instance 1 is alive
2015-12-31 15:42:00.539-0500 INFO Instance 1 was elected as coordinator
2015-12-31 15:42:00.598-0500 INFO Instance 1 is available as master at ha://0.0.0.0:6001?serverId=1 with StoreId{creationTime=1447860597504, randomId=2820629596580485150, storeVersion=15250506225055238, upgradeTime=1447860597504, upgradeId=1}
2015-12-31 15:42:00.647-0500 INFO Instance 1 is available as backup at backup://127.0.0.1:6362 with StoreId{creationTime=1447860597504, randomId=2820629596580485150, storeVersion=15250506225055238, upgradeTime=1447860597504, upgradeId=1}
2015-12-31 15:42:11.652-0500 INFO Instance 1 has failed
节点实体Java代码：
public class OutfitterWaterfowlHunt extends WaterfowlHunt {
@Relationship(type="RUN_BY", direction=Relationship.OUTGOING)
private GuideService guideService;
@Relationship(type="GUIDED", direction=Relationship.INCOMING)
private List<Guide> fieldStaffHunter = new ArrayList<Guide>();
@Relationship(type="ASSIGNED_BY", direction=Relationship.OUTGOING)
private Guide fieldStaff;
public void addGuide(Guide guide)
{
this.fieldStaffHunter.add(guide);
}
public List<Guide> getFieldStaffHunter() {
return fieldStaffHunter;
}
public void setFieldStaffHunter(List<Guide> fieldStaffHunter) {
this.fieldStaffHunter = fieldStaffHunter;
}
public GuideService getGuideService() {
return guideService;
}
public void setGuideService(GuideService guideService) {
this.guideService = guideService;
}
public Guide getFieldStaff() {
return fieldStaff;
}
public void setFieldStaff(Guide fieldStaff) {
this.fieldStaff = fieldStaff;
}
}
public class WaterfowlHunt extends Excursion {
@Property(name="type")
private String type;
public String getType() {
return type;
}
public void setType(String type) {
this.type = type;
}
}
public class Excursion extends BaseEntity {
@Relationship(type="OCCURED_ON", direction=Relationship.OUTGOING)
private TookPlaceOn occuredOn;
@Relationship(type="OCCURED_AT", direction=Relationship.OUTGOING)
private ExcursionLocation excursionLocation;
@Relationship(type="PARTICIPATED_IN", direction=Relationship.INCOMING)
private HuntGroupRole participatedIn;
@Relationship(type="HARVESTED", direction=Relationship.OUTGOING)
private HuntInformation harvestInfo;
public TookPlaceOn occuredOn(Day day, Long timeIn, Long timeOut)
{
TookPlaceOn tpo = new TookPlaceOn();
tpo.setDayOfExcursion(day);
tpo.setExcursion(this);
tpo.setTimeIn(timeIn);
tpo.setTimeOut(timeOut);
this.occuredOn = tpo;
day.addOccuredOn(tpo);
return tpo;
}
public void occuredAt(ExcursionLocation huntLocation)
{
this.setExcursionLocation(huntLocation);
}
public void harvested(HuntInformation harvestInfo)
{
this.setHarvestInfo(harvestInfo);
}
public HuntGroupRole participatedIn(HuntGroup huntGroup, Integer nbrOfHunters)
{
HuntGroupRole hgr = new HuntGroupRole();
hgr.setHuntGroup(huntGroup);
hgr.setHuntingSpot(this);
hgr.setNumberOfHunters(nbrOfHunters);
this.participatedIn = hgr;
huntGroup.addParticipatedIn(hgr);
return hgr;
}
public HuntGroupRole getParticipatedIn() {
return participatedIn;
}
public void setParticipatedIn(HuntGroupRole participatedIn) {
this.participatedIn = participatedIn;
}
public TookPlaceOn getOccuredOn() {
return occuredOn;
}
public void setOccuredOn(TookPlaceOn occuredOn) {
this.occuredOn = occuredOn;
}
public ExcursionLocation getExcursionLocation() {
return excursionLocation;
}
public void setExcursionLocation(ExcursionLocation excursionLocation) {
this.excursionLocation = excursionLocation;
}
public HuntInformation getHarvestInfo() {
return harvestInfo;
}
public void setHarvestInfo(HuntInformation harvestInfo) {
this.harvestInfo = harvestInfo;
}
}
我用来保存的代码是通过SDN4 GraphRepository保存的：
@Transactional
public void saveHunt()
{
OutfitterWaterfowlHunt owh = new OutfitterWaterfowlHunt();
owh.setType("GuideTypeHere");
Day doh = this.determineDayOfHunt();
owh.occuredOn(doh, this.timeIn.getTime(), this.timeOut.getTime());
owh.participatedIn(this.huntGroup, this.nbrOfHunters);
GuideService gs = WDSSession.getInstance().getNeo4JController().retrieveGuideServiceByName("GuideServiceNameHere");
owh.setGuideService(gs);
owh.setFieldStaffHunter(this.selectedFSMembers);
owh.setFieldStaff(this.responsibleFieldStaffer);
owh.occuredAt(this.huntLocation);
HuntInformation hi = this.populateHuntInformation();
owh.setHarvestInfo(hi);
owh = WDSSession.getInstance().getNeo4JController().saveOutfitterWaterfowlHunt(owh);
StringBuffer msg = new StringBuffer();
msg.append("Successfully Saved Hunt ");
msg.append(" (");
msg.append(owh.getGraphId());
msg.append(").");
FacesContext.getCurrentInstance().addMessage(null, new FacesMessage(FacesMessage.SEVERITY_INFO, "Hunt Save Status", msg.toString()));
}
GraphRepository保存：
@Transactional
public OutfitterWaterfowlHunt saveOutfitterWaterfowlHunt(OutfitterWaterfowlHunt owh)
{
OutfitterWaterfowlHunt owHunt = this.outWtrFwlRepo.save(owh);
return owHunt;
}
保存该节点时,对导致服务器突然启动失败的原因有什么想法？我的Neo4j数据库中目前有19957个节点,其中大多数构成了DateTree.是否有比我目前更好的方法来保存节点？
TIA
解决方法:
此问题已在尚未发布的neo4j-ogm 2.0中修复.同时解决此问题的困难方法是先保存所有相关实体,然后再保存顶级实体,但是从您的模型来看,这并不容易.
标签：neo4j,spring-data-neo4j-4,neo4j-ogm,java 来源： https://codeday.me/bug/20191119/2034537.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。