Lucene(一)

1. 搜索技术理论基础

1.1 为什么要学习Lucene

原来的方式实现搜索功能，我们的搜索流程如下图：

上图就是原始搜索引擎技术，如果用户比较少而且数据库的数据量比较小，那么这种方式实现搜索功能在企业中是比较常见的。

但是数据量过多时，数据库的压力就会变得很大，查询速度会变得非常慢。我们需要使用更好的解决方案来分担数据库的压力。

现在的方案（使用Lucene），如下图

为了解决数据库压力和速度的问题，我们的数据库就变成了索引库，我们使用Lucene的API的来操作服务器上的索引库。这样完全和数据库进行了隔离。

1.2 数据查询方法

1.2.1 顺序扫描法

算法描述：

所谓顺序扫描，例如要找内容包含一个字符串的文件，就是一个文档一个文档的看，对于每一个文档，从头看到尾，如果此文档包含此字符串，则此文档为我们要找的文件，接着看下一个文件，直到扫描完所有的文件。

优点：

查询准确率高

缺点：

查询速度会随着查询数据量的增大， 越来越慢

使用场景：

• 数据库中的like关键字模糊查询
• 文本编辑器的Ctrl + F 查询功能

1.2.2 倒排索引

先举一个栗子：

例如我们使用新华字典查询汉字，新华字典有偏旁部首的目录（索引），我们查字首先查这个目录，找到这个目录中对应的偏旁部首，就可以通过这个目录中的偏旁部首找到这个字所在的位置（文档）。

Lucene会对文档建立倒排索引

1 、 提取资源中关键信息， 建立索引 （目录）

2 、 搜索时，根据关键字（目录），找到资源的位置

算法描述：

查询前会先将查询的内容提取出来组成文档(正文), 对文档进行切分词组成索引(目录), 索引和文档有关联关系, 查询的时候先查询索引, 通过索引找文档的这个过程叫做全文检索。

切分词 :

就是将一句一句话切分成一个一个的词, 去掉停用词(的, 地, 得, a, an, the等)。去掉空格, 去掉标点符号, 大写字母转成小写字母, 去掉重复的词。

为什么倒排索引比顺序扫描快?

理解 : 因为索引可以去掉重复的词, 汉语常用的字和词大概等于, 字典加词典, 常用的英文在牛津词典也有收录.如果用计算机的速度查询, 字典+词典+牛津词典这些内容是非常快的. 但是用这些字典, 词典组成的文章却是千千万万不计其数. 索引的大小最多也就是字典+词典. 所以通过查询索引, 再通过索引和文档的关联关系找到文档速度比较快. 顺序扫描法则是直接去逐个查询那些不计其数的文章就算是计算的速度也会很慢.

优点：

查询准确率高

查询速度快， 并且不会因为查询内容量的增加， 而使查询速度逐渐变慢

缺点：

索引文件会占用额外的磁盘空间， 也就是占用磁盘量会增大。

使用场景：

海量数据查询

1.3 全文检索技术应用场景

应用场景 ：

1 、 站内搜索 （baidu贴吧、论坛、 京东、 taobao）

2 、 垂直领域的搜索 （ 818 工作网）

3 、 专业搜索引擎公司 （google、baidu）

2. Lucene介绍

2.1 什么是全文检索

计算机索引程序通过扫描文章中的每一个词，对每一个词建立一个索引，指明该词在文章中出现的次数和位置，当用户查询时，检索程序就根据事先建立的索引进行查找，并将查找的结果反馈给用户的检索方式

2.2 什么是Lucene

他是Lucene、Nutch 、Hadoop等项目的发起人Doug Cutting

Lucene是apache软件基金会4 jakarta项目组的一个子项目，是一个开放源代码的全文检索引擎工具包，但它不是一个完整的全文检索引擎，而是一个全文检索引擎的架构，提供了完整的查询引擎和索引引擎，部分文本分析引擎（英文与德文两种西方语言）。

Lucene的目的是为软件开发人员提供一个简单易用的工具包，以方便的在目标系统中实现全文检索的功能，或者是以此为基础建立起完整的全文检索引擎。

目前已经有很多应用程序的搜索功能是基于 Lucene 的，比如 Eclipse 的帮助系统的搜索功能。Lucene能够为文本类型的数据建立索引，所以你只要能把你要索引的数据格式转化的文本的，Lucene 就能对你的文档进行索引和搜索。比如你要对一些 HTML 文档，PDF 文档进行索引的话你就首先需要把HTML 文档和 PDF 文档转化成文本格式的，然后将转化后的内容交给 Lucene 进行索引，然后把创建好的索引文件保存到磁盘或者内存中，最后根据用户输入的查询条件在索引文件上进行查询。不指定要索引的文档的格式也使 Lucene 能够几乎适用于所有的搜索应用程序。

• Lucene是一套用于全文检索和搜寻的开源程式库，由Apache软件基金会支持和提供
• Lucene提供了一个简单却强大的应用程式接口，能够做全文索引和搜寻， 在Java开发环境里Lucene是一个成熟的免费开放源代码工具
• Lucene并不是现成的搜索引擎产品，但可以用来制作搜索引擎产品

2.3 Lucene官网

官网： http://lucene.apache.org/

3. Lucene全文检索的流程

3.1 索引和搜索流程图

1 、绿色表示索引过程，对要搜索的原始内容进行索引构建一个索引库，索引过程包括：

确定原始内容即要搜索的内容

• 获得文档
• 创建文档
• 分析文档
• 索引文档

2 、红色表示搜索过程，从索引库中搜索内容，搜索过程包括：

用户通过搜索界面

• 创建查询
• 执行搜索，从索引库搜索
• 渲染搜索结果

3.2 索引流程

