Lucene简介

川长思鸟来 2021-10-29 11:32 367阅读 0赞

<table> 
 <tbody> 
 <tr> 
 <td style="text-align:center;">&nbsp;Lucene</td> 
 </tr> 
 </tbody> 
</table>

**目****  ****录**

1 要讲的内容 3

2 Lucene简介 3

2.1 全文检索（Full-text Search） 3

2.1.1 定义 3

2.1.2 应用场景 3

2.2 Lucene实现全文检索的流程 5

3 入门示例 5

3.1 需求 5

3.2 配置步骤说明 5

3.3 配置步骤 6

3.3.1 第一部分：搭建环境（创建项目，导入包） 6

3.3.2 第二部分：创建索引 7

3.3.3 第三部分：搜索索引 12

3.4 小结 14

4 分词 14

4.1 重要性 14

4.2 分词过程 14

4.3 分词后索引库结构 15

4.4 Luke客户端连接索引库 16

4.4.1 启动方法 16

4.4.2 验证分词效果 17

5 Field域 17

5.1 域的属性 17

5.1.1 三大属性 17

5.1.2 特点 18

5.2 Field常用类型 18

5.3 改造入门示例中的域类型 19

5.3.1 分析 19

5.3.2 代码修改 20

5.3.3 测试 21

6 索引库维护 21

6.1 添加索引(文档) 22

6.1.1 需求 22

6.1.2 代码实现 22

6.2 删除索引(文档) 22

6.2.1 需求 22

6.2.2 代码实现 22

6.2.3 清空索引库 23

6.3 更新索引(文档) 23

6.3.1 说明 23

6.3.2 代码实现 23

7 搜索 24

7.1 创建查询的两种方法 24

7.1.1 使用Lucene提供Query子类 25

7.1.2 使用QueryParse解析查询表达式 25

7.2 常用的Query子类搜索 25

7.2.1 TermQuery 25

7.2.2 NumericRangeQuery 27

7.2.3 BooleanQuery 28

7.3 通过QueryParser搜索 28

7.3.1 特点 28

7.3.2 语法 29

7.3.3 QueryParser 29

7.3.4 MultiFieldQueryParser 30

8 中文分词器 31

8.1 什么是中文分词器 31

8.2 Lucene自带的中文分词器 31

8.2.1 StandardAnalyzer： 31

8.2.2 CJKAnalyzer 31

8.3 使用中文分词器IKAnalyzer 31

8.3.1 使用luke测试IK中文分词 31

8.3.2 改造代码，使用IkAnalyzer做分词器 32

9 思考：（面试题） 33

# 1 **要讲的内容** #

（1）Lucene概述

（2）什么是全文检索

**（3）Lucene配置流程（重点）**

**（4）什么是分词（难点）**

（5）Lucene域的属性

（6）索引库维护

**（7）Lucene复杂搜索（重点）**

（8）中文分词器

# 2 **Lucene简介** #

Lucene是apache下的一个开源的全文检索引擎工具包。

## 2.1 **全文检索（****Full-text Search****）**** ** ##

### 2.1.1 **定义** ###

全文检索就是先**分词**创建索引，再执行搜索的过程。

**分词**：就是将一段文字分成一个个单词

全文检索就将一段文字分成一个个单词去查询数据！！！

### 2.1.2 **应用场景** ###

#### 2.1.2.1 **搜索引擎（了解）** ####

搜索引擎是一个基于全文检索、能独立运行、提供搜索服务的软件系统。

#### 2.1.2.2 **电商站内搜索（重点）** ####

思考：电商网站内，我们都是通过输入关键词来搜索商品的。如果我们根据关键词，直接查询数据库，会有什么后果？

答：我们只能使用模糊搜索，来进行匹配，会导致很多数据匹配不到。所以，我们必须使用全文检索。

## 2.2 **Lucene实现全文检索的流程** ##

全文检索的流程分为两大部分：索引流程、搜索流程。

**索引****流程**：采集数据\--->构建文档对象\--->创建索引(将文档写入索引库)。

**搜索****流程**：创建查询\--->执行搜索\--->渲染搜索结果。

# 3 **入门示例** #

## 3.1 **需求** ##

使用Lucene实现电商项目中图书类商品的索引和搜索功能。

## 3.2 **配置步骤说明** ##

（1）搭建环境（先下载Lucene）

（2）创建索引库

（3）搜索索引库

## 3.3 **配置步骤** ##

### 3.3.1 **第一部分：搭建环境（创建项目，导入包）** ###

前提：已经创建好了数据库（直接导入book.sql文件）

#### 3.3.1.1 **第一步****：****下载****Lucene** ####

Lucene是开发全文检索功能的工具包，使用时从官方网站下载，并解压。

