解讀Lucene.Net——一、Directory之一在使用Lucene.Net中，第一個(gè)接觸的類(lèi)一般是Directory。它是Lucene存儲(chǔ)的一個(gè)抽象，由此派生了兩個(gè)類(lèi)：FSDirectory和RAMDirectory，用于控制索引文件的存儲(chǔ)位置。使用FSDirectory類(lèi)，就是存儲(chǔ)到硬盤(pán)；使用RAMDirectory類(lèi)，則是存儲(chǔ)到內(nèi)存。圖1-1存儲(chǔ)抽象實(shí)現(xiàn)UML圖如圖1-1，顯示了這種關(guān)系。而看Lucene代碼會(huì)發(fā)現(xiàn)，RAMDirectory和FSDirectoryJava版本轉(zhuǎn)移過(guò)來(lái)，工具自動(dòng)產(chǎn)生的。那就先看看Java代碼的結(jié)構(gòu)，然后再來(lái)看轉(zhuǎn)移過(guò)來(lái)生成的內(nèi)嵌類(lèi)是干什么用的。Directory類(lèi)一共有11個(gè)方法，看看類(lèi)的注釋就知道，翻譯過(guò)來(lái)也是沒(méi)有做非Java'si/oAPIsnotuseddirectly,butratheralli/oisthroughthisAPI.”。還保留著Java的解釋了，雖然沒(méi)有人會(huì)認(rèn)為在dotNet平臺(tái)會(huì)采用Java的API,Directory的注釋原文：ADirectoryisaflatlistoffiles.Filesmaybewrittenonce,whentheyarecreated.Onceafileiscreateditmayonlybeopenedforread,ordeleted.Randomaccessispermittedbothwhenreadingandwriting.Java'si/oAPIsnotuseddirectly,butratheralli/oisthroughthisAPI.Thispermitsthingssuchas:implementationofRAM-basedindices;implementationindicesstoredinadatabase,viaJDBC;implementationofanindexasasinglefile;Directory是允許的。Java的I/O庫(kù)沒(méi)有被直接使用，所以的I/O操作都通過(guò)這個(gè)。這些存儲(chǔ)可以允許：實(shí)現(xiàn)基于內(nèi)存的索引；實(shí)現(xiàn)索引存入數(shù)據(jù)庫(kù)，通過(guò)JDBC；實(shí)現(xiàn)一個(gè)索引是一個(gè)文件。而Directory的11個(gè)方法分別是：1、list把一個(gè)Directory對(duì)象下的文件，按字符串?dāng)?shù)組的方式返回；2、fileExists給定一個(gè)文件名，如果存在，就返回true；3、fileModified返回給定文件名被修改的時(shí)間；4、touchFile設(shè)置給定文件名文件的更新時(shí)間為現(xiàn)在；5、deleteFile刪除當(dāng)前directory對(duì)象下一個(gè)給定文件名的文件，該文件必須存在；6、renameFile重命名當(dāng)前directory一個(gè)文件的文件名，如果新的名字在directory里已經(jīng)存在，將會(huì)更換。這個(gè)要更換原子；7、fileLength返回文件的長(zhǎng)度；8、createFile創(chuàng)建一個(gè)空文件，并且返回該文件的寫(xiě)入流；9、openFile10、makeLock鎖定該directory對(duì)象；11、close關(guān)閉該對(duì)象。返回一個(gè)存在文件的讀取流；而在Directory類(lèi)中，使用的都是抽象方法，把這個(gè)類(lèi)換成接口也可以。然后再來(lái)看看RAMDirectory類(lèi)。RAMDirectory是Directory的內(nèi)存操作實(shí)現(xiàn)。RAMDirectory類(lèi)有5個(gè)重載構(gòu)造函數(shù)。RAMDirectory()構(gòu)造函數(shù)無(wú)操作；RAMDirectory(Directorydir)允許把硬盤(pán)上的索引載入內(nèi)存，這個(gè)操作只就不行了。）這個(gè)構(gòu)造函數(shù)只調(diào)用了RAMDirectory(Directorydir,booleancloseDir)構(gòu)造函數(shù)，并未做其他動(dòng)作。再來(lái)看看RAMDirectory(Directorydir,booleancloseDir)構(gòu)造函數(shù)。除了默認(rèn)構(gòu)造函數(shù)，其他3個(gè)構(gòu)造函數(shù)都是調(diào)用的這個(gè)構(gòu)造函數(shù)做處理的。代碼1-2:string[]files=dir.List();for(inti=0;i<files.Length;i++){//makeplaceonramdiskOutputStreamos=CreateFile(System.IO.Path.GetFileName(files[i]));//readcurrentfileInputStreamis_Renamed=dir.OpenFile(files[i]);//andcopytoramdiskintlen=(int)is_Renamed.Length();byte[]buf=newbyte[len];is_Renamed.ReadBytes(buf,0,len);os.WriteBytes(buf,len);//gracefulcleanupis_Renamed.Close();os.Close();}if(closeDir)dir.Close();其他兩個(gè)構(gòu)造函數(shù)用到了FSDirectory類(lèi)把文件構(gòu)造成Directory對(duì)象?？纯创a就行了:代碼1-3:publicRAMDirectory(System.IO.FileInfodir):this(FSDirectory.GetDirectory(dir,false),true){}publicRAMDirectory(System.Stringdir):this(FSDirectory.GetDirectory(dir,false),true){}這兩個(gè)構(gòu)造函數(shù)第二個(gè)參數(shù)都是true,和代碼1-4:publicRAMDirectory(Directorydir):this(dir,false){}的Directory對(duì)象。對(duì)于傳入的，也就是代碼1-4，因?yàn)檫@個(gè)傳入的對(duì)象是個(gè)引1-3是有它自身創(chuàng)建的Directory，關(guān)閉它并不會(huì)影響到RAMDirectory的外部。代碼12的功能就是實(shí)現(xiàn)把硬盤(pán)上的索引按字節(jié)轉(zhuǎn)存到內(nèi)存中。首先，會(huì)創(chuàng)建一個(gè)文件，調(diào)用的是RAMDirectory自身的CreateFile方法：代碼1-5publicoverrideOutputStreamCreateFile(System.Stringname){RAMFilefile=newRAMFile();files[name]=file;returnnewRAMOutputStream(file);}這個(gè)方法調(diào)用了兩個(gè)還沒(méi)講的類(lèi)。實(shí)現(xiàn)的功能就是創(chuàng)建一個(gè)內(nèi)存的文件映像。在RAMDirectory定義了一個(gè)HashtableCreateFile被調(diào)用時(shí)，往里面填充創(chuàng)建的文件。所以，從硬盤(pán)往內(nèi)存拷貝文件的過(guò)程中，這個(gè)哈希表就記錄下了內(nèi)存中所有被創(chuàng)建的文件。在List方法，就可以通過(guò)枚舉的方式來(lái)獲取內(nèi)存中文件的數(shù)量。代碼1-6publicoverrideSystem.String[]List(){System.String[]result=newSystem.String[files.Count];inti=0;System.Collections.IEnumeratornames=files.Keys.GetEnumerator();while(names.MoveNext()){result[i++]=((System.String)names.Current);}returnresult;}FileExists和FileModifiedCreateFile的代碼很容易讀懂：代碼1-7///<summary>Returnstrueiffthenamedfileexistsinthisdirectory.</summary>publicoverrideboolFileExists(System.Stringname){RAMFilefile=(RAMFile)files[name];returnfile!=null;}///<summary>Returnsthetimethenamedfilewaslastmodified.</summary>publicoverridelongFileModified(System.Stringname){RAMFilefile=(RAMFile)files[name];returnfile.lastModified;}TouchFile的代碼比較長(zhǎng)，需要看一下代碼1-8///<summary>Setthemodifiedtimeofanexistingfiletonow.</summary>publicoverridevoidTouchFile(System.Stringname){//finalbooleanMONITOR=false;RAMFilefile=(RAMFile)files[name];longts2,ts1=(System.DateTime.Now.Ticks-621355968000000000)/10000;do{try{System.Threading.Thread.Sleep(newSystem.TimeSpan((System.Int64)10000*0+100*1));}catch(System.Threading.ThreadInterruptedException){}ts2=(System.DateTime.Now.Ticks-621355968000000000)/10000;//////if(MONITOR){count++;}}while(ts1==ts2);file.lastModified=ts2;////if(MONITOR)System.out.println("SLEEPCOUNT:"+count);}RAMFile懂，為什么要減去個(gè)那數(shù)值呢？看看Java版的代碼：代碼1-9/**Setthemodifiedtimeofanexistingfiletonow.*/publicvoidtouchFile(Stringname)throwsIOException{//finalbooleanMONITOR=false;RAMFilefile=(RAMFile)files.get(name);longts2,ts1=System.currentTimeMillis();do{try{Thread.sleep(0,1);}catch(InterruptedExceptione){}ts2=System.currentTimeMillis();//if(MONITOR){//count++;//}}while(ts1==ts2);file.lastModified=ts2;//if(MONITOR)//System.out.println("SLEEPCOUNT:"+count);}看出來(lái)了，這段只是想計(jì)算時(shí)間的。為什么要這么計(jì)算時(shí)間呢？去FSDirectory類(lèi)看到，他的方法就要簡(jiǎn)單很多代碼1-10///<summary>Setthemodifiedtimeofanexistingfiletonow.</summary>publicoverridevoidTouchFile(System.Stringname){System.IO.FileInfofile=newSystem.IO.FileInfo(System.IO.Path.Combine(directory.FullName,name));file.LastWriteTime=System.DateTime.Now;}為什么在RAMDirectory需要這么來(lái)計(jì)算，那是為了取得一種隨機(jī)數(shù)的效果，文件時(shí)間的更新如果是用DateTime.Now的話(huà)就會(huì)產(chǎn)生誤差。通過(guò)這種算法，用Thread.Sleep的方式，然后通過(guò)循環(huán)對(duì)比，讓兩個(gè)時(shí)間產(chǎn)生差距，否則很可能會(huì)一樣。要是一樣，對(duì)文件版本的控制就不是很好。而這個(gè)睡眠0.01ms，速度很快，不會(huì)影響性能。實(shí)際上采用下面的方式也是一樣的：代碼1-11longts2,ts1=System.DateTime.Now.Ticks;do{try{System.Threading.Thread.Sleep(newSystem.TimeSpan((System.Int64)10000*0+100*1));}catch(System.Threading.ThreadInterruptedException){}ts2=System.DateTime.N