对文档索引的过程，将用户要搜索的文档内容进行索引，索引存储在索引库（index）中。

3.2.1 原始内容

原始内容是指要索引和搜索的内容。

原始内容包括互联网上的网页、数据库中的数据、磁盘上的文件等。

3.2.2 获得文档（采集数据）

从互联网上、数据库、文件系统中等获取需要搜索的原始信息，这个过程就是信息采集，采集数据的目的是为了对原始内容进行索引。

采集数据分类：

1 、对于互联网上网页，可以使用工具将网页抓取到本地生成html文件。

2 、数据库中的数据，可以直接连接数据库读取表中的数据。

3 、文件系统中的某个文件，可以通过I/O操作读取文件的内容。

在Internet上采集信息的软件通常称为爬虫或蜘蛛，也称为网络机器人，爬虫访问互联网上的每一个网页，将获取到的网页内容存储起来。

3.2.3 创建文档

获取原始内容的目的是为了索引，在索引前需要将原始内容创建成文档（Document），文档中包括一个一个的域（Field），域中存储内容。

这里我们可以将磁盘上的一个文件当成一个document，Document中包括一些Field，如下图：

注意：每个Document可以有多个Field，不同的Document可以有不同的Field，同一个Document可以有相同的Field（域名和域值都相同）

3.2.4 分析文档

将原始内容创建为包含域（Field）的文档（document），需要再对域中的内容进行分析，分析成为一个一个的单词。

比如下边的文档经过分析如下：

原文档内容：

vivo X23 8GB+128GB 幻夜蓝 全网通4G手机

华为 HUAWEI 麦芒7 6G+64G 亮黑色 全网通4G手机

分析后得到的词：

vivo, x23, 8GB, 128GB, 幻夜, 幻夜蓝, 全网, 全网通, 网通, 4G, 手机, 华为, HUAWEI, 麦芒 7 。。。。

3.2.5 索引文档

对所有文档分析得出的语汇单元进行索引，索引的目的是为了搜索，最终要实现只搜索被索引的语汇单元从而找到Document（文档）。

创建索引是对语汇单元索引，通过词语找文档，这种索引的结构叫倒排索引结构。

倒排索引结构是根据内容（词汇）找文档，如下图：

倒排索引结构也叫反向索引结构，包括索引和文档两部分，索引即词汇表，它的规模较小，而文档集合较大。

3.2.6 Lucene底层存储结构

3.3 搜索流程

搜索就是用户输入关键字，从索引中进行搜索的过程。根据关键字搜索索引，根据索引找到对应的文档，从而找到要搜索的内容。

3.3.1 用户

就是使用搜索的角色，用户可以是自然人，也可以是远程调用的程序。

3.3.2 用户搜索界面

全文检索系统提供用户搜索的界面供用户提交搜索的关键字，搜索完成展示搜索结果。如下图：

Lucene不提供制作用户搜索界面的功能，需要根据自己的需求开发搜索界面。

3.3.3 创建查询

用户输入查询关键字执行搜索之前需要先构建一个查询对象，查询对象中可以指定查询要查询关键字、要搜索的Field文档域等，查询对象会生成具体的查询语法，比如：

name:手机 : 表示要搜索name这个Field域中，内容为“手机”的文档。

name:华为 AND 手机 : 表示要搜索即包括关键字“华为” 并且也包括“手机”的文档。

3.3.4 执行搜索

搜索索引过程：

1.根据查询语法在倒排索引词典表中分别找出对应搜索词的索引，从而找到索引所链接的文档链表。

例如搜索语法为 “name:华为 AND 手机 ” 表示搜索出的文档中既要包括”华为”也要包括”手机”。

2 、由于是AND，所以要对包含 华为 和 手机 词语的链表进行交集，得到文档链表应该包括每一个搜索词语

3 、获取文档中的Field域数据。

3.3.5 渲染结果

以一个友好的界面将查询结果展示给用户，用户根据搜索结果找自己想要的信息，为了帮助用户很快找到自己的结果，提供了很多展示的效果，比如搜索结果中将关键字高亮显示，百度提供的快照等。

4. Lucene入门

4.1 Lucene准备

Lucene可以在官网上下载。课程已经准备好了Lucene的文件，我们使用的是7.7.2版本，文件位置如下图：

解压后的效果：

使用这三个文件的jar包，就可以实现lucene功能

4.2 开发环境

JDK： 1.8 （Lucene7以上，必须使用JDK1.8及以上版本）

数据库： MySQL

数据库脚本位置如下图：

导入到MySQL效果如下图：

4.3 创建Java工程

创建maven工程不依赖骨架, 测试即可，效果如下：

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.wgy</groupId>
    <artifactId>luceneDemo</artifactId>
    <version>1.0-SNAPSHOT</version>

    <properties>
        <maven.compiler.source>1.8</maven.compiler.source>
        <maven.compiler.target>1.8</maven.compiler.target>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <skipTests>true</skipTests>
    </properties>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.4.RELEASE</version>
    </parent>

    <dependencies>
        <dependency>
            <groupId>commons-io</groupId>
            <artifactId>commons-io</artifactId>
            <version>2.6</version>
        </dependency>
        <dependency>
            <groupId>org.apache.lucene</groupId>
            <artifactId>lucene-core</artifactId>
            <version>7.7.2</version>
        </dependency>
        <dependency>
            <groupId>org.apache.lucene</groupId>
            <artifactId>lucene-analyzers-common</artifactId>
            <version>7.7.2</version>
        </dependency>
        <dependency>
            <groupId>org.apache.lucene</groupId>
            <artifactId>lucene-queryparser</artifactId>
            <version>7.7.2</version>
        </dependency>

        <!-- 测试 -->
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
            <scope>test</scope>
        </dependency>
        <!-- mysql数据库驱动 -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.48</version>
        </dependency>

        <!-- IK中文分词器 -->
        <dependency>
            <groupId>org.wltea.ik-analyzer</groupId>
            <artifactId>ik-analyzer</artifactId>
            <version>8.1.0</version>
        </dependency>

        <!--web起步依赖-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- 引入thymeleaf -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-thymeleaf</artifactId>
        </dependency>
        <!-- Json转换工具 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.51</version>
        </dependency>
    </dependencies>
