现在的位置: 首页 > 综合 > 正文

lucene 搜索入门实例

2013年08月05日 ⁄ 综合 ⁄ 共 6107字 ⁄ 字号 小 中 大 ⁄ 评论关闭
  1. Y_indexer.java  建索引
  2. package com.hapark.lucene;
  4. import java.io.BufferedReader;   
  5. import java.io.File;   
  6. import java.io.FileInputStream;   
  7. import java.io.IOException;   
  8. import java.io.InputStreamReader;   
  9. import java.util.ArrayList;
  10. import java.util.Date;   
  11.   
  12. import org.apache.lucene.analysis.Analyzer;   
  13. import org.apache.lucene.analysis.standard.StandardAnalyzer;   
  14. import org.apache.lucene.document.Document;   
  15. import org.apache.lucene.document.Field;   
  16. import org.apache.lucene.index.IndexWriter;   
  18. public class Y_indexer {
  19.       public static void main(String[] args) throws Exception {   
  20.             /* 指明要索引文件夹的位置,这里是D盘的y文件夹下 */  
  21.             File fileDir = new File("d://y");   
  22.       
  23.             /* 这里放索引文件的位置 */  
  24.             File indexDir = new File("d://index");   
  25.             Analyzer luceneAnalyzer = new StandardAnalyzer();   
  26.             IndexWriter indexWriter = new IndexWriter(indexDir, luceneAnalyzer,   
  27.                     true); 
  28.             ArrayList list = new ArrayList();
  29.             getList(fileDir, list);
  30.             File[] textFiles = (File[])list.toArray(new File[0]);
  31.             System.out.println(textFiles.length);
  32.             long startTime = new Date().getTime();   
  33.                
  34.             //增加document到索引去   
  35.             for (int i = 0; i < textFiles.length; i++) {   
  36.                 if (textFiles[i].isFile()   
  37.                         && textFiles[i].getName().endsWith(".html")) {   
  38.                     System.out.println("File " + textFiles[i].getCanonicalPath()   
  39.                             + "正在被索引....");   
  40.                     String temp = FileReaderAll(textFiles[i].getCanonicalPath(),   
  41.                             "GBK");   
  42.                     System.out.println(temp);   
  43.                     Document document = new Document();   
  44.                     Field FieldPath = new Field("path", textFiles[i].getPath(),   
  45.                             Field.Store.YES, Field.Index.NO);   
  46.                     Field FieldBody = new Field("body", temp, Field.Store.YES,   
  47.                             Field.Index.TOKENIZED,   
  48.                             Field.TermVector.WITH_POSITIONS_OFFSETS);   
  49.                     Field FieldTitle = new Field("title", temp, Field.Store.YES,   
  50.                             Field.Index.TOKENIZED,   
  51.                             Field.TermVector.WITH_POSITIONS_OFFSETS);   
  52.                     document.add(FieldPath);   
  53.                     document.add(FieldBody);   
  54.                     document.add(FieldTitle);
  55.                     indexWriter.addDocument(document);   
  56.                 }   
  57.             }   
  58.             //optimize()方法是对索引进行优化   
  59.             indexWriter.optimize();   
  60.             indexWriter.close();   
  61.                
  62.             //测试一下索引的时间   
  63.             long endTime = new Date().getTime();   
  64.             System.out   
  65.                     .println("这花费了"  
  66.                             + (endTime - startTime)   
  67.                             + " 毫秒来把文档增加到索引里面去!"  
  68.                             + fileDir.getPath());   
  69.         }  
  70.       
  71.       
  72.       /**
  73.        * 多层文件夹
  74.        * @param file
  75.        * @param list
  76.        */
  77.       public static void getList(File file, ArrayList list){
  78.           if(file.isDirectory() && file.getName().indexOf(".") != 0){
  79.               
  80.               File [] file2 = file.listFiles();
  81.               for(int i= 0; i< file2.length; i++)
  82.               getList(file2[i], list);
  83.           }else{
  84.           list.add(file);
  85.           }
  86.       }
  87.       
  88.         public static String FileReaderAll(String FileName, String charset)   
  89.                 throws IOException {   
  90.             BufferedReader reader = new BufferedReader(new InputStreamReader(   
  91.                     new FileInputStream(FileName), charset));   
  92.             String line = new String();   
  93.             String temp = new String();   
  94.                
  95.             while ((line = reader.readLine()) != null) {   
  96.                 temp += line;   
  97.             }   
  98.             reader.close();   
  99.             return temp;   
  100.         }   
  101.     }  

 

 

  1. Y_searcher  lucene 搜索
  2. package com.hapark.lucene;
  4. import java.io.IOException;
  5. import java.util.ArrayList;
  6. import java.util.Date;
  7. import java.util.List;
  9. import org.apache.lucene.analysis.Analyzer;
  10. import org.apache.lucene.analysis.standard.StandardAnalyzer;
  11. import org.apache.lucene.queryParser.ParseException;
  12. import org.apache.lucene.queryParser.QueryParser;
  13. import org.apache.lucene.search.Hits;
  14. import org.apache.lucene.search.IndexSearcher;
  15. import org.apache.lucene.search.Query;
  16. public class Y_searcher {
  17.       
  18.      public List search(){
  19.          List searchResult = new ArrayList();//创建一个List接口的一个实例类ArrayList类
  20.          try{
  21.          Hits hits = null;   
  22.          String key = "苏";   
  23.          Query query = null;   
  24.          IndexSearcher searcher = new IndexSearcher("d://yuyang"); 
  25.             Analyzer analyzer = new StandardAnalyzer();   //创建一个Analyzer接口的一个实例类StandardAnalyzer
  26.            
  27.                 QueryParser qp = new QueryParser("title", analyzer);   
  28.                 query = qp.parse(key);   
  29.            
  30.             if (searcher != null) {   
  31.                   Date start=new Date();
  32.                 hits = searcher.search(query);   //遍历hist结果的length
  33.                 if(hits.length()==0){
  34.                      System.out.println("对不起。没你想要的结果!");
  35.                 }
  36.                 else{
  37.                 for(int i=0;i<hits.length();i++){ 
  38.                      Date end=new Date();
  39.                   //  System.out.println("找到:" + hits.length() + " Totalresult!");   
  40.                   System.out.println("文件的路径:"+hits.doc(i).get("path"));
  41.                    // System.out.println("内容:"+hits.doc(i).get("body"));
  42.                     System.out.println(hits.doc(i).get("title"));
  43.                     System.out.println("检索完成，用时" + (end.getTime() - start.getTime()) + "毫秒");
  44.                 } 
  45.                 }
  46.             }
  47.          }
  48.                 catch(ParseException ex){
  49.                       
  50.                   }
  51.                 catch(IOException e){
  52.                     
  53.                 }
  54.                 return searchResult;
  55.                 }   
  57.      public static void main(String args[]){
  58.               Y_searcher y_s=new Y_searcher();
  59.               y_s.search();
  60.      }
  62. }

 

返回
【上篇】
【下篇】

作者:

抱歉!评论已关闭.

返回首页

Copyright © 2013-2018 学步园  保留所有权利.
软文销售 QQ客服：2265327166 点击这里给我发消息（其他合作也可洽谈）
必威体育
必威电竞