Lucene 2.9.0 的简单实用方法

先建立索引

import java.io.File;
import java.io.FileFilter;
import java.io.FileReader;
import java.io.IOException;
import java.io.Reader;
import java.util.HashSet;
import java.util.Set;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.lucene.analysis.Analyzer;
import org.apache.lucene.document.Document;
import org.apache.lucene.document.Field;
import org.apache.lucene.index.CorruptIndexException;
import org.apache.lucene.index.IndexReader;
import org.apache.lucene.index.IndexWriter;
import org.apache.lucene.store.FSDirectory;
import org.apache.lucene.store.LockObtainFailedException;
import org.wltea.analyzer.lucene.IKAnalyzer;
import vrvclient.util.ConfigUtil;
import vrvclient.util.FileListUtil;

/**
 *
 * @author lan
 */
public class Indexer extends Constants {

    private static final Log log = LogFactory.getLog(Indexer.class);

    public void index(File[] files, FileFilter filter) {
        if (files == null) {
            return;
        }
//        System.out.println(filter.getClass());
        Set<File> set = new HashSet<File>();
        for (File f : files) {//过滤掉不合要求的文件，如后缀，文件名等
            FileListUtil.list(f, filter, set);
        }
        File indexDir = new File(ConfigUtil.getIndexPath());//这里是获得索引文件的保存路径的
        Analyzer analyzer = new IKAnalyzer();//使用国产的IK分词器，很好很强大
        try {
            FSDirectory dir = FSDirectory.open(indexDir);//保存到硬盘上
            IndexWriter iw = new IndexWriter(dir, analyzer, !IndexReader.indexExists(dir), IndexWriter.MaxFieldLength.LIMITED);
            for (File f : set) {
                if (f.isFile()) {
//                    System.out.println(f.getAbsolutePath());
                    Document doc = new Document();
                    Reader reader = new FileReader(f);
                    doc.add(new Field(PATH, f.getAbsolutePath(), Field.Store.YES, Field.Index.ANALYZED));//保存路径
                    doc.add(new Field(FILE, reader));//保存文件
                    iw.addDocument(doc);
                    reader.close();
                }
            }
            iw.optimize();
            iw.close();
        } catch (CorruptIndexException ex) {
            log.error(ex.getMessage(), ex);
        } catch (LockObtainFailedException ex) {
            log.error(ex.getMessage(), ex);
        } catch (IOException ex) {
            log.error(ex.getMessage(), ex);
        }
    }
}

这个是搜索结果

Java代码

1. import java.io.File;   
2. import java.io.IOException;   
3. import java.util.HashSet;   
4. import java.util.Set;   
5. import org.apache.commons.logging.Log;   
6. import org.apache.commons.logging.LogFactory;   
7. import org.apache.lucene.analysis.Analyzer;   
8. import org.apache.lucene.document.Document;   
9. import org.apache.lucene.queryParser.ParseException;   
10. import org.apache.lucene.queryParser.QueryParser;   
11. import org.apache.lucene.search.IndexSearcher;   
12. import org.apache.lucene.search.Query;   
13. import org.apache.lucene.search.ScoreDoc;   
14. import org.apache.lucene.search.TopDocs;   
15. import org.apache.lucene.store.FSDirectory;   
16. import org.wltea.analyzer.lucene.IKAnalyzer;   
17. import vrvclient.util.ConfigUtil;   
18.   
19. /**  
20.  *  
21.  * @author lan  
22.  */  
23. public class Searcher extends Constants {   
24.   
25.     private static final Log log = LogFactory.getLog(Indexer.class);   
26.   
27.     /**  
28.      *  
29.      * @param contents  
30.      * @param combineMode true = and,false = or  
31.      * @param limit -1=all  
32.      */  
33.     public Set<String> search(String[] contents, boolean combineMode, int limit) {   
34.         Set<String> paths = new HashSet<String>();   
35.         try {   
36.             File indexDir = new File(ConfigUtil.getIndexPath());   
37.             FSDirectory fsd = FSDirectory.open(indexDir);   
38.             IndexSearcher is = new IndexSearcher(fsd, true);   
39.             Analyzer analyzer = new IKAnalyzer();   
40.             if (fsd.getFile().exists()) {   
41.                 QueryParser qp = new QueryParser(FILE, analyzer);   
42.                 StringBuilder sb = new StringBuilder();   
43.                 String jioner = "";   
44.                 if (combineMode) {//如果是and，则所有条件要同时满足   
45.                     jioner = "+";   
46.                 }   
47.                 boolean b = true;   
48.                 for (String s : contents) {   
49.                     s = s.replaceAll("\\s+", " AND ");//防止条件中的空格被看成“或”，把其变成“与”   
50.                     if (!b) {   
51.                         sb.append(" ");   
52.                     }   
53.                     sb.append(jioner).append("(").append(s).append(")");   
54.                     b = false;   
55.                 }   
56.                 Query q = qp.parse(sb.toString());   
57.                 log.info(q.toString());   
58.                 if (limit == -1) {   
59.                     limit = is.maxDoc();   
60.                 }   
61.   
62.                 TopDocs hits = is.search(q, limit);   
63.                 ScoreDoc[] sds = hits.scoreDocs;   
64.                 for (int i = 0; i < sds.length; i++) {   
65.                     ScoreDoc sd = sds[i];   
66.                     Document doc = is.doc(sd.doc);   
67. //                    System.out.println("Hit:(" + sd.score + ")" + doc.toString());   
68. //本来想同时得到命中次数，也就是词频，但是网上找到的都是老版本的，这里不能用。   
69.                     paths.add(doc.get(PATH));//返回匹配的路径   
70.                 }   
71.             }   
72.             is.close();   
73.         } catch (ParseException ex) {   
74.             log.error(ex.getMessage(), ex);   
75.         } catch (IOException ex) {   
76.             log.error(ex.getMessage(), ex);   
77.         }   
78.         return paths;   
79.     }   
80. }  