</project>

4.4 索引流程

4.4.1 数据采集

在电商网站中，全文检索的数据源在数据库中，需要通过jdbc访问数据库中 sku 表的内容。

4.4.1.1 创建pojo

/**
 * 商品实体类
 *
 * @author wgy
 */
public class Sku {

    //商品主键id
    private String id;
    //商品名称
    private String name;
    //价格
    private Integer price;
    //库存数量
    private Integer num;
    //图片
    private String image;
    //分类名称
    private String categoryName;
    //品牌名称
    private String brandName;
    //规格
    private String spec;
    //销量
    private Integer saleNum;
    
    get/set/toString...
    
}

4.4.1.2 创建DAO接口

/**
 * 持久层接口
 *
 * @author wgy
 */
public interface SkuDao {

    /**
     * 查询所有的Sku数据
     *
     * @return
     **/
    public List<Sku> querySkuList();
}

4.4.1.3 创建DAO接口实现类

使用jdbc实现

/**
 * 持久层实现类
 *
 * @author wgy
 */
public class SkuDaoImpl implements SkuDao {
    @Override
    public List<Sku> querySkuList() {
        // 数据库链接
        Connection connection = null;
        // 预编译statement
        PreparedStatement preparedStatement = null;
        // 结果集
        ResultSet resultSet = null;
        // 商品列表
        List<Sku> list = new ArrayList<Sku>();

        try {
            // 加载数据库驱动
            Class.forName("com.mysql.jdbc.Driver");
            // 连接数据库
            connection = (Connection) DriverManager.getConnection("jdbc:mysql://localhost:3306/lucene", "root", "root");

            // SQL语句
            String sql = "SELECT * FROM tb_sku";
            // 创建preparedStatement
            preparedStatement = (PreparedStatement) connection.prepareStatement(sql);
            // 获取结果集
            resultSet = preparedStatement.executeQuery();
            // 结果集解析
            while (resultSet.next()) {
                Sku sku = new Sku();
                sku.setId(resultSet.getString("id"));
                sku.setName(resultSet.getString("name"));
                sku.setSpec(resultSet.getString("spec"));
                sku.setBrandName(resultSet.getString("brand_name"));
                sku.setCategoryName(resultSet.getString("category_name"));
                sku.setImage(resultSet.getString("image"));
                sku.setNum(resultSet.getInt("num"));
                sku.setPrice(resultSet.getInt("price"));
                sku.setSaleNum(resultSet.getInt("sale_num"));
                list.add(sku);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }

        return list;
    }
}

4.4.2 实现索引流程

1. 采集数据
2. 创建Document文档对象
3. 创建分析器（分词器）
4. 创建Directory对象，声明索引库存储位置
5. 创建IndexWriterConfig配置信息类
6. 创建IndexWriter写入对象
7. 把Document写入到索引库中
8. 释放资源

/**
 * 索引库维护
 *
 * @author wgy
 */
public class TestIndexManager {

    /**
     * 创建索引库
     */
    @Test
    public void createIndexTest() throws Exception {
        // 1. 采集数据
        SkuDao skuDao = new SkuDaoImpl();
        List<Sku> skuList = skuDao.querySkuList();
        // 2. 创建Document文档对象
        List<Document> documents = new ArrayList<Document>();
        for (Sku sku : skuList) {
            Document document = new Document();
            // Document文档中添加Field域
            // 商品Id
            // Store.YES:表示存储到文档域中
            document.add(new TextField("id", sku.getId(), Field.Store.YES));
            // 商品名称
            document.add(new TextField("name", sku.getName(), Field.Store.YES));
            // 商品价格
            document.add(new TextField("price", String.valueOf(sku.getPrice()), Field.Store.YES));
            // 品牌名称
            document.add(new TextField("brandName", sku.getBrandName(), Field.Store.YES));
            // 分类名称
            document.add(new TextField("categoryName", sku.getCategoryName(), Field.Store.YES));
            // 图片地址
            document.add(new TextField("image", sku.getImage(), Field.Store.YES));
            // 把Document放到list中
            documents.add(document);
        }
        //3. 创建分词器, StandardAnalyzer标准分词器, 对英文分词效果好, 对中文是单字分词, 也就是一个字就认为是一个词.
        Analyzer analyzer = new StandardAnalyzer();
        //4. 创建Directory目录对象，目录对象表示索引库的位置
        Directory dir = FSDirectory.open(Paths.get("E:\\LuceneDir"));
        //5. 创建IndexWriterConfig对象，这个对象中指定切分词使用的分词器
        IndexWriterConfig config = new IndexWriterConfig(analyzer);
        //6. 创建IndexWriter输出流对象，指定输出的位置和使用的config初始化对象
        IndexWriter indexWriter = new IndexWriter(dir, config);
        //7. 写入文档到索引库
        for (Document document : docList) {
            indexWriter.addDocument(document);
        }
        //8. 释放资源
        indexWriter.close();
    }
}

执行效果：

在文件夹中出现了以下文件，表示创建索引成功

4.5 使用Luke查看索引

Luke作为Lucene工具包中的一个工具（http://www.getopt.org/luke/），可以通过界面来进行索引文件的查询、修改

luke所在位置如下图：

将luke-swing-8.0.0里面的内容, 放到一个硬盘根目录的文件夹下, 不能有空格和中文名称.

运行luke.bat

打开后，使用如下图：

下图是索引域的展示效果：

下图是文档域展示效果

4.6 搜索流程

4.6.1 输入查询语句

Lucene可以通过query对象输入查询语句。同数据库的sql一样，lucene也有固定的查询语法：

最基本的有比如：AND, OR, NOT 等（必须大写）

举个栗子:

用户想找一个 name 域中包括 手 或 机 关键字的文档。

它对应的查询语句：name:手 OR name:机

如下图是使用luke搜索的例子：

4.6.1.1 搜索分词

和索引过程的分词一样，这里要对用户输入的关键字进行分词，一般情况索引和搜索使用的分词器一致。

比如：输入搜索关键字“java学习”，分词后为java和学习两个词，与java和学习有关的内容都搜索出来了，如下：

4.6.2 代码实现

1. 创建Query搜索对象
2. 创建Directory流对象,声明索引库位置
3. 创建索引读取对象IndexReader
4. 创建索引搜索对象IndexSearcher
5. 使用索引搜索对象，执行搜索，返回结果集TopDocs
6. 解析结果集
7. 释放资源

IndexSearcher搜索方法如下：

方法	说明
indexSearcher.search(query, n)	根据Query搜索，返回评分最高的n条记录
indexSearcher.search(query, filter, n)	根据Query搜索，添加过滤策略，返回评分最高的n条记录
indexSearcher.search(query, n, sort)	根据Query搜索，添加排序策略，返回评分最高的n条记录
indexSearcher.search(query,filter, n, sort)	根据Query搜索，添加过滤策略，添加排序策略，返回评分最高的n条记录

代码实现

/**
 * 测试搜索过程
 *
 * @author wgy
 */
public class TestSearch {