官方网站：[http://lucene.apache.org/][http_lucene.apache.org]

下载地址：[http://archive.apache.org/dist/lucene/java/][http_archive.apache.org_dist_lucene_java]

下载版本：4.10.3（要求：jdk1.7及以上）

**核心包****lucene-core-4.10.3.jar****（附常用API）**

#### 3.3.1.2 **第二步****：****创建项目****，****导入包** ####

<table> 
 <tbody> 
 <tr> 
 <td> mysql5.1驱动包：mysql-connector-java-5.1.7-bin.jar 核心包：lucene-core-4.10.3.jar 分析器通用包：lucene-analyzers-common-4.10.3.jar 查询解析器包：lucene-queryparser-4.10.3.jar </td> 
 </tr> 
 </tbody> 
</table>

项目结构如下：

### 3.3.2 **第二部分：创建索引** ###

步骤说明：

（1）采集数据

（2）将数据转换成Lucene文档

（3）将文档写入索引库，创建索引

#### 3.3.2.1 **第一步：采集数据** ####

Lucene全文检索，不是直接查询数据库，所以需要先将数据采集出来。

（1）创建Book类

<table> 
 <tbody> 
 <tr> 
 <td> public&nbsp;class&nbsp;Book { private&nbsp;Integer bookId;&nbsp;&nbsp;// 图书ID private&nbsp;String name;&nbsp;&nbsp;&nbsp;// 图书名称 private&nbsp;Float price;&nbsp;&nbsp;&nbsp;&nbsp;// 图书价格 private&nbsp;String pic;&nbsp;&nbsp;&nbsp;&nbsp;// 图书图片 private&nbsp;String description;&nbsp;// 图书描述 &nbsp;&nbsp;&nbsp;&nbsp;// 补全get\set方法 } </td> 
 </tr> 
 </tbody> 
</table>

（2）创建一个BookDao类

<table> 
 <tbody> 
 <tr> 
 <td> package&nbsp;cn.gzsxt.lucene.dao; &nbsp; import&nbsp;java.sql.Connection; import&nbsp;java.sql.DriverManager; import&nbsp;java.sql.PreparedStatement; import&nbsp;java.sql.ResultSet; import&nbsp;java.sql.SQLException; import&nbsp;java.util.ArrayList; import&nbsp;java.util.List; &nbsp; import&nbsp;cn.gzsxt.lucene.pojo.Book; &nbsp; public&nbsp;class&nbsp;BookDao { public&nbsp;List&lt;Book&gt; getAll() { // 数据库链接 Connection connection&nbsp;= null; // 预编译statement PreparedStatement preparedStatement&nbsp;= null; // 结果集 ResultSet resultSet&nbsp;= null; // 图书列表 List&lt;Book&gt; list&nbsp;= new&nbsp;ArrayList&lt;Book&gt;(); try&nbsp;{ // 加载数据库驱动 Class.forName("com.mysql.jdbc.Driver"); // 连接数据库 connection&nbsp;= DriverManager.getConnection( "jdbc:mysql://localhost:3306/lucene", "root", "gzsxt"); &nbsp; // SQL语句 String sql&nbsp;= "SELECT * FROM book"; // 创建preparedStatement preparedStatement&nbsp;= connection.prepareStatement(sql); &nbsp; // 获取结果集 resultSet&nbsp;= preparedStatement.executeQuery(); &nbsp; // 结果集解析 while&nbsp;(resultSet.next()) { Book book&nbsp;= new&nbsp;Book(); book.setBookId(resultSet.getInt("id")); book.setName(resultSet.getString("name")); book.setPrice(resultSet.getFloat("price")); book.setPic(resultSet.getString("pic")); book.setDescription(resultSet.getString("description")); list.add(book); } } catch&nbsp;(Exception e) { e.printStackTrace(); &nbsp; }finally&nbsp;{ &nbsp; if(null!=resultSet){ try&nbsp;{ resultSet.close(); } catch&nbsp;(SQLException e) { // TODO&nbsp;Auto-generated catch block e.printStackTrace(); } } if(null!=preparedStatement){ try&nbsp;{ preparedStatement.close(); } catch&nbsp;(SQLException e) { // TODO&nbsp;Auto-generated catch block e.printStackTrace(); } } if(null!=connection){ try&nbsp;{ connection.close(); } catch&nbsp;(SQLException e) { // TODO&nbsp;Auto-generated catch block e.printStackTrace(); } } } return&nbsp;list; } } </td> 
 </tr> 
 </tbody> 
</table>

（3）创建一个测试类BookDaoTest

<table> 
 <tbody> 
 <tr> 
 <td> package&nbsp;cn.gzsxt.lucene.test; &nbsp; import&nbsp;java.util.List; &nbsp; import&nbsp;org.junit.Test; import&nbsp;cn.gzsxt.lucene.dao.BookDao; import&nbsp;cn.gzsxt.lucene.pojo.Book; &nbsp; public&nbsp;class&nbsp;BookDaoTest { &nbsp; @Test public&nbsp;void&nbsp;getAll(){ BookDao dao&nbsp;= new&nbsp;BookDao(); List&lt;Book&gt; books&nbsp;= dao.getAll(); &nbsp; for&nbsp;(Book book&nbsp;: books) { System.out.println("图书id:"+book.getBookId()+",图书名称:"+book.getName()); } } } </td> 
 </tr> 
 </tbody> 
</table>

（4）测试结果，采集数据成功

#### 3.3.2.2 **第二步：将数据转换成Lucene文档** ####

Lucene是使用**文档类型**来封装数据的，所有需要先将采集的数据转换成文档类型。其格式为：

修改BookDao，新增一个方法，转换数据

#### 3.3.2.3 **第三步****：****创建索引库** ####

说明：Lucene是在将文档**写入索引库的过程中，自动完成分词、创建索引的。**因此创建索引库，从形式上看，就是将文档写入索引库！

修改测试类，新增createIndex方法

<table> 
 <tbody> 
 <tr> 
 <td> @Test public&nbsp;void&nbsp;createIndex(){ try&nbsp;{ BookDao dao&nbsp;= new&nbsp;BookDao(); &nbsp; // 分析文档，对文档中的field域进行分词 Analyzer analyzer&nbsp;= new&nbsp;StandardAnalyzer(); // 创建索引 // 1) 创建索引库目录 Directory directory&nbsp;= FSDirectory.open(new&nbsp;File("F:\\lucene\\0719")); // 2) 创建IndexWriterConfig对象 IndexWriterConfig cfg&nbsp;= new&nbsp;IndexWriterConfig(Version.LATEST, analyzer); // 3) 创建IndexWriter对象 IndexWriter writer&nbsp;= new&nbsp;IndexWriter(directory, cfg); // 4) 通过IndexWriter对象添加文档对象（document） writer.addDocuments(dao.getDocuments(dao.getAll())); &nbsp; // 5) 关闭IndexWriter writer.close(); System.out.println("创建索引库成功"); &nbsp; } catch&nbsp;(Exception e) { e.printStackTrace(); } } </td> 
 </tr> 
 </tbody> 
</table>

测试结果，创建成功！！！

### 3.3.3 **第三部分****：****搜索索引** ###

#### 3.3.3.1 **说明** ####

搜索的时候，需要指定搜索哪一个域（也就是字段），并且，还要对搜索的关键词做分词处理。

#### 3.3.3.2 **执行搜索** ####

修改测试类，新增searchDocumentByIndex方法

<table> 
 <tbody> 
 <tr> 
 <td> @Test public&nbsp;void&nbsp;searchDocumentByIndex(){ try&nbsp;{ // 1、 创建查询（Query对象） // 创建分析器 Analyzer analyzer&nbsp;= new&nbsp;StandardAnalyzer(); QueryParser queryParser&nbsp;= new&nbsp;QueryParser("name", analyzer); Query query&nbsp;= queryParser.parse("name:java教程"); // 2、 执行搜索 // a) 指定索引库目录 Directory directory&nbsp;= FSDirectory.open(new&nbsp;File("F:\\lucene\\0719")); // b) 创建IndexReader对象 IndexReader reader&nbsp;= DirectoryReader.open(directory); // c) 创建IndexSearcher对象 IndexSearcher searcher&nbsp;= new&nbsp;IndexSearcher(reader); // d) 通过IndexSearcher对象执行查询索引库，返回TopDocs对象 // 第一个参数：查询对象 // 第二个参数：最大的n条记录 TopDocs topDocs&nbsp;= searcher.search(query, 10); // e) 提取TopDocs对象中前n条记录 ScoreDoc[] scoreDocs&nbsp;= topDocs.scoreDocs; System.out.println("查询出文档个数为："&nbsp;+ topDocs.totalHits); for&nbsp;(ScoreDoc scoreDoc&nbsp;: scoreDocs) { // 文档对象ID int&nbsp;docId&nbsp;= scoreDoc.doc; Document doc&nbsp;= searcher.doc(docId); // f) 输出文档内容 System.out.println("==============================="); System.out.println("文档id:"&nbsp;+ docId); System.out.println("图书id:"&nbsp;+ doc.get("id")); System.out.println("图书name:"&nbsp;+ doc.get("name")); System.out.println("图书price:"&nbsp;+ doc.get("price")); System.out.println("图书pic:"&nbsp;+ doc.get("pic")); System.out.println("图书description:"&nbsp;+ doc.get("description")); } // g) 关闭IndexReader reader.close(); } catch&nbsp;(Exception e) { // TODO&nbsp;Auto-generated catch block e.printStackTrace(); } } </td> 
 </tr> 
 </tbody> 
</table>

测试结果，非常成功！！！

## 3.4 **小结** ##

Lucene全文检索，确实可以实现对关键词做分词、再执行搜索功能。并且结果更精确。

# 4 **分词** #

## 4.1 **重要性** ##

**分词是全文检索的核心。**

** **

所谓的分词，就是将一段文本，根据一定的规则，拆分成一个一个词。

Lucene是根据分析器实现分词的。针对不同的语言提供了不同的分析器。并且提供了一个通用的标准分析器StandardAnalyzer

## 4.2 **分词过程** ##

\--说明：我们通过分析StandardAnalyzer核心源码来分析分词过程

<table> 
 <tbody> 
 <tr> 
 <td> @Override &nbsp;&nbsp;protected&nbsp;TokenStreamComponents createComponents(final&nbsp;String fieldName, final&nbsp;Reader reader) { &nbsp;&nbsp;&nbsp;&nbsp;final&nbsp;StandardTokenizer src&nbsp;= new&nbsp;StandardTokenizer(getVersion(), reader); &nbsp;&nbsp;&nbsp;&nbsp;src.setMaxTokenLength(maxTokenLength); &nbsp;&nbsp;&nbsp;&nbsp;TokenStream tok&nbsp;= new&nbsp;StandardFilter(getVersion(), src); &nbsp;&nbsp;&nbsp;&nbsp;tok&nbsp;= new&nbsp;LowerCaseFilter(getVersion(), tok); &nbsp;&nbsp;&nbsp;&nbsp;tok&nbsp;= new&nbsp;StopFilter(getVersion(), tok, stopwords); &nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;new&nbsp;TokenStreamComponents(src, tok) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;@Override &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;protected&nbsp;void&nbsp;setReader(final&nbsp;Reader reader) throws&nbsp;IOException { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;src.setMaxTokenLength(StandardAnalyzer.this.maxTokenLength); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;super.setReader(reader); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;}; &nbsp;&nbsp;} </td> 
 </tr> 
 </tbody> 
</table>

对应Lucene分词的过程，我们可以做如下总结：

（1）分词的时候，**是以域为单位的**。不同的域，相互独立。

同一个域中，拆分出来相同的词，视为同一个词**（Term）**

不同的域中，拆分出来相同的词，不是同一个词。

其中，Term是Lucene最小的语汇单元，不可再细分。

（2）分词的时候经历了一系列的**过滤**器。如大小写转换、去除停用词等。

## 4.3 **分词后索引库结构** ##

我们这里借助前面的示例来说明

从上图中，我们发现：

（1）索引库中有两个区域：索引区、文档区。

（2）文档区存放的是文档。Lucene给每一个文档自动加上一个文档编号docID。

（3）索引区存放的是索引。注意：

索引是以域为单位的，不同的域，彼此相互独立。

索引是根据分词规则创建出来的，根据索引就能找到对应的文档。

## 4.4 **Luke客户端连接索引库** ##

Luke作为Lucene工具包中的一个工具（http://www.getopt.org/luke/），可以通过可视化界面，连接操作索引库。

### 4.4.1 **启动方法** ###

(1)双击start.bat启动！

(2)连接索引库

### 4.4.2 **验证分词效果** ###

# 5 **Field域** #

问题：我们已经知道，Lucene是在写入文档时，完成分词、索引的。那Lucene是怎么知道的呢？

答：Lucene是根据文档中的域的属性，来确定是否要分词、创建索引的。所以，我们必须搞清楚域有哪些属性。

## 5.1 **域的属性** ##

### 5.1.1 **三大属性** ###

#### 5.1.1.1 **是否分词****（****tokenized****）** ####

只有设置了分词属性为**true**，lucene才会对这个域进行分词处理。

在实际的开发中，有一些字段是不需要分词的，比如商品id，商品图片等。

而有一些字段是必须分词的，比如商品名称，描述信息等。

#### 5.1.1.2 **是否索引****（indexed）** ####

只有设置了索引属性为**true**，lucene才为这个域的Term词创建索引。

在实际的开发中，有一些字段是不需要创建索引的，比如商品的图片等。我们只需要对参与搜索的字段做索引处理。

#### 5.1.1.3 **是否存储****（stored）** ####

只有设置了存储属性为**true**，在查找的时候，才能从文档中获取这个域的值。

在实际开发中，有一些字段是不需要存储的。比如：商品的描述信息。

因为商品描述信息，通常都是大文本数据，读的时候会造成巨大的IO开销。而描述信息是不需要经常查询的字段，这样的话就白白浪费了cpu的资源了。

因此，像这种不需要经常查询，又是大文本的字段，通常不会存储到索引库。

### 5.1.2 **特点** ###

（1）三大属性彼此独立。

（2）通常分词是为了创建索引。

**（3）不存储这个域文本内容，也可以对这个域先分词、创建索引。**

** **

## 5.2 **Field常用类型** ##

域的常用类型有很多，每一个类都有自己默认的三大属性。如下：

<table> 
 <tbody> 
 <tr> 
 <td> Field类 </td> 
 <td> 数据类型 </td> 
 <td> Analyzed 是否分词 </td> 
 <td> Indexed 是否索引 </td> 
 <td> Stored 是否存储 </td> 
 </tr> 
 <tr> 
 <td> StringField(FieldName, FieldValue,Store.YES)) </td> 
 <td> 字符串 </td> 
 <td> N </td> 
 <td> Y </td> 
 <td> Y或N </td> 
 </tr> 
 <tr> 
 <td> LongField(FieldName, FieldValue,Store.YES) </td> 
 <td> Long型 </td> 
 <td> Y </td> 
 <td> Y </td> 
 <td> Y或N </td> 
 </tr> 
 <tr> 
 <td> FloatField(FieldName, FieldValue,Store.YES) </td> 
 <td> Float型 </td> 
 <td> Y </td> 
 <td> Y </td> 
 <td> Y或N </td> 
 </tr> 
 <tr> 
 <td> StoredField(FieldName, FieldValue)&nbsp; </td> 
 <td> 重载方法，支持多种类型 </td> 
 <td> N </td> 
 <td> N </td> 
 <td> Y </td> 
 </tr> 
 <tr> 
 <td> TextField(FieldName, FieldValue, Store.NO) </td> 
 <td> 字符串 </td> 
 <td> Y </td> 
 <td> Y </td> 
 <td> Y或N </td> 
 </tr> 
 </tbody> 
</table>

## 5.3 **改造入门示例中的域类型** ##

### 5.3.1 **分析** ###

（1）图书id：

是否分词：不用分词，因为不会根据商品id来搜索商品

是否索引：不索引，因为不需要根据图书ID进行搜索

是否存储：要存储，因为查询结果页面需要使用id这个值。

（2）图书名称：

是否分词：要分词，因为要将图书的名称内容分词索引，根据关键搜索图书名称抽取的词。

是否索引：要索引。

是否存储：要存储。

（3）图书价格：

是否分词：要分词，**lucene对数字型的值只要有搜索需求的都要分词和索引，因为lucene对数字型的内容要特殊分词处理**，本例子可能要根据价格范围搜索，  需要分词和索引。

是否索引：要索引

是否存储：要存储

（4）图书图片地址：

是否分词：不分词

是否索引：不索引

是否存储：要存储

（5）图书描述：

是否分词：要分词

是否索引：要索引

是否存储：因为图书描述内容量大，不在查询结果页面直接显示，不存储。

不存储是来不在lucene的索引文件中记录，节省lucene的索引文件空间，如果要在详情页面显示描述，思路：

从lucene中取出图书的id，根据图书的id查询关系数据库中book表得到描述信息。

### 5.3.2 **代码修改** ###

修改BookDao的getDocument方法

<table> 
 <tbody> 
 <tr> 
 <td> public&nbsp;List&lt;Document&gt; getDocuments(List&lt;Book&gt; books){ // Document对象集合 List&lt;Document&gt; docList&nbsp;= new&nbsp;ArrayList&lt;Document&gt;(); // Document对象 Document doc&nbsp;= null; for&nbsp;(Book book&nbsp;: books) { // 创建Document对象，同时要创建field对象 doc&nbsp;= new&nbsp;Document(); &nbsp; // 图书ID // 参数：域名、域中存储的内容、是否存储 // 不分词、索引、要存储 // Field id = new TextField("id", book.getId().toString(),Store.YES); Field id = new&nbsp;StoredField("id", book.getBookId().toString()); // 图书名称 // 分词、索引、存储 Field name = new&nbsp;TextField("name", book.getName(),Store.YES); // 图书价格 // 分词、索引、存储 Field price = new&nbsp;FloatField("price", book.getPrice(), Store.YES); // 图书图片 // 不分词、不索引、要存储 Field pic = new&nbsp;StoredField("pic", book.getPic()); // 图书描述 // 分词、索引、不存储 Field desc = new&nbsp;TextField("description",book.getDescription(), Store.NO); &nbsp; &nbsp; // 把域（Field）添加到文档（Document）中 doc.add(id); doc.add(name); doc.add(price); doc.add(pic); doc.add(desc); &nbsp; docList.add(doc); } &nbsp; return&nbsp;docList; } </td> 
 </tr> 
 </tbody> 
</table>

### 5.3.3 **测试** ###

（1）去索引库目录中，手动清空索引库。

（2）重新创建索引库。

（3）使用Luke验证分词、索引效果。

改造成功！！！

# 6 **索引库维护** #

在第4节，我们需要重新创建索引的时候，是去索引库目录下，手动删除的。

而在实际的开发中，我们可能压根就不知道索引库在哪，就算知道，我们也不可能每次都去手动删除，非常之麻烦！！！

所以，我们必须学习如何维护索引库，使用程序来操作索引库。

需要注意的是，索引是与文档紧密相连的，因此对索引的维护，实际上就是对文档的**增删改**。

## 6.1 **添加索引(文档)** ##

### 6.1.1 **需求** ###

数据库中新上架了图书，必须把这些图书也添加到索引库中，不然就搜不到该新上架的图书了。

### 6.1.2 **代码实现** ###

调用 indexWriter.addDocument(doc)添加索引。

参考入门示例中的创建索引。

## 6.2 **删除索引(文档)** ##

### 6.2.1 **需求** ###

某些图书不再出版销售了，我们需要从索引库中移除该图书。

### 6.2.2 **代码实现** ###

<table> 
 <tbody> 
 <tr> 
 <td> @Test public&nbsp;void&nbsp;deleteIndex() throws&nbsp;Exception { // 1、指定索引库目录 Directory directory&nbsp;= FSDirectory.open(new&nbsp;File("F:\\lucene\\0719")); // 2、创建IndexWriterConfig IndexWriterConfig cfg&nbsp;= new&nbsp;IndexWriterConfig(Version.LATEST, new&nbsp;StandardAnalyzer()); // 3、 创建IndexWriter IndexWriter writer&nbsp;= new&nbsp;IndexWriter(directory, cfg); // 4、通过IndexWriter来删除索引 // 删除指定索引 writer.deleteDocuments(new&nbsp;Term("name", "apache")); // 5、关闭IndexWriter writer.close(); &nbsp; System.out.println("删除成功"); &nbsp; } </td> 
 </tr> 
 </tbody> 
</table>

### 6.2.3 **清空索引库** ###

<table> 
 <tbody> 
 <tr> 
 <td> @Test public&nbsp;void&nbsp;deleteIndex() throws&nbsp;Exception { // 1、指定索引库目录 Directory directory&nbsp;= FSDirectory.open(new&nbsp;File("F:\\lucene\\0719")); // 2、创建IndexWriterConfig IndexWriterConfig cfg&nbsp;= new&nbsp;IndexWriterConfig(Version.LATEST, new&nbsp;StandardAnalyzer()); // 3、 创建IndexWriter IndexWriter writer&nbsp;= new&nbsp;IndexWriter(directory, cfg); // 4、通过IndexWriter来删除索引 // 删除指定索引 writer.deleteAll(); // 5、关闭IndexWriter writer.close(); &nbsp; System.out.println("清空索引库成功"); &nbsp; } </td> 
 </tr> 
 </tbody> 
</table>

## 6.3 **更新索引(文档)** ##

### 6.3.1 **说明** ###

Lucene更新索引比较特殊，是先删除满足条件的索引，再添加新的索引。

### 6.3.2 **代码实现** ###

<table> 
 <tbody> 
 <tr> 
 <td> // 修改索引 @Test public&nbsp;void&nbsp;updateIndex() throws&nbsp;Exception { // 1、指定索引库目录 Directory directory&nbsp;= FSDirectory.open(new&nbsp;File("F:\\lucene\\0719")); // 2、创建IndexWriterConfig IndexWriterConfig cfg&nbsp;= new&nbsp;IndexWriterConfig(Version.LATEST, new&nbsp;StandardAnalyzer()); // 3、 创建IndexWriter IndexWriter writer&nbsp;= new&nbsp;IndexWriter(directory, cfg); // 4、通过IndexWriter来修改索引 // a)、创建修改后的文档对象 Document document&nbsp;= new&nbsp;Document(); &nbsp; // 文件名称 Field filenameField&nbsp;= new&nbsp;StringField("name", "updateIndex", Store.YES); document.add(filenameField); &nbsp; // 修改指定索引为新的索引 writer.updateDocument(new&nbsp;Term("name", "apache"), document); &nbsp; // 5、关闭IndexWriter writer.close(); &nbsp; System.out.println("更新成功"); } </td> 
 </tr> 
 </tbody> 
</table>

# 7 **搜索** #

问题：我们在入门示例中，已经知道Lucene是通过IndexSearcher对象，来执行搜索的。那我们为什么还要继续学习Lucene呢？

答：因为在实际的开发中，我们的查询的业务是相对复杂的，比如我们在通过关键词查找的时候，往往进行价格、商品类别的过滤。

而Lucene提供了一套查询方案，供我们实现复杂的查询。

## 7.1 **创建查询的两种方法** ##

执行查询之前，必须创建一个查询Query查询对象。

Query自身是一个抽象类，不能实例化，必须通过其它的方式来实现初始化。

在这里，Lucene提供了两种初始化Query查询对象的方式。

### 7.1.1 **使用Lucene提供Query子类** ###

Query是一个抽象类，lucene提供了很多查询对象，比如TermQuery项精确查询，NumericRangeQuery数字范围查询等。

使用TermQuery实例化

<table> 
 <tbody> 
 <tr> 
 <td> Query query = new&nbsp;TermQuery(new&nbsp;Term("name", "lucene")); </td> 
 </tr> 
 </tbody> 
</table>

### 7.1.2 **使用QueryParse解析查询表达式** ###

QueryParser会将用户输入的查询表达式解析成Query对象实例。如下代码：

<table> 
 <tbody> 
 <tr> 
 <td> QueryParser queryParser = new&nbsp;QueryParser("name", new&nbsp;IKAnalyzer()); Query query&nbsp;= queryParser.parse("name:lucene"); </td> 
 </tr> 
 </tbody> 
</table>

## 7.2 **常用****的Query子类搜索** ##

### 7.2.1 **TermQuery** ###

特点：查询的关键词不会再做分词处理，作为整体来搜索。代码如下：

<table> 
 <tbody> 
 <tr> 
 <td> /** &nbsp;* Query子类查询之 TermQuery &nbsp;* &nbsp; &nbsp;* 特点：不会再对查询的关键词做分词处理。 &nbsp;* &nbsp;* 需要：查询书名与java教程相关书。 &nbsp;*/ @Test public&nbsp;void&nbsp;queryByTermQuery(){ //1、获取一个查询对象 Query query&nbsp;= new&nbsp;TermQuery(new&nbsp;Term("name", "编程思想")); doSearch(query); &nbsp; } &nbsp;&nbsp;&nbsp;private&nbsp;void&nbsp;doSearch(Query query) { try&nbsp;{ &nbsp; &nbsp; //2、创建一个查询的执行对象 //指定索引库的目录 Directory d&nbsp;= FSDirectory.open(new&nbsp;File("F:\\lucene\\0719")); //创建流对象 IndexReader reader&nbsp;= DirectoryReader.open(d); //创建搜索执行对象 IndexSearcher searcher&nbsp;= new&nbsp;IndexSearcher(reader); &nbsp; //3、执行搜索 TopDocs result&nbsp;= searcher.search(query, 10); &nbsp; //4、提出结果集，获取图书的信息 int&nbsp;totalHits&nbsp;= result.totalHits; System.out.println("共查询到"+totalHits+"条满足条件的数据!"); System.out.println("-----------------------------------------"); //提取图书信息。 //score即相关度。即搜索的关键词和 图书名称的相关度，用来做排序处理 ScoreDoc[] scoreDocs&nbsp;= result.scoreDocs; &nbsp; for&nbsp;(ScoreDoc scoreDoc&nbsp;: scoreDocs) { /** &nbsp;* scoreDoc.doc的返回值，是文档的id， 即 将文档写入索引库的时候，lucene自动给这份文档做的一个编号。 &nbsp;* &nbsp;* 获取到这个文档id之后，即可以根据这个id，找到这份文档。 &nbsp;*/ int&nbsp;docId&nbsp;= scoreDoc.doc; System.out.println("文档在索引库中的编号:"+docId); &nbsp; //从文档中提取图书的信息 Document doc&nbsp;= searcher.doc(docId); System.out.println("图书id:"+doc.get("id")); System.out.println("图书name:"+doc.get("name")); System.out.println("图书price:"+doc.get("price")); System.out.println("图书pic:"+doc.get("pic")); System.out.println("图书description:"+doc.get("description")); System.out.println(); System.out.println("------------------------------------"); &nbsp; } &nbsp; //关闭连接，释放资源 if(null!=reader){ reader.close(); } } catch&nbsp;(Exception e) { e.printStackTrace(); } } </td> 
 </tr> 
 </tbody> 
</table>

### 7.2.2 **NumericRangeQuery** ###

指定数字范围查询.（创建field类型时，注意与之对应）

<table> 
 <tbody> 
 <tr> 
 <td> /** &nbsp;* Query子类查询 &nbsp;之 &nbsp;NumricRangeQuery &nbsp;* 需求：查询所有价格在[60,80)之间的书 &nbsp;* @param&nbsp;query &nbsp;*/ @Test &nbsp;&nbsp;&nbsp;&nbsp;public&nbsp;void&nbsp;queryByNumricRangeQuery(){ &nbsp;&nbsp;&nbsp;&nbsp; /** &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* 第一个参数：要搜索的域 &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* 第二个参数：最小值 &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* 第三个参数：最大值 &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* 第四个参数：是否包含最小值 &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* 第五个参数：是否包含最大值 &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp; Query query&nbsp;= NumericRangeQuery.newFloatRange("price", 60.0f, 80.0f, true, false); &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; doSearch(query); &nbsp;&nbsp;&nbsp;&nbsp;} </td> 
 </tr> 
 </tbody> 
</table>

### 7.2.3 **BooleanQuery** ###

BooleanQuery，布尔查询，实现组合条件查询。

<table> 
 <tbody> 
 <tr> 
 <td> /** &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* Query子类查询 &nbsp;之 &nbsp;BooelanQuery查询 &nbsp;&nbsp;组合条件查询 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;* 需求：查询书名包含java，并且价格区间在[60,80)之间的书。 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp;@Test &nbsp;&nbsp;&nbsp;&nbsp;public&nbsp;void&nbsp;queryBooleanQuery(){ &nbsp;&nbsp;&nbsp;&nbsp; //1、要使用BooelanQuery查询，首先要把单个创建出来，然后再通过BooelanQuery组合 &nbsp;&nbsp;&nbsp;&nbsp; Query price&nbsp;= NumericRangeQuery.newFloatRange("price", 60.0f, 80.0f, true, false); &nbsp;&nbsp;&nbsp;&nbsp; Query name&nbsp;= new&nbsp;TermQuery(new&nbsp;Term("name", "java")); &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; //2、创建BooleanQuery实例对象 &nbsp;&nbsp;&nbsp;&nbsp; BooleanQuery query&nbsp;= new&nbsp;BooleanQuery(); &nbsp;&nbsp;&nbsp;&nbsp; query.add(name, Occur.MUST_NOT); &nbsp;&nbsp;&nbsp;&nbsp; query.add(price, Occur.MUST); &nbsp;&nbsp;&nbsp;&nbsp; /** &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* MSUT &nbsp;表示必须满足 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;对应的是 &nbsp;+ &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* MSUT_NOT &nbsp;必须不满足 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;应对的是 &nbsp;- &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* SHOULD &nbsp;可以满足也可以不满足 &nbsp;&nbsp;&nbsp;&nbsp;没有符号 &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* SHOULD 与MUST、MUST_NOT组合的时候，SHOULD就没有意义了。 &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; doSearch(query); &nbsp;&nbsp;&nbsp;&nbsp;} </td> 
 </tr> 
 </tbody> 
</table>

## 7.3 **通过QueryParser搜索** ##

### 7.3.1 **特点** ###

对搜索的关键词，做分词处理。

### 7.3.2 **语法** ###

#### 7.3.2.1 **基础语法** ####

#### 7.3.2.2 **组合条件语法** ####

### 7.3.3 **QueryParser** ###

#### 7.3.3.1 **代码实现** ####

<table> 
 <tbody> 
 <tr> 
 <td> /** &nbsp;* 查询解析器查询 &nbsp;之 &nbsp;QueryParser查询 &nbsp;*/ @Test public&nbsp;void&nbsp;queryByQueryParser(){ try&nbsp;{ &nbsp; //1、加载分词器 Analyzer analyzer&nbsp;= new&nbsp;StandardAnalyzer(); &nbsp; /** &nbsp;* 2、创建查询解析器实例对象 &nbsp;* 第一个参数：默认搜索的域。 &nbsp;* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;如果在搜索的时候，没有特别指定搜索的域，则按照默认的域进行搜索 &nbsp;* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;如何在搜索的时候指定搜索域呢？ &nbsp;* &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;答：格式 &nbsp;域名：关键词 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;即 &nbsp;&nbsp;name:java教程 &nbsp;* &nbsp;* 第二个参数：分词器 &nbsp;&nbsp;，对关键词做分词处理 &nbsp;*/ QueryParser parser&nbsp;= new&nbsp;QueryParser("description", analyzer); &nbsp; Query query&nbsp;= parser.parse("name:java教程"); &nbsp; doSearch(query); &nbsp; } catch&nbsp;(Exception e) { e.printStackTrace(); } } </td> 
 </tr> 
 </tbody> 
</table>

### 7.3.4 **MultiF****ieldQueryParser** ###

通过MulitFieldQueryParse对多个域查询。

<table> 
 <tbody> 
 <tr> 
 <td> /** &nbsp;* 查询解析器查询 &nbsp;之 &nbsp;MultiFieldQueryParser查询 &nbsp;* &nbsp; &nbsp;* &nbsp;&nbsp;&nbsp;&nbsp;特点：同时指定多个搜索域，并且对关键做分词处理 &nbsp;*/ @Test public&nbsp;void&nbsp;queryByMultiFieldQueryParser(){ try&nbsp;{ &nbsp; //1、定义多个搜索的 &nbsp;name、description String[] fields&nbsp;= {"name","description"}; //2、加载分词器 Analyzer analyzer&nbsp;= new&nbsp;StandardAnalyzer(); &nbsp; //3、创建 MultiFieldQueryParser实例对象 MultiFieldQueryParser mParser&nbsp;= new&nbsp;MultiFieldQueryParser(fields, analyzer); &nbsp; Query query&nbsp;= mParser.parse("lucene教程"); &nbsp; doSearch(query); } catch&nbsp;(Exception e) { e.printStackTrace(); } } </td> 
 </tr> 
 </tbody> 
</table>

# 8 **中文****分词器** #

## 8.1 **什么是中文分词器** ##

学过英文的都知道，英文是以单词为单位的，**单词与单词之间以空格或者逗号句号隔开**。

而中文的语义比较特殊，很难像英文那样，一个汉字一个汉字来划分。

所以需要一个能自动识别中文语义的分词器。

## 8.2 **Lucene自带的中文分词器** ##

### 8.2.1 **StandardAnalyzer****：** ###

**单字分词**：就是按照中文一个字一个字地进行分词。如：“我爱中国”，  
效果：“我”、“爱”、“中”、“国”。

### 8.2.2 **CJKAnalyzer** ###

**二分法分词**：按两个字进行切分。如：“我是中国人”，效果：“我是”、“是中”、“中国”“国人”。

上边两个分词器无法满足需求。

## 8.3 **使用中文分词器IKAnalyzer** ##

IKAnalyzer继承Lucene的Analyzer抽象类，使用IKAnalyzer和Lucene自带的分析器方法一样，将Analyzer测试代码改为IKAnalyzer测试中文分词效果。

如果使用中文分词器ik-analyzer，就在索引和搜索程序中使用一致的分词器ik-analyzer。

### 8.3.1 **使用luke测试IK中文分词** ###

（1）打开Luke，不要指定Lucene目录。否则看不到效果

（2）在分词器栏，手动输入IkAnalyzer的全路径

org.wltea.analyzer.lucene.IKAnalyzer

### 8.3.2 **改造代码，使用IkAnalyzer做分词器** ###

#### 8.3.2.1 **添加jar包** ####

#### 8.3.2.2 **修改分词器代码** ####

<table> 
 <tbody> 
 <tr> 
 <td> // 创建中文分词器 Analyzer analyzer = new&nbsp;IKAnalyzer(); </td> 
 </tr> 
 </tbody> 
</table>

#### 8.3.2.3 **扩展中文词库** ####

拓展词库的作用：在分词的过程中，保留定义的这些词

1在src或其他source目录下建立自己的拓展词库，mydict.dic文件，例如：

2在src或其他source目录下建立自己的停用词库，ext\_stopword.dic文件

停用词的作用：在分词的过程中，分词器会忽略这些词。

3在src或其他source目录下建立IKAnalyzer.cfg.xml，内容如下（注意路径对应）：

<table> 
 <tbody> 
 <tr> 
 <td> &lt;?xml&nbsp;version="1.0"&nbsp;encoding="UTF-8"?&gt; &lt;!DOCTYPE&nbsp;properties&nbsp;SYSTEM&nbsp;"http://java.sun.com/dtd/properties.dtd"&gt;&nbsp;&nbsp; &lt;properties&gt;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&lt;comment&gt;IK Analyzer 扩展配置&lt;/comment&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;!-- 用户可以在这里配置自己的扩展字典 --&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;entry&nbsp;key="ext_dict"&gt;mydict.dic&lt;/entry&gt;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;!-- 用户可以在这里配置自己的扩展停用词字典 &nbsp;&nbsp;&nbsp;--&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;entry&nbsp;key="ext_stopwords"&gt;ext_stopword.dic&lt;/entry&gt; &lt;/properties&gt; &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

如果想配置扩展词和停用词，就创建扩展词的文件和停用词的文件，文件的编码要是utf-8。

注意：**不要用记事本保存扩展词文件和停用词文件****，****那样的话****，****格式中是含有bom的**。

# 9 **思考：（面试题）** #

在一堆文件中，如何快速根据关键词找出对应的文件？

思路：（1）使用全文检索来解决问题

（2）数据源由数据库变成一堆文件。

（3）从一堆文件中，读出里面的内容，转成文档，创建索引库。

（4）创建索引库之后，再根据关键词搜索索引库，找出文件的名称。

问题：如何读文件的内容？

答：txt文本，直接使用IO即可。

doc|docx  使用POI读取内容。

转载于:https://www.cnblogs.com/meizhoulqp/p/11197024.html