import java.io.File;
import java.io.IOException;
import java.util.HashSet;
import java.util.Set;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.lucene.analysis.Analyzer;
import org.apache.lucene.document.Document;
import org.apache.lucene.queryParser.ParseException;
import org.apache.lucene.queryParser.QueryParser;
import org.apache.lucene.search.IndexSearcher;
import org.apache.lucene.search.Query;
import org.apache.lucene.search.ScoreDoc;
import org.apache.lucene.search.TopDocs;
import org.apache.lucene.store.FSDirectory;
import org.wltea.analyzer.lucene.IKAnalyzer;
import vrvclient.util.ConfigUtil;

/**
 *
 * @author lan
 */
public class Searcher extends Constants {

    private static final Log log = LogFactory.getLog(Indexer.class);

    /**
     *
     * @param contents
     * @param combineMode true = and,false = or
     * @param limit -1=all
     */
    public Set<String> search(String[] contents, boolean combineMode, int limit) {
        Set<String> paths = new HashSet<String>();
        try {
            File indexDir = new File(ConfigUtil.getIndexPath());
            FSDirectory fsd = FSDirectory.open(indexDir);
            IndexSearcher is = new IndexSearcher(fsd, true);
            Analyzer analyzer = new IKAnalyzer();
            if (fsd.getFile().exists()) {
                QueryParser qp = new QueryParser(FILE, analyzer);
                StringBuilder sb = new StringBuilder();
                String jioner = "";
                if (combineMode) {//如果是and，则所有条件要同时满足
                    jioner = "+";
                }
                boolean b = true;
                for (String s : contents) {
                    s = s.replaceAll("\\s+", " AND ");//防止条件中的空格被看成“或”，把其变成“与”
                    if (!b) {
                        sb.append(" ");
                    }
                    sb.append(jioner).append("(").append(s).append(")");
                    b = false;
                }
                Query q = qp.parse(sb.toString());
                log.info(q.toString());
                if (limit == -1) {
                    limit = is.maxDoc();
                }

                TopDocs hits = is.search(q, limit);
                ScoreDoc[] sds = hits.scoreDocs;
                for (int i = 0; i < sds.length; i++) {
                    ScoreDoc sd = sds[i];
                    Document doc = is.doc(sd.doc);
//                    System.out.println("Hit:(" + sd.score + ")" + doc.toString());
//本来想同时得到命中次数，也就是词频，但是网上找到的都是老版本的，这里不能用。
                    paths.add(doc.get(PATH));//返回匹配的路径
                }
            }
            is.close();
        } catch (ParseException ex) {
            log.error(ex.getMessage(), ex);
        } catch (IOException ex) {
            log.error(ex.getMessage(), ex);
        }
        return paths;
    }
}

附用到的工具类：

Java代码