    @Test
    public void testIndexSearch() throws Exception {
        //1. 创建Query搜索对象
        //1.1 创建分词器(对搜索的关键词进行分词使用)
        //注意: 分词器要和创建索引的时候使用的分词器一模一样
        Analyzer analyzer = new StandardAnalyzer();
        //1.2 创建搜索解析器
        //第一个参数: 默认查询域, 如果查询的关键字中带搜索的域名, 则从指定域中查询, 如果不带域名则从, 默认搜索域中查询
        //queryParser.parse("brandName:华为手机");
        //第二个参数: 使用的分词器
        QueryParser queryParser = new QueryParser("name", analyzer);
        //1.3 创建搜索对象
        //华 OR  为   手   机
        Query query = queryParser.parse("华为手机");
        //2. 创建Directory流对象,声明索引库位置
        Directory dir = FSDirectory.open(Paths.get("E:\\LuceneDir"));
        //3. 创建索引读取对象IndexReader
        IndexReader indexReader = DirectoryReader.open(dir);
        //4. 创建索引搜索对象
        IndexSearcher indexSearcher = new IndexSearcher(indexReader);
        //5. 使用索引搜索对象，执行搜索，返回结果集TopDocs
        // 第一个参数：搜索对象，第二个参数：返回的数据条数，指定查询结果最顶部的n条数据返回
        TopDocs topDocs = indexSearcher.search(query, 10);

        //获取查询到的结果集的总数, 打印
        System.out.println("=======count=======" + topDocs.totalHits);
        //5.1 获取结果集
        ScoreDoc[] scoreDocs = topDocs.scoreDocs;
        //6. 解析结果集
        if (scoreDocs != null) {
            for (ScoreDoc scoreDoc : scoreDocs) {
                //获取查询到的文档唯一标识, 文档id, 这个id是lucene在创建文档的时候自动分配的
                int docID = scoreDoc.doc;
                //通过文档id, 读取文档
                Document doc = indexSearcher.doc(docID);
                System.out.println("==================================================");
                //通过域名, 从文档中获取域值
                System.out.println("===id==" + doc.get("id"));
                System.out.println("===name==" + doc.get("name"));
                System.out.println("===price==" + doc.get("price"));
                System.out.println("===image==" + doc.get("image"));
                System.out.println("===brandName==" + doc.get("brandName"));
                System.out.println("===categoryName==" + doc.get("categoryName"));
            }
        }
        //7. 关闭流
        indexReader.close();
    }
}

5. Field域类型

5.1 Field属性

Field是文档中的域，包括Field名和Field值两部分，一个文档可以包括多个Field，Document只是Field的一个承载体，Field值即为要索引的内容，也是要搜索的内容。

是否分词(tokenized)

是：作分词处理，即将Field值进行分词，分词的目的是为了索引。

比如：商品名称、商品描述等，这些内容用户要输入关键字搜索，由于搜索的内容格式大、内容多需要分词后将语汇单元建立索引

否：不作分词处理

比如：商品id、订单号、身份证号等

是否索引(indexed)

是：进行索引。将Field分词后的词或整个Field值进行索引，存储到索引域，索引的目的是为了搜索。

比如：商品名称、商品描述分析后进行索引，订单号、身份证号不用分词但也要索引，这些将来都要作为查询条件。

否：不索引。

比如：图片路径、文件路径等，不用作为查询条件的不用索引。

是否存储(stored)

是：将Field值存储在文档域中，存储在文档域中的Field才可以从Document中获取。

比如：商品名称、订单号，凡是将来要从Document中获取的Field都要存储。

否：不存储Field值

比如：商品描述，内容较大不用存储。如果要向用户展示商品描述可以从系统的关系数据库中获取。

5.2 Field常用类型

下边列出了开发中常用 的Filed类型，注意Field的属性，根据需求选择：

Field类	数据类型	Analyzed是否分词	Indexed是否索引	Stored是否存储	说明
StringField(FieldName,FieldValue,Store.YES))	字符串	N	Y	Y或N	这个Field用来构建一个字符串Field，但是不会进行分词，会将整个串存储在索引中，比如(订单号,身份证号等)是否存储在文档中用Store.YES或Store.NO决定
FloatPoint(FieldName, FieldValue)	Float型	Y	Y	N	这个Field用来构建一个Float数字型Field，进行分词和索引，不存储, 比如(价格) 存储在文档中
DoublePoint(FieldName,FieldValue)	Double型	Y	Y	N	这个Field用来构建一个Double数字型Field，进行分词和索引，不存储
LongPoint(FieldName, FieldValue)	Long型	Y	Y	N	这个Field用来构建一个Long数字型Field，进行分词和索引，不存储
IntPoint(FieldName, FieldValue)	Integer型	Y	Y	N	这个Field用来构建一个Integer数字型Field，进行分词和索引，不存储
StoredField(FieldName, FieldValue)	重载方法，支持多种类型	N	N	Y	这个Field用来构建不同类型Field不分析，不索引，但要Field存储在文档中
TextField(FieldName, FieldValue,Store.NO) 或 TextField(FieldName,reader)	字符串或流	Y	Y	Y或N	如果是一个Reader, lucene猜测内容比较多,会采用Unstored的策略.
NumericDocValuesField(FieldName,FieldValue)	数值	_	_	_	配合其他域排序使用

