<rt id="bn8ez"></rt>
<label id="bn8ez"></label>
  • 

    • <span id="bn8ez"></span>
    

    <label id="bn8ez"><meter id="bn8ez"></meter></label>
    

    
    

    




    







												


        


    
	
    
		
			

    

    
	
    
		
			
    葉明的javablog
    
			java學習天堂,個人關于其他blog：blog.javaworker.cn,歡迎大家訪問
		    		
	
    

    

    

    

    posts - 64, comments - 50, trackbacks - 0, articles - 3
    


    		
	
    
	
    
		
			
		
		
			
    
				
					
	
    
		
		
       RAMDirectory是Directory抽象類在使用內存最為文件存儲的實現類，其主要是將所有的索引文件保存到內存中。這樣可以提高效率。但是如果索引文件過大的話，則會導致內存不足，因此，小型的系統推薦使用，如果大型的，索引文件達到G級別上，推薦使用FSDirectory
    

    首先我們看看該類的源代碼：
    

    首先該類繼承與抽象類Directory，并且實現了序列話接口
    

      1/**一個對于Directory的內存實現的類，鎖工廠是有SingleInstanceLockFactory來實現，但是鎖工廠可以更改 */
    
      2public class RAMDirectory extends Directory implements Serializable {
    
      3  private static final long serialVersionUID = 1l;
    
      4  HashMap fileMap = new HashMap();            //首先定了保存文件名以及的Map
    
      5  long sizeInBytes = 0;                        //文件占用的字節數
    
      6 /** 構造函數。指定LockFactory為該類的一個實例SingleInstanceLockFactory，SingleInstanceLockFactory類的特點是，所有的加鎖操作必須通過該SingleInstanceLockFactory的一個實例而發生，也就是說，在進行加鎖操作的時候，必須獲取到這個SingleInstanceLockFactory的實例*/
    
      7  public RAMDirectory() {
    
      8    setLockFactory(new SingleInstanceLockFactory());
    
      9  }
    
     10  /** 定義一個新的RAMDirectory，并且指定其目錄，這個做的目的可以將一個文件系統的索引加載到內存中，這個只能使用在該索引能夠被全部加在到內存中。這次只是將系統文件的索引拷貝一份到內存中，加載后，系統文件索引發生變化，將不會在該實例中體現。 */
    
     11  public RAMDirectory(Directory dir) throws IOException {
    
     12    this(dir, false);
    
     13  }
    
     14  /** 根據目錄，以及參數將該目錄中的所有文件復制到內存中，需要復制的文件已經存在，則直接覆蓋。closeDir表示是否關閉源目錄*/
    
     15  private RAMDirectory(Directory dir, boolean closeDir) throws IOException {
    
     16    this();
    
     17    Directory.copy(dir, this, closeDir);
    
     18  }
    
     19  /**根據提供的文件路徑，將該文件路徑下的所有的文件復制到內存中，并且創建一個RAMDirectory對象。如果需要復制的對象已經存在，則覆蓋原來的文件*/
    
     20  public RAMDirectory(File dir) throws IOException {
    
     21    this(FSDirectory.getDirectory(dir), true);
    
     22  }
    
     23/**根據提供的String路徑，將該文件路徑下的所有的文件復制到內存中，并且創建一個RAMDirectory對象。如果需要復制的對象已經存在，則覆蓋原來的文件*/
    
     24  public RAMDirectory(String dir) throws IOException {
    
     25    this(FSDirectory.getDirectory(dir), true);
    
     26  }
    
     27  /**返回所有該文件該內存索引中的所有文件  */
    
     28  public synchronized final String[] list() {
    
     29    ensureOpen();
    
     30    Set fileNames = fileMap.keySet();        //該文件的所有key
    
     31    String[] result = new String[fileNames.size()];
    
     32    int i = 0;
    
     33    Iterator it = fileNames.iterator();
    
     34    while (it.hasNext())
    
     35      result[i++] = (String)it.next();
    
     36    return result;
    
     37  }
    
     38  /**如果指定文件名的文件在索引中存在，則返回true，否則返回false*/
    
     39  public final boolean fileExists(String name) {
    
     40    ensureOpen();
    
     41    RAMFile file;
    
     42    synchronized (this) {
    
     43      file = (RAMFile)fileMap.get(name);
    
     44    }
    
     45    return file != null;
    
     46  }
    
     47/**返回指定文件最后的修改時間   */
    
     48  public final long fileModified(String name) throws IOException {
    
     49    ensureOpen();
    
     50    RAMFile file;
    
     51    synchronized (this) {
    
     52      file = (RAMFile)fileMap.get(name);
    
     53    }
    
     54    if (file==null)
    
     55      throw new FileNotFoundException(name);
    
     56    return file.getLastModified();
    
     57  }
    
     58  /**將指定文件的最后修改時間設置為現在 */
    
     59  public void touchFile(String name) throws IOException {
    
     60    ensureOpen();
    
     61    RAMFile file;
    
     62    synchronized (this) {
    
     63      file = (RAMFile)fileMap.get(name);
    
     64    }
    
     65    if (file==null)
    
     66      throw new FileNotFoundException(name);
    
     67    
    
     68    long ts2, ts1 = System.currentTimeMillis();
    
     69    do {
    
     70      try {
    
     71        Thread.sleep(0, 1);
    
     72      }     catch (InterruptedException e) {}
    
     73      ts2 = System.currentTimeMillis();
    
     74    }     while(ts1 == ts2);
    
     75    
    
     76    file.setLastModified(ts2);
    
     77  }
    
     78  /** 返回指定文件的大小*/
    
     79  public final long fileLength(String name) throws IOException {
    
     80    ensureOpen();
    
     81    RAMFile file;
    
     82    synchronized (this) {
    
     83      file = (RAMFile)fileMap.get(name);
    
     84    }
    
     85    if (file==null)
    
     86      throw new FileNotFoundException(name);
    
     87    return file.getLength();
    
     88  }
    
     89  
    
     90  /** 返回當前目錄中所有的文件大小*/
    
     91  public synchronized final long sizeInBytes() {
    
     92    ensureOpen();
    
     93    return sizeInBytes;
    
     94  }
    
     95  /** 刪除指定文件名的文件*/
    
     96  public synchronized void deleteFile(String name) throws IOException {
    
     97    ensureOpen();
    
     98    RAMFile file = (RAMFile)fileMap.get(name);
    
     99    if (file!=null) {
    
    100        fileMap.remove(name);
    
    101        file.directory = null;
    
    102        sizeInBytes -= file.sizeInBytes;       // updates to RAMFile.sizeInBytes synchronized on directory
    
    103    }     else
    
    104      throw new FileNotFoundException(name);
    
    105  }
    
    106  /**根據制定的名稱，創建一個空文件，并且返回操作該文件的輸出流。 */
    
    107  public IndexOutput createOutput(String name) throws IOException {
    
    108    ensureOpen();
    
    109    RAMFile file = new RAMFile(this);
    
    110    synchronized (this) {
    
    111      RAMFile existing = (RAMFile)fileMap.get(name);
    
    112      if (existing!=null) {
    
    113        sizeInBytes -= existing.sizeInBytes;
    
    114        existing.directory = null;
    
    115      }
    
    116      fileMap.put(name, file);
    
    117    }
    
    118    return new RAMOutputStream(file);
    
    119  }
    
    120  /** 根據指定的文件名返回一個操作該文件的輸入流 */
    
    121  public IndexInput openInput(String name) throws IOException {
    
    122    ensureOpen();
    
    123    RAMFile file;
    
    124    synchronized (this) {
    
    125      file = (RAMFile)fileMap.get(name);
    
    126    }
    
    127    if (file == null)
    
    128      throw new FileNotFoundException(name);
    
    129    return new RAMInputStream(file);
    
    130  }
    
    131
    
    132  /** 關閉并且釋放索引占用的內存 */
    
    133  public void close() {
    
    134    isOpen = false;
    
    135    fileMap = null;
    
    136  }
    
    137}
    

    由于RAMDirectory是抽象類Directory根據內存來實現的，所以他不是永久性存在，一旦內存釋放，索引就會消失。不像FSDirectory有一個本地的文件來存儲索引。
    

    我們看看RAMDirectory的構造函數，特別是根據本地的目錄來創建。將永久保存的文件初始化到內存中。因為內存的操作速度肯定比操作文件要快很倍。這樣索引的速度就大大的提供了。
    

    將指定的dir目錄拷貝到當前的內存中，即實例化一個RAMDirectory。這里，closeDir是一個很重要的狀態變量，指定了拷貝完成后，源目錄dir是否關閉。如果實例化一個RAMDirectory完成后就關閉源目錄dir，可能會因為處理的時間非常短，而需要再次打開源目錄dir，持久化到文件系統目錄，開銷可能會比直接操作源目錄dir要大，這點要權衡。
    

    

    
	
    


    
	    
    




    








    

				
			
    
		    		
	
    
	
    
		
			

		
	
    

    


    







    
        
	



