個人的部落格小站也搭建成功，網址：www.llwjy.com ，歡迎大家來吐槽~

基本原理

      在前面的部落格中也說過，程式初始話索引檔案是十分消耗系統資源的，因此要想實現實時索引就不能實時的去修改索引檔案、重新載入索引檔案，就必須考慮如何使用記憶體來實現這實時索引；在Lucene4.3.1版本（之前的版本也有，但是在後面的版本中就將NRT*相關的類刪除了）中NRT*相關類就提供了建立實時索引（偽實時索引）的相關方法，將IndexWrite的相關操作委託給TrackingIndexWriter來處理，實現了記憶體索引和硬碟索引的結合，通過NRTManager為外部提供可用的索引，當然，在執行commit（之前

建立索引中有相關介紹）操作之前，操作的資料都是存在記憶體中，一旦宕機或者服務重，這些資料都將丟失，因此就需要自己新增一個守護執行緒去不斷的執行commit操作（commit操作十分消耗系統資源，索引不可能每一次修改都去執行該操作）。下面就通過幾個簡單的圖來介紹一下實時索引的實現原理：

      在系統剛啟動時候，存在兩個索引：記憶體索引、硬碟索引，當然此時記憶體索引中是沒有任何資料的，結構如下圖所示：

      在系統執行過程中，一旦有索引的增加、刪除、修改等操作，這些操作都是操作記憶體索引，而不是硬碟索引，如下圖所示：

      當程式主動執行commit操作時，這是會將記憶體索引複製一份，我們稱之為合併索引，同時將記憶體索引清空，用於之後的索引操作，此時系統中就存在記憶體索引、合併索引、硬碟索引，在想外提供服務的同時，也會將合併索引中的資料寫入硬碟，如下圖所示：

      當合並索引中的資料已經全部寫入硬碟之後，程式會對硬碟索引重讀，形成新的IndexReader，在新的硬碟IndexReader替換舊的硬碟IndexReader時，刪除合併索引的IndexReader，這樣系統又重新回到最初的狀態（當然此時記憶體索引中可能會有資料），如下圖所示：

      如此反覆，一個實時索引的系統也就算完成了，當然這裡也會有一定的風險，就是在宕機時可能會丟失一部分的資料。關於這個問題，如果資料準確度要求不是太高的話可以忽略，畢竟這種情況發生的概率太小了；如果對資料的準確度要求特別高的話，可以通過新增輸出日誌來完成。

      ps：Lucene內部的實現邏輯比上面複雜的多，這裡只是簡單的介紹一下實現原理，如要深入瞭解，還請詳細閱讀相關書籍、原始碼。

配置類

      在這篇部落格中就先把這個系列的實時索引的配置類介紹以下，後面就不再介紹了。

ConfigBean

      ConfigBean類中，定義了一些索引的基本屬性，如：索引名、硬碟儲存位置、採用的分詞器、commit操作執行頻率、記憶體索引重讀頻率等，具體程式碼如下：

/**  
 *@Description:  索引基礎配置屬性
 */
package com.lulei.lucene.index.model;

import org.apache.lucene.analysis.Analyzer;
import org.apache.lucene.analysis.standard.StandardAnalyzer;
import org.apache.lucene.util.Version;

public class ConfigBean {
	// 分詞器
	private Analyzer analyzer = new StandardAnalyzer(Version.LUCENE_43);
	// 索引地址
	private String indexPath = "/index/";
	private double indexReopenMaxStaleSec = 10;
	private double indexReopenMinStaleSec = 0.025;
	// 索引commit時間
	private int indexCommitSeconds = 60;
	// 索引名稱
	private String indexName = "index";
	//commit時是否輸出相關資訊
	private boolean bprint = true;
	
	public Analyzer getAnalyzer() {
		return analyzer;
	}
	public void setAnalyzer(Analyzer analyzer) {
		this.analyzer = analyzer;
	}
	public String getIndexPath() {
		return indexPath;
	}
	public void setIndexPath(String indexPath) {
		if (!(indexPath.endsWith("\\") || indexPath.endsWith("/"))) {
			indexPath += "/";
		}
		this.indexPath = indexPath;
	}
	public double getIndexReopenMaxStaleSec() {
		return indexReopenMaxStaleSec;
	}
	public void setIndexReopenMaxStaleSec(double indexReopenMaxStaleSec) {
		this.indexReopenMaxStaleSec = indexReopenMaxStaleSec;
	}
	public double getIndexReopenMinStaleSec() {
		return indexReopenMinStaleSec;
	}
	public void setIndexReopenMinStaleSec(double indexReopenMinStaleSec) {
		this.indexReopenMinStaleSec = indexReopenMinStaleSec;
	}
	public int getIndexCommitSeconds() {
		return indexCommitSeconds;
	}
	public void setIndexCommitSeconds(int indexCommitSeconds) {
		this.indexCommitSeconds = indexCommitSeconds;
	}
	public String getIndexName() {
		return indexName;
	}
	public void setIndexName(String indexName) {
		this.indexName = indexName;
	}
	public boolean isBprint() {
		return bprint;
	}
	public void setBprint(boolean bprint) {
		this.bprint = bprint;
	}
}

 

IndexConfig

      在一個系統中並不一定只存在一個索引，也可能會是多個，所以又添加了一個IndexConfig類，具體程式碼如下：

 /**  
 *@Description: 索引的相關配置引數
 */ 
package com.lulei.lucene.index.model;  

import java.util.HashSet;

public class IndexConfig {
	//配置引數
	private static HashSet<ConfigBean> configBean = null;
	
	//預設的配置
	private static class LazyLoadIndexConfig {
		private static final HashSet<ConfigBean> configBeanDefault = new HashSet<ConfigBean>();
		 static {
			 ConfigBean configBean = new ConfigBean();
			 configBeanDefault.add(configBean);
		 }
	}

	public static HashSet<ConfigBean> getConfigBean() {
		//如果未對IndexConfig初始化，則使用預設配置
		if (configBean == null) {
			configBean = LazyLoadIndexConfig.configBeanDefault;
		}
		return configBean;
	}

	public static void setConfigBean(HashSet<ConfigBean> configBean) {
		IndexConfig.configBean = configBean;
	}
}

ps:最近發現其他網站可能會對部落格轉載，上面並沒有源連結，如想檢視更多關於 基於lucene的案例開發 請點選這裡。或訪問網址http://blog.csdn.net/xiaojimanman/article/category/2841877 或 http://www.llwjy.com/