5.3 Field修改

对之前编写的testCreateIndex()方法进行修改。

代码片段

//创建域对象并且放入文档对象中
/*
 * 是否分词: 否, 因为主键分词后无意义
 * 是否索引: 是, 如果根据id主键查询, 就必须索引
 * 是否存储: 是, 因为主键id比较特殊, 可以确定唯一的一条数据, 在业务上一般有重要所用, 所以存储存储后, 才可以获取到id具体的内容
 */
//document.add(new TextField("id", sku.getId(), Field.Store.YES));
document.add(new StringField("id", sku.getId(), Field.Store.YES));

/*
 * 是否分词: 是, 因为名称字段需要查询, 并且分词后有意义所以需要分词
 * 是否索引: 是, 因为需要根据名称字段查询
 * 是否存储: 是, 因为页面需要展示商品名称, 所以需要存储
 */
document.add(new TextField("name", sku.getName(), Field.Store.YES));

/*
 * 是否分词: 是(因为lucene底层算法规定, 如果根据价格范围查询, 必须分词)
 * 是否索引: 是, 需要根据价格进行范围查询, 所以必须索引
 * 是否存储: 是, 因为页面需要展示价格
 */
//document.add(new TextField("price", String.valueOf(sku.getPrice()), Field.Store.YES));
document.add(new IntPoint("price", sku.getPrice()));
document.add(new StoredField("price", sku.getPrice()));

/*
 * 是否分词: 否, 因为不查询, 所以不索引, 因为不索引所以不分词
 * 是否索引: 否, 因为不需要根据图片地址路径查询
 * 是否存储: 是, 因为页面需要展示商品图片
 */
//document.add(new TextField("image", sku.getImage(), Field.Store.YES));
document.add(new StoredField("image", sku.getImage()));

/*
 * 是否分词: 否, 因为分类是专有名词, 是一个整体, 所以不分词
 * 是否索引: 是, 因为需要根据分类查询
 * 是否存储: 是, 因为页面需要展示分类
 */
//document.add(new TextField("categoryName", sku.getCategoryName(), Field.Store.YES));
document.add(new StringField("categoryName", sku.getCategoryName(), Field.Store.YES));

/*
 * 是否分词: 否, 因为品牌是专有名词, 是一个整体, 所以不分词
 * 是否索引: 是, 因为需要根据品牌进行查询
 * 是否存储: 是, 因为页面需要展示品牌
 */
//document.add(new TextField("brandName", sku.getBrandName(), Field.Store.YES));
document.add(new StringField("brandName", sku.getBrandName(), Field.Store.YES));

6. 索引维护

6.1 需求

管理人员通过电商系统更改图书信息，这时更新的是关系数据库，如果使用lucene搜索图书信息，需要在数据库表book信息变化时及时更新lucene索引库。

6.2 添加索引

调用 indexWriter.addDocument（doc）添加索引。

参考入门程序的创建索引。

6.3 修改索引

更新索引是先删除再添加，建议对更新需求采用此方法并且要保证对已存在的索引执行更新，可以先查询出来，确定更新记录存在执行更新操作。

如果更新索引的目标文档对象不存在，则执行添加。

代码

/**
 * 索引库修改操作
 *
 * @throws Exception
 */
@Test
public void updateIndexTest() throws Exception {
    //需要变更成的内容
    Document document = new Document();

    document.add(new StringField("id", "100000003145", Field.Store.YES));
    document.add(new TextField("name", "xxxx", Field.Store.YES));
    document.add(new IntPoint("price", 123));
    document.add(new StoredField("price", 123));
    document.add(new StoredField("image", "xxxx.jpg"));
    document.add(new StringField("categoryName", "手机", Field.Store.YES));
    document.add(new StringField("brandName", "华为", Field.Store.YES));

    //3. 创建分词器, StandardAnalyzer标准分词器, 对英文分词效果好, 对中文是单字分词, 也就是一个字就认为是一个词.
    Analyzer analyzer = new StandardAnalyzer();
    //4. 创建Directory目录对象, 目录对象表示索引库的位置
    Directory dir = FSDirectory.open(Paths.get("E:\\LuceneDir"));
    //5. 创建IndexWriterConfig对象, 这个对象中指定切分词使用的分词器
    IndexWriterConfig config = new IndexWriterConfig(analyzer);
    //6. 创建IndexWriter输出流对象, 指定输出的位置和使用的config初始化对象
    IndexWriter indexWriter = new IndexWriter(dir, config);

    //7. 修改, 第一个参数: 修改条件, 第二个参数: 修改成的内容
    indexWriter.updateDocument(new Term("id", "100000003145"), document);

    //8. 释放资源
    indexWriter.close();
}

