Lucene
写在前之前实习的公司用到全文检索,不知其原理,感觉高深莫测,现如今自己想尝试探究一下。 Solr和ElasticSearch的底层也是Lucene.
一、什么是全文检索1、数据的分类 1)结构化数据 格式固定、长度固定、数据类型固定。 例如数据库中的数据 2)非结构化数据 word文档、pdf文档、邮件、html、txt 格式不固定、长度不固定、数据类型不固定。 2、数据的查询 1)结构化数据的查询 SQL语句,查询结构化数据的方法。简单、速度快。 2)非结构化数据的查询 从文本文件中找出包含spring单词的文件。 1、目测 2、使用程序吧文档读取到内存中,然后匹配字符串。顺序扫描。 3、把非结构化数据变成结构化数据 先跟根据空格进行字符串拆分,得到一个单词列表,基于单词列表创建一个索引。 然后查询索引,根据单词和文档的对应关系找到文档列表。这个过程叫做全文检索。
索引:一个为了提高查询速度,创建某种数据结构的集合。3、全文检索 先创建索引然后查询索引的过程叫做全文检索。 索引一次创建可以多次使用。表现为每次查询速度很快。
二、全文检索的应用场景1、搜索引擎 百度、360搜索、谷歌、搜狗 2、站内搜索 论坛搜索、微博、文章搜索 3、电商搜索 淘宝搜索、京东搜索 4、只要是有搜索的地方就可以使用全文检索技术。
三、什么是Lucene Lucene是一个基于Java开发全文检索工具包。 四、Lucene实现全文检索的流程1、创建索引 1)获得文档 原始文档:要基于那些数据来进行搜索,那么这些数据就是原始文档。 搜索引擎:使用爬虫获得原始文档 站内搜索:数据库中的数据。 案例:直接使用io流读取磁盘上的文件。 2)构建文档对象 对应每个原始文档创建一个Document对象 每个document对象中包含多个域(field) 域中保存就是原始文档数据。 域的名称 域的值 每个文档都有一个唯一的编号,就是文档id 3)分析文档 就是分词的过程 1、根据空格进行字符串拆分,得到一个单词列表 2、把单词统一转换成小写。 3、去除标点符号 4、去除停用词 停用词:无意义的词 每个关键词都封装成一个Term对象中。 Term中包含两部分内容: 关键词所在的域 关键词本身 不同的域中拆分出来的相同的关键词是不同的Term。 4)创建索引 基于关键词列表创建一个索引。保存到索引库中。 索引库中: 索引 document对象 关键词和文档的对应关系 通过词语找文档,这种索引的结构叫倒排索引结构。 2、查询索引 1)用户查询接口 用户输入查询条件的地方 例如:百度的搜索框 2)把关键词封装成一个查询对象 要查询的域 要搜索的关键词 3)执行查询 根据要查询的关键词到对应的域上进行搜索。 找到关键词,根据关键词找到 对应的文档 4)渲染结果 根据文档的id找到文档对象 对关键词进行高亮显示 分页处理 最终展示给用户看。
五、入门程序1、创建索引 环境: 需要下载Lucene lucene.apache./ 最低要求jdk1.8 工程搭建: 创建一个java工程 添加jar: lucene-analyzers-mon-7.4.0.jar lucene-core-7.4.0.jar mons-io.jar
步骤:1、创建一个Director对象,指定索引库保存的位置。2、基于Directory对象创建一个IndexWriter对象3、读取磁盘上的文件,对应每个文件创建一个文档对象。4、向文档对象中添加域5、把文档对象写入索引库6、关闭indexwriter对象 public void createIndex() throws Exception {//1、创建一个Director对象,指定索引库保存的位置。//把索引库保存在内存中//Directory directory = new RAMDirectory();//把索引库保存在磁盘Directory directory = FSDirectory.open(new File("C:\\temp\\index").toPath());//2、基于Directory对象创建一个IndexWriter对象IndexWriterConfig config = new IndexWriterConfig(new IKAnalyzer());IndexWriter indexWriter = new IndexWriter(directory, config);//3、读取磁盘上的文件,对应每个文件创建一个文档对象。File dir = new File("C:\\A0.lucene2018\\05.参考资料\\searchsource");File[] files = dir.listFiles();for (File f :files) {//取文件名String fileName = f.getName();//文件的路径String filePath = f.getPath();//文件的内容String fileContent = FileUtils.readFileToString(f, "utf-8");//文件的大小long fileSize = FileUtils.sizeOf(f);//创建Field//参数1:域的名称,参数2:域的内容,参数3:是否存储Field fieldName = new TextField("name", fileName, Field.Store.YES);//Field fieldPath = new TextField("path", filePath, Field.Store.YES);Field fieldPath = new StoredField("path", filePath);Field fieldContent = new TextField("content", fileContent, Field.Store.YES);//Field fieldSize = new TextField("size", fileSize + "", Field.Store.YES);Field fieldSizeValue = new LongPoint("size", fileSize);Field fieldSizeStore = new StoredField("size", fileSize);//创建文档对象Document document = new Document();//向文档对象中添加域document.add(fieldName);document.add(fieldPath);document.add(fieldContent);//document.add(fieldSize);document.add(fieldSizeValue);document.add(fieldSizeStore);//5、把文档对象写入索引库indexWriter.addDocument(document);}//6、关闭indexwriter对象indexWriter.close();}2、使用luke查看索引库中的内容 3、查询索引库 步骤: 1、创建一个Director对象,指定索引库的位置 2、创建一个IndexReader对象 3、创建一个IndexSearcher对象,构造方法中的参数indexReader对象。 4、创建一个Query对象,TermQuery 5、执行查询,得到一个TopDocs对象 6、取查询结果的总记录数 7、取文档列表 8、打印文档中的内容 9、关闭IndexReader对象
public void searchIndex() throws Exception {//1、创建一个Director对象,指定索引库的位置Directory directory = FSDirectory.open(new File("C:\\temp\\index").toPath());//2、创建一个IndexReader对象IndexReader indexReader = DirectoryReader.open(directory);//3、创建一个IndexSearcher对象,构造方法中的参数indexReader对象。IndexSearcher indexSearcher = new IndexSearcher(indexReader);//4、创建一个Query对象,TermQueryQuery query = new TermQuery(new Term("name", "spring"));//5、执行查询,得到一个TopDocs对象//参数1:查询对象 参数2:查询结果返回的最大记录数TopDocs topDocs = indexSearcher.search(query, 10);//6、取查询结果的总记录数System.out.println("查询总记录数:" + topDocs.totalHits);//7、取文档列表ScoreDoc[] scoreDocs = topDocs.scoreDocs;//8、打印文档中的内容for (ScoreDoc doc :scoreDocs) {//取文档idint docId = doc.doc;//根据id取文档对象Document document = indexSearcher.doc(docId);System.out.println(document.get("name"));System.out.println(document.get("path"));System.out.println(document.get("size"));//System.out.println(document.get("content"));System.out.println("-----------------寂寞的分割线");}//9、关闭IndexReader对象indexReader.close();} 六、分析器 默认使用的数标准分析器StandardAnalyzer1、查看分析器的分析效果 使用Analyzer对象的tokenStream方法返回一个TokenStream对象。词对象中包含了最终分词结果。 实现步骤: 1)创建一个Analyzer对象,StandardAnalyzer对象 2)使用分析器对象的tokenStream方法获得一个TokenStream对象 3)向TokenStream对象中设置一个引用,相当于数一个指针 4)调用TokenStream对象的rest方法。如果不调用抛异常 5)使用while循环遍历TokenStream对象 6)关闭TokenStream对象
public void testTokenStream() throws Exception {//1)创建一个Analyzer对象,StandardAnalyzer对象// Analyzer analyzer = new StandardAnalyzer();Analyzer analyzer = new IKAnalyzer();//2)使用分析器对象的tokenStream方法获得一个TokenStream对象TokenStream tokenStream = analyzer.tokenStream("", "2017年12月14日 - 传智播客Lucene概述公安局Lucene是一款高性能的、可扩展的信息检索(IR)工具库。信息检索是指文档搜索、文档内信息搜索或者文档相关的元数据搜索等操作。");//3)向TokenStream对象中设置一个引用,相当于数一个指针CharTermAttribute charTermAttribute = tokenStream.addAttribute(CharTermAttribute.class);//4)调用TokenStream对象的rest方法。如果不调用抛异常tokenStream.reset();//5)使用while循环遍历TokenStream对象while(tokenStream.incrementToken()) {System.out.println(charTermAttribute.toString());}//6)关闭TokenStream对象tokenStream.close();}2、IKAnalyze的使用方法 1)把IKAnalyzer的jar包添加到工程中 2)把配置文件和扩展词典添加到工程的classpath下 注意:扩展词典严禁使用windows记事本编辑保证扩展词典的编码格式是utf-8 扩展词典:添加一些新词 停用词词典:无意义的词或者是敏感词汇
七、索引库维护1、添加文档 2、删除文档 1)删除全部 2)根据查询、关键词删除文档 3、修改文档 修改的原理是先删除后添加
八、索引库查询1、使用Query的子类 1)TermQuery 根据关键词进行查询。 需要指定要查询的域及要查询的关键词 2)RangeQuery 范围查询 2、使用QueryPaser进行查询 可以对要查询的内容先分词,然后基于分词的结果进行查询。 添加一个jar包 lucene-queryparser-7.4.0.jar
Lucene