主站蜘蛛池模板：
我想看一级毛片免费的|
免费a在线观看播放|
久久久久免费看黄A片APP|
国产一精品一aⅴ一免费|
久久亚洲精品中文字幕无码
|
在线播放亚洲第一字幕|
亚洲精品人成电影网|
一级**爱片免费视频|
免费无码看av的网站|
亚洲人成影院在线|
十八禁的黄污污免费网站|
无码中文在线二区免费|
亚洲人成网站影音先锋播放|
99在线免费观看视频|
国产亚洲午夜高清国产拍精品|
国产精品亚洲精品久久精品|
999国内精品永久免费视频|
亚洲精品自产拍在线观看|
粉色视频成年免费人15次|
岛国av无码免费无禁网站|
性色av极品无码专区亚洲|
成年女人喷潮毛片免费播放|
国产亚洲欧美在线观看|
亚洲男女内射在线播放|
亚洲AV无码精品国产成人|
亚洲日韩中文在线精品第一|
无码天堂va亚洲va在线va|
亚洲毛片不卡av在线播放一区|
久久国产乱子精品免费女
|
国产成人aaa在线视频免费观看|
亚洲一卡二卡三卡|
16女性下面扒开无遮挡免费|
亚洲AV乱码一区二区三区林ゆな
|
亚洲国产精品高清久久久|
jizz免费观看|
亚洲美女又黄又爽在线观看|
国产精品免费视频观看拍拍
|
亚洲福利一区二区精品秒拍|
午夜无遮挡羞羞漫画免费|
亚洲AV无码国产一区二区三区|
亚洲国产综合无码一区|