6.4 删除索引

6.4.1 删除指定索引

根据Term项删除索引，满足条件的将全部删除。

/**
 * 测试根据条件删除
 *
 * @throws Exception
 */
@Test
public void deleteIndexTest() throws Exception {
    //3. 创建分词器, StandardAnalyzer标准分词器, 对英文分词效果好, 对中文是单字分词, 也就是一个字就认为是一个词.
    Analyzer analyzer = new StandardAnalyzer();
    //4. 创建Directory目录对象, 目录对象表示索引库的位置
    Directory dir = FSDirectory.open(Paths.get("E:\\LuceneDir"));
    //5. 创建IndexWriterConfig对象, 这个对象中指定切分词使用的分词器
    IndexWriterConfig config = new IndexWriterConfig(analyzer);
    //6. 创建IndexWriter输出流对象, 指定输出的位置和使用的config初始化对象
    IndexWriter indexWriter = new IndexWriter(dir, config);

    //7. 测试根据条件删除
    indexWriter.deleteDocuments(new Term("id", "998188"));

    //8. 释放资源
    indexWriter.close();
}

效果如下图：索引域没有变化

文档域数据被删除掉

6.4.2 删除全部索引（慎用）

将索引目录的索引信息全部删除，直接彻底删除，无法恢复。

建议参照关系数据库基于主键删除方式，所以在创建索引时需要创建一个主键Field，删除时根据此主键Field删除。

索引删除后将放在Lucene的回收站中，Lucene3.X版本可以恢复删除的文档，3.X之后无法恢复。

代码：

/**
 * 测试根据条件删除
 *
 * @throws Exception
 */
@Test
public void deleteIndexTest() throws Exception {
    //3. 创建分词器, StandardAnalyzer标准分词器, 对英文分词效果好, 对中文是单字分词, 也就是一个字就认为是一个词.
    Analyzer analyzer = new StandardAnalyzer();
    //4. 创建Directory目录对象, 目录对象表示索引库的位置
    Directory dir = FSDirectory.open(Paths.get("E:\\LuceneDir"));
    //5. 创建IndexWriterConfig对象, 这个对象中指定切分词使用的分词器
    IndexWriterConfig config = new IndexWriterConfig(analyzer);
    //6. 创建IndexWriter输出流对象, 指定输出的位置和使用的config初始化对象
    IndexWriter indexWriter = new IndexWriter(dir, config);

    //测试删除所有内容
    indexWriter.deleteAll();

    //8. 释放资源
    indexWriter.close();
}

索引域数据清空

文档域数据也清空

7. 分词器

7.1 分词理解

在对Document中的内容进行索引之前，需要使用分词器进行分词 ，分词的目的是为了搜索。分词的主要过程就是先分词后过滤。

• 分词：采集到的数据会存储到document对象的Field域中，分词就是将Document中Field的value值切分成一个一个的词。
• 过滤：包括去除标点符号过滤、去除停用词过滤（的、是、a、an、the等）、大写转小写、词的形还原（复数形式转成单数形参、过去式转成现在式。。。）等。

什么是停用词？停用词是为节省存储空间和提高搜索效率，搜索引擎在索引页面或处理搜索请求时会自动忽略某些字或词，这些字或词即被称为Stop Words(停用词)。比如语气助词、副词、介词、连接词等，通常自身并无明确的意义，只有将其放入一个完整的句子中才有一定作用，如常见的“的”、“在”、“是”、“啊”等。

对于分词来说，不同的语言，分词规则不同。Lucene作为一个工具包提供不同国家的分词器

7.2 Analyzer使用时机

7.2.1 索引时使用Analyzer

输入关键字进行搜索，当需要让该关键字与文档域内容所包含的词进行匹配时需要对文档域内容进行分析，需要经过Analyzer分析器处理生成语汇单元（Token）。分析器分析的对象是文档中的Field域。当Field的属性tokenized（是否分词）为true时会对Field值进行分析，如下图：

对于一些Field可以不用分析：

1 、不作为查询条件的内容，比如文件路径

2 、不是匹配内容中的词而匹配Field的整体内容，比如订单号、身份证号等。

7.2.2 搜索时使用Analyzer

对搜索关键字进行分析和索引分析一样，使用Analyzer对搜索关键字进行分析、分词处理，使用分析后每个词语进行搜索。比如：搜索关键字：spring web ，经过分析器进行分词，得出：spring web拿词去索引词典表查找 ，找到索引链接到Document，解析Document内容。

对于匹配整体Field域的查询可以在搜索时不分析，比如根据订单号、身份证号查询等。

注意：搜索使用的分析器要和索引使用的分析器一致。

7.3 Lucene原生分词器

以下是Lucene中自带的分词器

7.3.1 StandardAnalyzer

特点 :

Lucene提供的标准分词器, 可以对用英文进行分词, 对中文是单字分词, 也就是一个字就认为是一个词.

如下是org.apache.lucene.analysis.standard.standardAnalyzer的部分源码：

protected TokenStreamComponents createComponents(String fieldName) {
    final StandardTokenizer src = new StandardTokenizer();
    src.setMaxTokenLength(this.maxTokenLength);
    TokenStream tok = new LowerCaseFilter(src);
    TokenStream tok = new StopFilter(tok, this.stopwords);
    return new TokenStreamComponents(src, tok) {
        protected void setReader(Reader reader) {
            src.setMaxTokenLength(StandardAnalyzer.this.maxTokenLength);
            super.setReader(reader);
        }
    };
}

