【SpringBoot1.x】SpringBoot1.x 检索

SpringBoot1.x 检索

概念

Elasticsearch 是一个分布式的开源搜索和分析引擎，适用于所有类型的数据，包括文本、数字、地理空间、结构化和非结构化数据。Elasticsearch 在 Apache Lucene 的基础上开发而成，由 Elasticsearch N.V.（即现在的 Elastic）于 2010 年首次发布。Elasticsearch 以其简单的 REST 风格 API、分布式特性、速度和可扩展性而闻名，是 Elastic Stack 的核心组件；Elastic Stack 是适用于数据采集、充实、存储、分析和可视化的一组开源工具。人们通常将 Elastic Stack 称为 ELK Stack（代指 Elasticsearch、Logstash 和 Kibana），目前 Elastic Stack 包括一系列丰富的轻量型数据采集代理，这些代理统称为 Beats，可用来向 Elasticsearch 发送数据。

以 员工文档 的形式存储为例：一个文档代表一个员工数据。存储数据到 ElasticSearch 的行为叫做索引，但在索引一个文档之前，需要确定将文档存储在哪里。

一个 ElasticSearch 集群可以包含多个索引，相应的每个索引可以包含多个类型。这些不同的类型存储着多个文档，每个文档又有多个属性。

Elasticsearch 的用途：

应用程序搜索
网站搜索
企业搜索
日志处理和分析
基础设施指标和容器监测
应用程序性能监测
地理空间数据分析和可视化
安全分析
业务分析

Elasticsearch 的工作原理：原始数据会从多个来源（包括日志、系统指标和网络应用程序）输入到 Elasticsearch 中。数据采集指在 Elasticsearch 中进行索引之前解析、标准化并充实这些原始数据的过程。这些数据在 Elasticsearch 中索引完成之后，用户便可针对他们的数据运行复杂的查询，并使用聚合来检索自身数据的复杂汇总。在 Kibana 中，用户可以基于自己的数据创建强大的可视化，分享仪表板，并对 Elastic Stack 进行管理。

整合 Elasticsearch

SpringBoot 默认支持两种技术来和 ES 交互：

Jest，它默认不生效
- 使用它需要导入 jest 工具包，io.searchbox.client.JestClient;
SpringData Elasticsearch，默认生效，推荐使用它
- 使用 Client 节点，配置属性 clusterNodes、clusterName
- 用 ElasticsearchTemplate 操作 ES，或者
- 编写 ElasticsearchRepository 的子接口来操作 ES

安装测试

Docker 安装 Elasticsearch：docker pull elasticsearch:6.8.13
启动 Elasticsearch：docker run --name elasticsearch -p 9200:9200 -p 9300:9300 -e ES_JAVA_OPTS="-Xms512m -Xmx512m" -d elasticsearch:6.8.13，注意分配内存，默认为 2GB
输入 http://localhost:9200/，若显示内容，则代表安装启动成功

Jest

导入依赖

        <!-- https://mvnrepository.com/artifact/io.searchbox/jest -->
        <dependency>
            <groupId>io.searchbox</groupId>
            <artifactId>jest</artifactId>
            <version>6.3.1</version>
        </dependency>

编写配置文件

# 这也是默认值
spring.elasticsearch.jest.uris=http://localhost:9200

编写 Article 实体类：

public class Article {

    @JestId
    private Integer id;
    private String author;
    private String title;
    private String content;

    // constructor setter getter toString
}

编写测试文件：

@RunWith(SpringRunner.class)
@SpringBootTest
public class IntegrationSearchApplicationTests {

    @Autowired
    JestClient jestClient;  // Jest 操作 ES

    // 创建一个索引 http://localhost:9200/parzulpan/tips/1001
    @Test
    public void testJestCreate() {
        // 给 ES 中 索引（保存）一个文档
        Article article = new Article(1001, "消息通知", "zs", "Hello World");

        // 构建一个索引
        Index index = new Index.Builder(article).index("parzulpan").type("tips").build();

        try {
            // 执行
            DocumentResult result = jestClient.execute(index);
            System.out.println(result.getJsonString());
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    // 全文搜索
    @Test
    public void testJestSearch() {
        // 全文搜索 查询表达式
        String json = "{
" +
                "    "query" : {
" +
                "        "match" : {
" +
                "            "content" : "Hello"
" +
                "        }
" +
                "    }
" +
                "}";

        // 构建一个搜索
        Search search = new Search.Builder(json).addIndex("parzulpan").addType("tips").build();

        try {
            // 执行
            SearchResult result = jestClient.execute(search);
            System.out.println(result.getJsonString());
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

SpringData Elasticsearch