接著昨天學(xué)習(xí)的 Lucene-2.2.0 源代碼閱讀學(xué)習(xí)(11) 繼續(xù)學(xué)習(xí)。

IndexWriter的一個(gè)構(gòu)造器，定義如下所示：

public IndexWriter(String path, Analyzer a, boolean create)
?????? throws CorruptIndexException, LockObtainFailedException, IOException {
??? init(FSDirectory.getDirectory(path), a, create, true, null, true);
}

已經(jīng)知道，init方法的復(fù)雜性和重要性。對init方法所涉及到的有用的相關(guān)類進(jìn)行系統(tǒng)地學(xué)習(xí)。

init方法的聲明是這樣的：

private void init(Directory d, Analyzer a, final boolean create, boolean closeDir, IndexDeletionPolicy deletionPolicy, boolean autoCommit)

首先看一下Directory這個(gè)類的繼承關(guān)系，如圖所示：

Directory是一個(gè)抽象類，它是與目錄有關(guān)的一個(gè)類，主要定義了一些與目錄相關(guān)的屬性和行為，源代碼如下所示：

package org.apache.lucene.store;

import java.io.IOException;

public abstract class Directory {

// 有目錄相關(guān)的一個(gè)鎖工廠，主要是為向目錄中寫入文件服務(wù)，使用工廠模式，寫入文件內(nèi)容必須獲取鎖
protected LockFactory lockFactory;

//?? 獲取該目錄下的所有文件名稱字符串的一個(gè)數(shù)組
public abstract String[] list()
?????? throws IOException;

// 判斷指定文件名稱為name的文件是否存在
public abstract boolean fileExists(String name)
?????? throws IOException;

// 獲取指定文件名稱為name的文件最后修改的時(shí)間
public abstract long fileModified(String name)
?????? throws IOException;

//?? 設(shè)置指定文件名稱為name的文件的修改時(shí)間為當(dāng)前時(shí)間
public abstract void touchFile(String name)
?????? throws IOException;

// 刪除已經(jīng)存在于該目錄下的指定文件名稱為namde的文件
public abstract void deleteFile(String name)
?????? throws IOException;

// 重新命名文件，將原文件名from修改為to
public abstract void renameFile(String from, String to)
?????? throws IOException;

// 獲取 指定文件名稱為name的文件的長度
public abstract long fileLength(String name)
?????? throws IOException;

// 在該目錄下創(chuàng)建一個(gè)名稱為name的文件，同時(shí)返回一個(gè)索引輸出流，以便向其中寫入內(nèi)容
public abstract IndexOutput createOutput(String name) throws IOException;

// 讀取該目錄下名稱為name的文件，返回一個(gè)輸入流，以便對該文件進(jìn)行相關(guān)操作
public abstract IndexInput openInput(String name)
??? throws IOException;

/** 讀取該目錄下名稱為name的文件，指定了讀入緩沖區(qū)的大小為bufferSize，返回一個(gè)輸入流
* Currently the only Directory implementations that respect this
* parameter are {@link FSDirectory} and {@link
* org.apache.lucene.index.CompoundFileReader}.
*/
public IndexInput openInput(String name, int bufferSize) throws IOException {
??? return openInput(name);
}

// 獲取一個(gè)鎖對象，其中name指定的鎖文件的名稱，即write.lock文件
public Lock makeLock(String name) {
????? return lockFactory.makeLock(name);
}
// 當(dāng)指定名稱為name的鎖文件不再被使用的時(shí)候，從鎖工廠LockFactory中清除該鎖；注意：是從內(nèi)存中清除，并非從文件系統(tǒng)中刪除。
public void clearLock(String name) throws IOException {
??? if (lockFactory != null) {
????? lockFactory.clearLock(name);
??? }
}

// 關(guān)閉該目錄，不再對該目錄操作了
public abstract void close()
?????? throws IOException;

// 當(dāng)該目錄被管理，要對其進(jìn)行操作之前，必須先創(chuàng)建一個(gè)鎖工廠LockFactory實(shí)例，只有擁有了鎖工廠才可以獲取鎖實(shí)例
public void setLockFactory(LockFactory lockFactory) {
????? this.lockFactory = lockFactory;
????? lockFactory.setLockPrefix(this.getLockID());
}

// 獲取鎖工廠實(shí)例
public LockFactory getLockFactory() {
????? return this.lockFactory;
}

// 過去鎖實(shí)例的唯一表示ID的字符串描述
public String getLockID() {
????? return this.toString();
}

// 拷貝源目錄src下的文件，復(fù)制到目的目錄dest下面，拷貝完成后關(guān)閉源目錄src
public static void copy(Directory src, Directory dest, boolean closeDirSrc) throws IOException {
????? final String[] files = src.list();??? // 獲取源目錄src下的所有文件

????? if (files == null)??? // 如果源目錄src下沒有文件，則拋出異常
??????? throw new IOException("cannot read directory " + src + ": list() returned null");

????? // 如果獲取到的源目錄src目錄下的文件列表files不空，就執(zhí)行復(fù)制操作

????? byte[] buf = new byte[BufferedIndexOutput.BUFFER_SIZE];
????? for (int i = 0; i < files.length; i++) {
??????? IndexOutput os = null;
??????? IndexInput is = null;
??????? try {
????????? // 在目的目錄dest下面創(chuàng)建一個(gè)新文件，名稱與從源目錄src下獲得的文件名稱相同
????????? os = dest.createOutput(files[i]);
????????? // 打開源目錄下對應(yīng)的該文件，返回一個(gè)索引輸入流
????????? is = src.openInput(files[i]);
????????? // 復(fù)制到目錄目錄下
????????? long len = is.length();
????????? long readCount = 0;
????????? while (readCount < len) {
??????????? int toRead = readCount + BufferedIndexOutput.BUFFER_SIZE > len ? (int)(len - readCount) : BufferedIndexOutput.BUFFER_SIZE;
??????????? is.readBytes(buf, 0, toRead);??? // 以字節(jié)流的方式讀取源目錄的文件，將toRead個(gè)字節(jié)讀入到緩沖區(qū)buf中
??????????? os.writeBytes(buf, toRead);??? // 以字節(jié)流的方式寫入目的目錄的文件中，將緩沖區(qū)buf中toRead個(gè)字節(jié)寫入到目的目錄對應(yīng)的文件中
??????????? readCount += toRead;
????????? }
??????? } finally {
????????? // 最后要關(guān)閉輸入流
????????? try {
??????????? if (os != null)
????????????? os.close();
????????? } finally {
??????????? if (is != null)
????????????? is.close();??? // 關(guān)閉輸入流
????????? }
??????? }
????? }
????? if(closeDirSrc)
??????? src.close();??? // 關(guān)閉源目錄
}
}

從Directory抽象類的定義，我們可以得到如下幾點(diǎn)：

1、管理鎖工廠及其鎖實(shí)例；

2、管理Directory目錄實(shí)例的基本屬性，主要是通過文件名稱進(jìn)行管理；

3、管理與操作該目錄相關(guān)的一些流對象；

4、管理索引文件的拷貝。

然后就要對Directory抽象類的具體實(shí)現(xiàn)類進(jìn)行學(xué)習(xí)了。