Tokenizer就是分词器，负责将reader转换为语汇单元即进行分词处理，Lucene提供了很多的分词器，也可以使用第三方的分词，比如IKAnalyzer一个中文分词器。

TokenFilter是分词过滤器，负责对语汇单元进行过滤，TokenFilter可以是一个过滤器链儿，Lucene提供了很多的分词器过滤器，比如大小写转换、去除停用词等。

如下图是语汇单元的生成过程：

从一个Reader字符流开始，创建一个基于Reader的Tokenizer分词器，经过三个TokenFilter生成语汇单元Token。

比如下边的文档经过分析器分析如下：

原文档内容：

分析后得到的多个语汇单元：

7.3.2 WhitespaceAnalyzer

特点 :

仅仅是去掉了空格，没有其他任何操作，不支持中文。

测试代码:

/**
 * 去掉空格分词器, 不支持中文
 *
 * @throws Exception
 */
@Test
public void TestWhitespaceAnalyzer() throws Exception {
    // 1. 创建分词器,分析文档，对文档进行分词
    Analyzer analyzer = new WhitespaceAnalyzer();

    // 2. 创建Directory对象,声明索引库的位置
    Directory directory = FSDirectory.open(Paths.get("E:\\LuceneDir"));

    // 3. 创建IndexWriteConfig对象，写入索引需要的配置
    IndexWriterConfig config = new IndexWriterConfig(analyzer);

    // 4.创建IndexWriter写入对象
    IndexWriter indexWriter = new IndexWriter(directory, config);

    // 5.写入到索引库，通过IndexWriter添加文档对象document
    Document doc = new Document();
    doc.add(new TextField("name", "vivo X23 8GB+128GB 幻夜蓝", Field.Store.YES));
    indexWriter.addDocument(doc);

    // 6.释放资源
    indexWriter.close();
}

结果:

7.3.3 SimpleAnalyzer

特点 :

将除了字母以外的符号全部去除，并且将所有字母变为小写，需要注意的是这个分词器同样把数字也去除了，同样不支持中文。

测试:

/**
 * 简单分词器: 不支持中文, 将除了字母之外的所有符号全部取出, 所有大写字母转换成小写字母, 对于数字也会去除
 *
 * @throws Exception
 */
@Test
public void TestSimpleAnalyzer() throws Exception {
    // 1. 创建分词器,分析文档，对文档进行分词
    Analyzer analyzer = new SimpleAnalyzer();

    // 2. 创建Directory对象,声明索引库的位置
    Directory directory = FSDirectory.open(Paths.get("E:\\LuceneDir"));

    // 3. 创建IndexWriteConfig对象，写入索引需要的配置
    IndexWriterConfig config = new IndexWriterConfig(analyzer);

    // 4.创建IndexWriter写入对象
    IndexWriter indexWriter = new IndexWriter(directory, config);

    // 5.写入到索引库，通过IndexWriter添加文档对象document
    Document doc = new Document();
    doc.add(new TextField("name", "vivo，X23。 8GB+128GB； 幻夜蓝", Field.Store.YES));
    indexWriter.addDocument(doc);

    // 6.释放资源
    indexWriter.close();
}

结果:

7.3.4 CJKAnalyzer

特点 :

这个支持中日韩文字，前三个字母也就是这三个国家的缩写。对中文是二分法分词, 去掉空格, 去掉标点符号。个人感觉对中文支持依旧很烂。

代码:

/**
 * 中日韩分词器: 使用二分法分词, 去掉空格, 去掉标点符号, 所有大写字母转换成小写字母
 *
 * @throws Exception
 */
@Test
public void TestCJKAnalyzer() throws Exception {
    // 1. 创建分词器,分析文档，对文档进行分词
    Analyzer analyzer = new CJKAnalyzer();

    // 2. 创建Directory对象,声明索引库的位置
    Directory directory = FSDirectory.open(Paths.get("E:\\LuceneDir"));

    // 3. 创建IndexWriteConfig对象，写入索引需要的配置
    IndexWriterConfig config = new IndexWriterConfig(analyzer);

    // 4.创建IndexWriter写入对象
    IndexWriter indexWriter = new IndexWriter(directory, config);

    // 5.写入到索引库，通过IndexWriter添加文档对象document
    Document doc = new Document();
    doc.add(new TextField("name", "vivo，X23。 8GB+128GB； 幻夜蓝", Field.Store.YES));
    indexWriter.addDocument(doc);

    // 6.释放资源
    indexWriter.close();
}

结果:

7.3.5 SmartChineseAnalyzer

特点 :

对中文支持也不是很好，扩展性差，扩展词库，禁用词库和同义词库等不好处理。

代码:

@Test
public void TestSmartChineseAnalyzer() throws Exception {
    // 1. 创建分词器,分析文档，对文档进行分词
    Analyzer analyzer = new SmartChineseAnalyzer();

    // 2. 创建Directory对象,声明索引库的位置
    Directory directory = FSDirectory.open(Paths.get("E:\\LuceneDir"));

    // 3. 创建IndexWriteConfig对象，写入索引需要的配置
    IndexWriterConfig config = new IndexWriterConfig(analyzer);

    // 4.创建IndexWriter写入对象
    IndexWriter indexWriter = new IndexWriter(directory, config);

    // 5.写入到索引库，通过IndexWriter添加文档对象document
    Document doc = new Document();
    doc.add(new TextField("name", "vivo，X23。 8GB+128GB； 幻夜蓝", Field.Store.YES));
    indexWriter.addDocument(doc);

    // 6.释放资源
    indexWriter.close();
}

结果:

7.4 第三方中文分词器

7.4.1 什么是中文分词器

