解决Lucene的多线程并发问题

创建IndexWriter的方式：

public class HelloWorld_2 {
@Test
public void createIndex() throws Exception {
Directory directory = FSDirectory.open(new File("./indexDir/"));
Analyzer analyzer = new StandardAnalyzer(Version.LUCENE_36);
IndexWriterConfig indexWriterCOnfig= new
IndexWriterConfig(Version.LUCENE_36,analyzer);
IndexWriter indexWriter = new IndexWriter(directory,indexWriterConfig);
}
}

在Lucene程序中，成功以上面的方式创建IndexWriter对象以后，会在索引库中出现一个锁文件，这个锁文件是当前这个IndexWriter的锁，如果调用indexWriter.close()关闭了链接，则将会把这个锁文件删除，也就是说，它释放了锁。释放以后，第二个IndexWriter再开启是没有问题的。如果不关闭，同时开了两个或以上的IndexWriter，会抛出一个异常。导致程序终止。

解决方案就是：通过某种方法保证IndexWriter对象只创建一个。

出现的锁文件：

当调用IndexWriter的close方法后，这个锁文件就消失了。

1，多线程并发问题模拟

下面程序开启了两个IndexWriter，都没有关闭，执行结果抛出异常：

org.apache.lucene.store.LockObtainFailedException:Lock obtain timed out:NativeFSLock@D:\itcast2\lucene\indexDir\write.lock

public class MultiThreadTest {
@Test
public void test() throws Exception {
//创建索引配置。
IndexWriterConfig indexWriterConfig1 = new IndexWriterConfig(Version.LUCENE_36, DirAnaUtil.getAnalyzer());
IndexWriter indexWriter1 = new IndexWriter(DirAnaUtil.getDirectory(), indexWriterConfig1);
// indexWriter1.close();

//创建第二个，模拟并发问题。
IndexWriterConfig indexWriterConfig2 = new IndexWriterConfig(Version.LUCENE_36, DirAnaUtil.getAnalyzer());
IndexWriter indexWriter2 = new IndexWriter(DirAnaUtil.getDirectory(), indexWriterConfig2);
// indexWriter2.close();
}
}

造成错误的原因是：indexWriter1创建成功后，持有一个锁，这时还没有关闭indexWriter1，indexWriter2也要来拿这个锁，而现在这个锁被indexWriter1持有，indexWriter2无法获取，所以异常。

/**
* 获取唯一的IndexWriter对象
* 原理：通过静态代码块static{}在类的生命周期中只加载一次的特点，完成唯一的对象的创建
* @author 许智敏
*/
public class LuceneUtils {
private static IndexWriter indexWriter;
static {
try {
IndexWriterConfig indexWriterCOnfig= new IndexWriterConfig(Version.LUCENE_36, DirAnaUtil.getAnalyzer());
indexWriter = new IndexWriter(DirAnaUtil.getDirectory(), indexWriterConfig);
} catch (Exception e) {
e.printStackTrace();
}
/**当当前线程结束时，自动关闭IndexWriter，使用Runtime对象*/
Runtime.getRuntime().addShutdownHook(new Thread(){
@Override
public void run() {
try {
closeIndexWriter();
} catch (Exception e) {
e.printStackTrace();
}
}
});
}
/**在线程结束时，自动关闭IndexWriter*/
public static IndexWriter getIndexWriter() {
return indexWriter;
}
/**关闭IndexWriter
* @throws IOException
* @throws CorruptIndexException */
public static void closeIndexWriter() throws Exception {
if(indexWriter != null) {
indexWriter.close();
}
}
}

然后我们通过这个工具类获取IndexWriter对象，就没有问题了。

public class MultiThreadTest {
@Test
public void test() throws Exception {
IndexWriter indexWriter1 = LuceneUtils.getIndexWriter();
System.out.println(indexWriter1);
IndexWriter indexWriter2 = LuceneUtils.getIndexWriter();
System.out.println(indexWriter2);
}
}

可在控制台看到，这两个对象是一样的。

至于IndexSearcher，它是从索引库中获取数据的，不涉及对索引库中内容的增删改，所以IndexSearcher没有并发问题。