java.nio.channels.OverlappingFileLockException 在 Hibernate 搜索上
java.nio.channels.OverlappingFileLockException on Hibernate Search
我在我的项目中实现了非常基本的 Hibernate Search。下面是搜索方法：
public List<Patients> search (String givenName, String middleName, String email, String phoneNumber)
throws InterruptedException, AppException {
fullTextEntityManager = Search.getFullTextEntityManager(EntityManagerUtil.getEntityManager());
fullTextEntityManager.createIndexer().startAndWait();
QueryBuilder qb = fullTextEntityManager
.getSearchFactory()
.buildQueryBuilder()
.forEntity(Patients.class)
.overridesForField("givenName", "customanalyzer_query")
.overridesForField("middleName", "customanalyzer_query")
.overridesForField("email", "customanalyzer_query")
.overridesForField("phoneNumber", "customanalyzer_query")
.get();
org.apache.lucene.search.Query luceneQuery = qb.bool()
.must(qb.keyword().wildcard().onField("givenName").matching(givenName).createQuery())
.must(qb.keyword().wildcard().onField("middleName").matching(middleName).createQuery())
.must(qb.keyword().wildcard().onField("email").matching(email).createQuery())
.must(qb.keyword().wildcard().onField("phoneNumber").matching(phoneNumber).createQuery()).createQuery();
javax.persistence.Query jpaQuery =
fullTextEntityManager.createFullTextQuery(luceneQuery, Patients.class);
@SuppressWarnings("unchecked")
List<Patients> result = jpaQuery.getResultList();
return result;
}
我正在使用 Postgresql 从中读取数据。
这是第一次 运行，一切顺利。正在目录中创建索引，搜索完成。
然后我继续在数据库中添加一些条目。我添加后，我运行同样搜索。有时我会得到想要的结果，有时它不包括搜索中新添加的条目。我得到这个例外：
ERROR [Hibernate Search: Index updates queue processor for index com.healthelife.DGS.entity.Patients-1] (LuceneBackendQueueTask.java:73) - HSEARCH000073: Error in backend
java.nio.channels.OverlappingFileLockException
at sun.nio.ch.SharedFileLockTable.checkList(FileLockTable.java:255)
at sun.nio.ch.SharedFileLockTable.add(FileLockTable.java:152)
at sun.nio.ch.FileChannelImpl.tryLock(FileChannelImpl.java:1108)
at java.nio.channels.FileChannel.tryLock(FileChannel.java:1155)
at org.apache.lucene.store.NativeFSLock.obtain(NativeFSLockFactory.java:217)
at org.apache.lucene.store.Lock.obtain(Lock.java:72)
at org.apache.lucene.index.IndexWriter.<init>(IndexWriter.java:1098)
at org.hibernate.search.backend.impl.lucene.IndexWriterHolder.createNewIndexWriter(IndexWriterHolder.java:148)
at org.hibernate.search.backend.impl.lucene.IndexWriterHolder.getIndexWriter(IndexWriterHolder.java:115)
at org.hibernate.search.backend.impl.lucene.AbstractWorkspaceImpl.getIndexWriter(AbstractWorkspaceImpl.java:117)
at org.hibernate.search.backend.impl.lucene.LuceneBackendQueueTask.applyUpdates(LuceneBackendQueueTask.java:99)
at org.hibernate.search.backend.impl.lucene.LuceneBackendQueueTask.run(LuceneBackendQueueTask.java:67)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
ERROR [Hibernate Search: Index updates queue processor for index com.healthelife.DGS.entity.Patients-1] (LogErrorHandler.java:83) - HSEARCH000058: Exception occurred java.nio.channels.OverlappingFileLockException
Primary Failure:
Entity com.healthelife.DGS.entity.Patients Id null Work Type org.hibernate.search.backend.PurgeAllLuceneWork
我的实体class：
@Produces(MediaType.APPLICATION_JSON)
@XmlRootElement
@AnalyzerDef(name = "customanalyzer_query",
tokenizer = @TokenizerDef(factory = WhitespaceTokenizerFactory.class),
filters = {
@TokenFilterDef(factory = LowerCaseFilterFactory.class),
@TokenFilterDef(factory = SnowballPorterFilterFactory.class, params = { @Parameter(name = "language", value = "English")
})
})
@Analyzer(definition = "customanalyzer_query")
public class Patients implements Serializable {
private static final long serialVersionUID = -6061320465621019356L;
@Id
@GeneratedValue(strategy = GenerationType.AUTO)
@Column(name = "personId", nullable = false, unique = true)
private Long personId;
@Column(name = "prefix", nullable = true, unique = false)
private String prefix;
@Field(index=Index.YES, analyze=Analyze.YES, store=Store.NO, analyzer=@Analyzer(definition="customanalyzer_query"))
@Column(name = "givenName", nullable = true, unique = false)
private String givenName;
@Field(index=Index.YES, analyze=Analyze.YES, store=Store.NO, analyzer=@Analyzer(definition="customanalyzer_query"))
@Column(name = "middleName", nullable = true, unique = false)
private String middleName;
@OneToOne(cascade = CascadeType.ALL, fetch = FetchType.EAGER)
@JoinColumn(name = "gender", nullable = true)
private Gender gender;
@Column(name = "dateOfBirth", nullable = true, unique = false)
private String dateOfBirth;
@Column(name = "address1", nullable = true, unique = false)
private String address1;
@Column(name = "address2", nullable = true, unique = false)
private String address2;
@Column(name = "postalCode", nullable = true, unique = false)
private String postalCode;
@Field(index=Index.YES, analyze=Analyze.YES, store=Store.NO, analyzer=@Analyzer(definition="customanalyzer_query"))
@Column(name = "phoneNumber", nullable = true, unique = false)
private String phoneNumber;
@Column(name = "phoneExt", nullable = true, unique = false)
private String phoneExt;
@Field(index=Index.YES, analyze=Analyze.YES, store=Store.NO, analyzer=@Analyzer(definition="customanalyzer_query"))
@Column(name = "email", nullable = true, unique = false)
private String email;
@Column(name = "city", nullable = true, unique = false)
private String city;
@Column(name = "dateChanged", nullable = true, unique = false)
private String dateChanged;
@Column(name = "dateCreated", nullable = false, unique = false)
private String dateCreated;
@OneToOne(cascade = CascadeType.ALL, fetch = FetchType.EAGER, orphanRemoval=true)
@JoinColumn(name = "personIdentifiers", nullable = true)
private PersonIdentifiers personIdentifiers;
@Column(name = "profileImage", nullable = true, unique = false)
private String profileImage;
@Column(name = "nationality", nullable = true, unique = false)
private String nationality;
@OneToOne(cascade = CascadeType.ALL, fetch = FetchType.EAGER)
@JoinColumn(name = "visa", nullable = true)
private VisaDetails visa;
@OneToOne(cascade = CascadeType.ALL, fetch = FetchType.EAGER)
@JoinColumn(name = "emergencyContact", nullable = true)
private EmergencyContact emergencyContact;
@OneToMany(fetch = FetchType.EAGER, cascade= CascadeType.ALL)
private List<IDProof> idproof = new ArrayList<>();
//getters and setters....
}
您需要确保对于用于存储 Lucene 索引的给定路径，您没有多个 Hibernate Search 实例 运行。
这也意味着您必须确保任何 Hibernate 应用程序在关闭时正确停止；例如 Hibernate SessionFactory 需要关闭：
sessionFactory.close();
永远不要在一个副本还在的时候开始第二个副本运行：为了防止你犯这样的错误，锁会抛出你所看到的异常。
我在我的项目中实现了非常基本的 Hibernate Search。下面是搜索方法：
public List<Patients> search (String givenName, String middleName, String email, String phoneNumber)
throws InterruptedException, AppException {
fullTextEntityManager = Search.getFullTextEntityManager(EntityManagerUtil.getEntityManager());
fullTextEntityManager.createIndexer().startAndWait();
QueryBuilder qb = fullTextEntityManager
.getSearchFactory()
.buildQueryBuilder()
.forEntity(Patients.class)
.overridesForField("givenName", "customanalyzer_query")
.overridesForField("middleName", "customanalyzer_query")
.overridesForField("email", "customanalyzer_query")
.overridesForField("phoneNumber", "customanalyzer_query")
.get();
org.apache.lucene.search.Query luceneQuery = qb.bool()
.must(qb.keyword().wildcard().onField("givenName").matching(givenName).createQuery())
.must(qb.keyword().wildcard().onField("middleName").matching(middleName).createQuery())
.must(qb.keyword().wildcard().onField("email").matching(email).createQuery())
.must(qb.keyword().wildcard().onField("phoneNumber").matching(phoneNumber).createQuery()).createQuery();
javax.persistence.Query jpaQuery =
fullTextEntityManager.createFullTextQuery(luceneQuery, Patients.class);
@SuppressWarnings("unchecked")
List<Patients> result = jpaQuery.getResultList();
return result;
}
我正在使用 Postgresql 从中读取数据。
这是第一次 运行，一切顺利。正在目录中创建索引，搜索完成。
然后我继续在数据库中添加一些条目。我添加后，我运行同样搜索。有时我会得到想要的结果，有时它不包括搜索中新添加的条目。我得到这个例外：
ERROR [Hibernate Search: Index updates queue processor for index com.healthelife.DGS.entity.Patients-1] (LuceneBackendQueueTask.java:73) - HSEARCH000073: Error in backend
java.nio.channels.OverlappingFileLockException
at sun.nio.ch.SharedFileLockTable.checkList(FileLockTable.java:255)
at sun.nio.ch.SharedFileLockTable.add(FileLockTable.java:152)
at sun.nio.ch.FileChannelImpl.tryLock(FileChannelImpl.java:1108)
at java.nio.channels.FileChannel.tryLock(FileChannel.java:1155)
at org.apache.lucene.store.NativeFSLock.obtain(NativeFSLockFactory.java:217)
at org.apache.lucene.store.Lock.obtain(Lock.java:72)
at org.apache.lucene.index.IndexWriter.<init>(IndexWriter.java:1098)
at org.hibernate.search.backend.impl.lucene.IndexWriterHolder.createNewIndexWriter(IndexWriterHolder.java:148)
at org.hibernate.search.backend.impl.lucene.IndexWriterHolder.getIndexWriter(IndexWriterHolder.java:115)
at org.hibernate.search.backend.impl.lucene.AbstractWorkspaceImpl.getIndexWriter(AbstractWorkspaceImpl.java:117)
at org.hibernate.search.backend.impl.lucene.LuceneBackendQueueTask.applyUpdates(LuceneBackendQueueTask.java:99)
at org.hibernate.search.backend.impl.lucene.LuceneBackendQueueTask.run(LuceneBackendQueueTask.java:67)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
ERROR [Hibernate Search: Index updates queue processor for index com.healthelife.DGS.entity.Patients-1] (LogErrorHandler.java:83) - HSEARCH000058: Exception occurred java.nio.channels.OverlappingFileLockException
Primary Failure:
Entity com.healthelife.DGS.entity.Patients Id null Work Type org.hibernate.search.backend.PurgeAllLuceneWork
我的实体class：
@Produces(MediaType.APPLICATION_JSON)
@XmlRootElement
@AnalyzerDef(name = "customanalyzer_query",
tokenizer = @TokenizerDef(factory = WhitespaceTokenizerFactory.class),
filters = {
@TokenFilterDef(factory = LowerCaseFilterFactory.class),
@TokenFilterDef(factory = SnowballPorterFilterFactory.class, params = { @Parameter(name = "language", value = "English")
})
})
@Analyzer(definition = "customanalyzer_query")
public class Patients implements Serializable {
private static final long serialVersionUID = -6061320465621019356L;
@Id
@GeneratedValue(strategy = GenerationType.AUTO)
@Column(name = "personId", nullable = false, unique = true)
private Long personId;
@Column(name = "prefix", nullable = true, unique = false)
private String prefix;
@Field(index=Index.YES, analyze=Analyze.YES, store=Store.NO, analyzer=@Analyzer(definition="customanalyzer_query"))
@Column(name = "givenName", nullable = true, unique = false)
private String givenName;
@Field(index=Index.YES, analyze=Analyze.YES, store=Store.NO, analyzer=@Analyzer(definition="customanalyzer_query"))
@Column(name = "middleName", nullable = true, unique = false)
private String middleName;
@OneToOne(cascade = CascadeType.ALL, fetch = FetchType.EAGER)
@JoinColumn(name = "gender", nullable = true)
private Gender gender;
@Column(name = "dateOfBirth", nullable = true, unique = false)
private String dateOfBirth;
@Column(name = "address1", nullable = true, unique = false)
private String address1;
@Column(name = "address2", nullable = true, unique = false)
private String address2;
@Column(name = "postalCode", nullable = true, unique = false)
private String postalCode;
@Field(index=Index.YES, analyze=Analyze.YES, store=Store.NO, analyzer=@Analyzer(definition="customanalyzer_query"))
@Column(name = "phoneNumber", nullable = true, unique = false)
private String phoneNumber;
@Column(name = "phoneExt", nullable = true, unique = false)
private String phoneExt;
@Field(index=Index.YES, analyze=Analyze.YES, store=Store.NO, analyzer=@Analyzer(definition="customanalyzer_query"))
@Column(name = "email", nullable = true, unique = false)
private String email;
@Column(name = "city", nullable = true, unique = false)
private String city;
@Column(name = "dateChanged", nullable = true, unique = false)
private String dateChanged;
@Column(name = "dateCreated", nullable = false, unique = false)
private String dateCreated;
@OneToOne(cascade = CascadeType.ALL, fetch = FetchType.EAGER, orphanRemoval=true)
@JoinColumn(name = "personIdentifiers", nullable = true)
private PersonIdentifiers personIdentifiers;
@Column(name = "profileImage", nullable = true, unique = false)
private String profileImage;
@Column(name = "nationality", nullable = true, unique = false)
private String nationality;
@OneToOne(cascade = CascadeType.ALL, fetch = FetchType.EAGER)
@JoinColumn(name = "visa", nullable = true)
private VisaDetails visa;
@OneToOne(cascade = CascadeType.ALL, fetch = FetchType.EAGER)
@JoinColumn(name = "emergencyContact", nullable = true)
private EmergencyContact emergencyContact;
@OneToMany(fetch = FetchType.EAGER, cascade= CascadeType.ALL)
private List<IDProof> idproof = new ArrayList<>();
//getters and setters....
}
您需要确保对于用于存储 Lucene 索引的给定路径，您没有多个 Hibernate Search 实例 运行。
这也意味着您必须确保任何 Hibernate 应用程序在关闭时正确停止；例如 Hibernate SessionFactory 需要关闭：
sessionFactory.close();
永远不要在一个副本还在的时候开始第二个副本运行：为了防止你犯这样的错误，锁会抛出你所看到的异常。