学过英文的都知道，英文是以单词为单位的，单词与单词之间以空格或者逗号句号隔开。所以对于英文，我们可以简单以空格判断某个字符串是否为一个单词，比如I love China，love 和 China很容易被程序区分开来。

而中文则以字为单位，字又组成词，字和词再组成句子。中文“我爱中国”就不一样了，电脑不知道“中国”是一个词语还是“爱中”是一个词语。

把中文的句子切分成有意义的词，就是中文分词，也称切词。我爱中国，分词的结果是：我、爱、中国。

7.4.2 第三方中文分词器简介

• paoding： 庖丁解牛最新版在 https://code.google.com/p/paoding/ 中最多支持Lucene 3.0，且最新提交的代码在 2008-06-03，在svn中最新也是 2010 年提交，已经过时，不予考虑。
• mmseg4j：最新版已从 https://code.google.com/p/mmseg4j/ 移至 https://github.com/chenlb/mmseg4j-solr，支持Lucene 4.10，且在github中最新提交代码是 2014 年 6 月，从 09 年～ 14 年一共有： 18 个版本，也就是一年几乎有 3 个大小版本，有较大的活跃度，用了mmseg算法。
• IK-analyzer： 最新版在https://code.google.com/p/ik-analyzer/上，支持Lucene 4.10从 2006 年12 月推出1.0版开始， IKAnalyzer已经推出了 4 个大版本。最初，它是以开源项目Luence为应用主体的，结合词典分词和文法分析算法的中文分词组件。从3.0版本开 始，IK发展为面向Java的公用分词组件，独立于Lucene项目，同时提供了对Lucene的默认优化实现。在 2012 版本中，IK实现了简单的分词 歧义排除算法，标志着IK分词器从单纯的词典分词向模拟语义分词衍化。 但是也就是2012 年 12 月后没有在更新。
• ansj_seg：最新版本在 https://github.com/NLPchina/ansj_seg tags仅有1.1版本，从 2012 年到2014 年更新了大小 6 次，但是作者本人在 2014 年 10 月 10 日说明：“可能我以后没有精力来维护ansj_seg了”，现在由”nlp_china”管理。 2014 年 11 月有更新。并未说明是否支持Lucene，是一个由CRF（条件随机场）算法所做的分词算法。
• imdict-chinese-analyzer：最新版在 https://code.google.com/p/imdict-chinese-analyzer/ ， 最新更新也在 2009 年 5 月，下载源码，不支持Lucene 4.10 。是利用HMM（隐马尔科夫链）算法。
• Jcseg：最新版本在git.oschina.net/lionsoul/jcseg，支持Lucene 4.10，作者有较高的活跃度。利用mmseg算法。

7.4.3 使用中文分词器IKAnalyzer

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

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

1、添加依赖, pom.xml中加入依赖

<!-- IK中文分词器 -->
<dependency>
    <groupId>org.wltea.ik-analyzer</groupId>
    <artifactId>ik-analyzer</artifactId>
    <version>8.1.0</version>
</dependency>

2、加入配置文件:

3、测试代码

/**
 * 使用第三方分词器(IK分词)
 * 特点: 支持中文语义分析, 提供停用词典, 提供扩展词典, 供程序员扩展使用
 *
 * @throws Exception
 */
@Test
public void TestIKAnalyzer() throws Exception {
    // 1. 创建分词器,分析文档，对文档进行分词
    Analyzer analyzer = new IKAnalyzer();

    // 2. 创建Directory对象,声明索引库的位置
    Directory directory = FSDirectory.open(Paths.get("E:\\LuceneDir"));

    // 3. 创建IndexWriteConfig对象，写入索引需要的配置
    IndexWriterConfig config = new IndexWriterConfig(analyzer);

    // 4.创建IndexWriter写入对象
    IndexWriter indexWriter = new IndexWriter(directory, config);

    // 5.写入到索引库，通过IndexWriter添加文档对象document
    Document doc = new Document();
    doc.add(new TextField("name", "vivo X23 8GB+128GB 幻夜蓝,水滴屏全面屏,游戏手机.移动联通电信全网通4G手机", Field.Store.YES));
    indexWriter.addDocument(doc);

    // 6.释放资源
    indexWriter.close();
}

4、测试结果

7.4.4 扩展中文词库

如果想配置扩展词和停用词，就创建扩展词的文件和停用词的文件。

从ikanalyzer包中拷贝配置文件

拷贝到资源文件夹中

IKAnalyzer.cfg.xml配置文件

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE properties SYSTEM "http://java.sun.com/dtd/properties.dtd">
<properties>
    <comment>IK Analyzer 扩展配置</comment>
    <!--用户可以在这里配置自己的扩展字典 -->
    <entry key="ext_dict">ext.dic;</entry>

    <!--用户可以在这里配置自己的扩展停止词字典-->
    <entry key="ext_stopwords">stopword.dic;</entry>

</properties>

停用词典stopword.dic作用 :

停用词典中的词例如: a, an, the, 的, 地, 得等词汇, 凡是出现在停用词典中的字或者词, 在切分词的时候会被过滤掉.

扩展词典ext.dic作用 :

扩展词典中的词例如: 程序员, 贵州茅台等专有名词, 在汉语中一些公司名称, 行业名称, 分类, 品牌等不是汉语中的词汇, 是专有名词. 这些分词器默认不识别, 所以需要放入扩展词典中, 效果是被强制分成一个词.

-------------本文结束感谢您的阅读-------------

本文作者： Wgy
本文标题： Lucene(一)
本文链接： https://wgy1993.gitee.io/archives/c330d3d2.html
版权声明： 本作品采用 CC BY-NC-SA 4.0 进行许可。转载请注明出处！

赏

谢谢你请我吃糖果

支付宝

微信