1. import java.io.File;   
2. import java.io.FileFilter;   
3. import java.util.Map;   
4. import java.util.Set;   
5.   
6. /**  
7.  *  
8.  * @author lan  
9.  */  
10. public final class FileListUtil {   
11.   
12. //返回一定数量的符合要求的文件   
13.     public static void list(File f, FileFilter filter, Set<File> set, int limit) {   
14.         if (limit > -1 && set.size() >= limit) {   
15.             return;   
16.         }   
17.         if (f == null) {   
18.             return;   
19.         }   
20.         if (f.isFile()) {   
21.             set.add(f);   
22.         } else if (f.isDirectory()) {   
23.             File[] files = null;   
24.             if (filter == null) {   
25.                 files = f.listFiles();   
26.             } else {   
27.                 files = f.listFiles(filter);   
28.             }   
29.             if (files != null) {   
30.                 for (File file : files) {   
31.                     list(file, filter, set, limit);   
32.                 }   
33.             }   
34.         }   
35.     }   
36.   
37. //返回所有的符合要求的文件，不要担心set放不上，至少我的D盘资料盘都放进去都没有内存溢出   
38.     public static void list(File f, FileFilter filter, Set<File> set) {   
39.         if (f == null) {   
40.             return;   
41.         }   
42.         if (f.isFile()) {   
43.             set.add(f);   
44.         } else if (f.isDirectory()) {   
45.             File[] files = null;   
46.             if (filter == null) {   
47.                 files = f.listFiles();   
48.             } else {   
49.                 files = f.listFiles(filter);   
50.             }   
51.             if (files != null) {   
52.                 for (File file : files) {   
53.                     list(file, filter, set);   
54.                 }   
55.             }   
56.         }   
57.     }   
58.   
59. //其实是打包工具类用到的   
60.     public static void list(File f, FileFilter filter, String parent, Map<String, File> map) {   
61.         if (f == null) {   
62.             return;   
63.         }   
64.         String name = f.getName();   
65.         if (parent != null) {   
66.             name = parent + "/" + name;   
67.         }   
68.         if (f.isFile()) {   
69.             map.put(name, f);   
70.         } else if (f.isDirectory()) {   
71.             File[] files = null;   
72.             if (filter == null) {   
73.                 files = f.listFiles();   
74.             } else {   
75.                 files = f.listFiles(filter);   
76.             }   
77.             if (files != null) {   
78.                 for (File file : files) {   
79.                     list(file, filter, name, map);   
80.                 }   
81.             }   
82.         }   
83.     }   
84. }  

import java.io.File;
import java.io.FileFilter;
import java.util.Map;
import java.util.Set;

/**
 *
 * @author lan
 */
public final class FileListUtil {

//返回一定数量的符合要求的文件
    public static void list(File f, FileFilter filter, Set<File> set, int limit) {
        if (limit > -1 && set.size() >= limit) {
            return;
        }
        if (f == null) {
            return;
        }
        if (f.isFile()) {
            set.add(f);
        } else if (f.isDirectory()) {
            File[] files = null;
            if (filter == null) {
                files = f.listFiles();
            } else {
                files = f.listFiles(filter);
            }
            if (files != null) {
                for (File file : files) {
                    list(file, filter, set, limit);
                }
            }
        }
    }

//返回所有的符合要求的文件，不要担心set放不上，至少我的D盘资料盘都放进去都没有内存溢出
    public static void list(File f, FileFilter filter, Set<File> set) {
        if (f == null) {
            return;
        }
        if (f.isFile()) {
            set.add(f);
        } else if (f.isDirectory()) {
            File[] files = null;
            if (filter == null) {
                files = f.listFiles();
            } else {
                files = f.listFiles(filter);
            }
            if (files != null) {
                for (File file : files) {
                    list(file, filter, set);
                }
            }
        }
    }

//其实是打包工具类用到的
    public static void list(File f, FileFilter filter, String parent, Map<String, File> map) {
        if (f == null) {
            return;
        }
        String name = f.getName();
        if (parent != null) {
            name = parent + "/" + name;
        }
        if (f.isFile()) {
            map.put(name, f);
        } else if (f.isDirectory()) {
            File[] files = null;
            if (filter == null) {
                files = f.listFiles();
            } else {
                files = f.listFiles(filter);
            }
            if (files != null) {
                for (File file : files) {
                    list(file, filter, name, map);
                }
            }
        }
    }
}

常量类，大部分人用接口，但是我不太喜欢用接口来保存常量，虽然更方便点，但是不合规范。

文章来源：http://www.xinxilong.com

• ·百度贴吧推广大师2.2.1
• ·石青微博营销软件2.4.1.1
• ·石青邮件大师2.2.6.1
• ·百度关键字优化精灵2.3.6.1
• ·石青微信工具箱1.3.5.1
• ·快手解封助手1.1.2.1
• ·百度知道推广大师2.1.7.1
• ·石青抖音推广大师软件1.2.5.1
• ·小红书解封助手1.0.9.1
• ·淘宝推广大师2.2.6.1
• ·论坛群发大师2.5.3
• ·博客群发大师2.5.7
• ·石青伪原创软件1.7.5.1
• ·百度热议删除软件1.3.0.1
• ·石青抖音营销软件1.3.0.1
• ·石青微博私信软件1.2.2.1
• ·网格回测工具1.2.9.1
• ·剪映备份大师1.1.4.1
• ·B站视频快传助手1.0.2.1
• ·小红书解封助手1.0.8.1