全文檢索ElasticSearch與Spring boot集成實例

阿新 • • 發佈：2018-11-27

ini ng- har .com maven onu ren oot beans

全文檢索
1.全文搜索概念：
（1）數據結構：
·結構化：只具有固定格式或者有限長度的數據，如數據庫，元數據等
·非結構化：指不定長或者無固定格式的數據，如郵件，word文檔等
（2）非結構化數據的檢索：
·順序掃描法：適合小數據量文件
·全文搜索：將非結構化的數據轉為結構化的數據，然後創建索引，在進行搜索
（3）概念：全文搜索是一種將文件中所有文本域搜索項匹配的文件資料檢索方式
2.全文搜索實現原理
技術分享圖片

3.全文搜索實現技術：基於java的開源實現Lucene,ElasticSearch（具有自身的分布式管理功能）,Solr
4.ElasticSearch簡介：
概念：
（1）高度可擴展的開源全文搜索和分析引擎
（2）快速的，近實的多大數據進行存儲，搜索和分析

（3）用來支撐有復雜的數據搜索需求的企業級應用
特點及介紹：
（1）分布式
（2）高可用
（3）對類型，支持多種數據類型
（4）多API
（5）面向文檔
（6）異不寫入
（7）近實時：每隔n秒查詢，在寫入磁盤中
（8）基於Lucene
（9）Apache協議
5.ElasticSearch與Spring Boot集成
（1）配置環境：ElasticSearch，Spring Data ElasticSearch,JNA
（2）安裝ElasticSearch，下載包，解壓直接啟動即可,這裏特別說一下ElasticSearch的一些異常問題，必須版本對應，其次端口問題一定要註意
（3）建立Spring Boot項目
（4）我們修改pom.xml文件，將相關依賴加進去

（5）在項目代碼編寫之前我們必須在本地安裝ElasticSearch並在版本上與Spring Boot版本相兼容，其次註意端口號的問題，集成時ElasticSearch服務的端口號為9200，而客戶端端口號為9300
接下來我們啟動本地安裝的ElasticSearch然後在啟動我們的項目：

<?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.dhtt.spring.boot.blog</groupId>
    <artifactId>spring.data.action</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>spring.data.action</name>
    <description>Demo project for Spring Boot</description>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.0.RELEASE</version>
        <relativePath /> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>
        <!-- spring boot集成elasticsearch -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.data</groupId>
            <artifactId>spring-data-elasticsearch</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-thymeleaf</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- 添加熱部署 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!-- JNA 的依賴 -->
        <dependency>
            <groupId>net.java.dev.jna</groupId>
            <artifactId>jna</artifactId>
            <version>4.5.1</version>
        </dependency>

        <dependency>
            <groupId>org.elasticsearch</groupId>
            <artifactId>elasticsearch</artifactId>
        </dependency>
        <!-- 內存數據庫h2 -->
        <!-- <dependency> <groupId>com.h2database</groupId> <artifactId>h2</artifactId> 
            </dependency> -->

        <!-- MySql數據庫驅動 -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.46</version>
        </dependency>
        <!-- hibernate持久層框架引入 -->
        <dependency>
            <groupId>org.hibernate</groupId>
            <artifactId>hibernate-core</artifactId>
            <version>5.3.7.Final</version>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

啟動項目進行測試，觀察項目各項配置是否正確，項目能否成功啟動，項目啟動成功後
（5）接下來配置application.properties文件：

#thymeleaf配置
spring.thymeleaf.encoding=UTF-8
#熱部署靜態文件,不需要緩存，實時觀察文件修改效果
spring.thymeleaf.cache=false
#使用html5標準
spring.thymeleaf.mode=HTML5
spring.thymeleaf.suffix=.html
spring.resources.chain.strategy.content.enabled=true

#elasticsearch服務器地址
spring.data.elasticsearch.cluster-nodes=127.0.0.1:9300
#連接超時時間
spring.data.elasticsearch.properties.transport.tcp.connect_timeout=120s
 #節點名字，默認elasticsearch
#spring.data.elasticsearch.cluster-name=elasticsearch 
#spring.data.elasticsearch.repositories.enable=true
#spring.data.elasticsearch.properties.path.logs=./elasticsearch/log
#spring.data.elasticsearch.properties.path.data=./elasticsearch/data

#數據庫連接配置
spring.datasource.url=jdbc:mysql://localhost:3306/blog_test?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2B8&useSSL=false
spring.datasource.username=root
spring.datasource.password=qitao1996
spring.datasource.driver-class-name=com.mysql.jdbc.Driver

#jpa配置
spring.jpa.show-sql=true
spring.jpa.hibernate.ddl-auto=create-drop

（6）進行後臺編碼：
文檔類EsBlog:

package com.dhtt.spring.boot.blog.spring.data.action.entity;

import java.io.Serializable;

import javax.persistence.Id;

import org.springframework.data.elasticsearch.annotations.Document;

/**
 * EsBlog實體（文檔）類
 * 
 * @author QiTao
 *
 */
@Document(indexName="blog",type="blog")   //指定文檔
public class EsBlog implements Serializable {

    /**
     * 
     */
    private static final long serialVersionUID = 4745983033416635193L;
    @Id
    private String id;
    private String title;
    private String summary;
    private String content;

    protected EsBlog() {
        super();
    }

    public EsBlog(String title, String summary, String content) {
        super();
        this.title = title;
        this.summary = summary;
        this.content = content;
    }

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getTitle() {
        return title;
    }

    public void setTitle(String title) {
        this.title = title;
    }

    public String getSummary() {
        return summary;
    }

    public void setSummary(String summary) {
        this.summary = summary;
    }

    public String getContent() {
        return content;
    }

    public void setContent(String content) {
        this.content = content;
    }

    @Override
    public String toString() {
        return "EsBlog [id=" + id + ", title=" + title + ", summary=" + summary + ", content=" + content + "]";
    }

}

資源庫，定義數據查詢接口：

package com.dhtt.spring.boot.blog.spring.data.action.repository;

import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;

import com.dhtt.spring.boot.blog.spring.data.action.entity.EsBlog;

/**
 * EsBlogRepository接口
 * 
 * @author QiTao
 *
 */
public interface EsBlogRepository extends ElasticsearchRepository<EsBlog, String> {
    /**
     * 分頁，查詢，去重
     * 
     * @param title
     * @param summary
     * @param content
     * @param pageable
     * @return
     */
    Page<EsBlog> findDistinctEsBlogByTitleContainingOrSummaryContainingOrContentContaining(String title, String summary,
            String content, PageRequest pageRequest);
}

最後編寫Controller類：

package com.dhtt.spring.boot.blog.spring.data.action.web.user;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import com.dhtt.spring.boot.blog.spring.data.action.entity.EsBlog;
import com.dhtt.spring.boot.blog.spring.data.action.repository.EsBlogRepository;

@RestController
@RequestMapping("/blogs")
public class BlogController {
    @Autowired
    private EsBlogRepository esBlogRepository;

    @GetMapping
    public List<EsBlog> list(@RequestParam(value = "title") String title,
            @RequestParam(value = "summary") String summary, 
            @RequestParam(value = "content") String content,
            @RequestParam(value = "pageIndex", defaultValue = "0") int pageIndex,
            @RequestParam(value = "pageSize", defaultValue = "10") int pageSize) {
        //添加測試數據
        esBlogRepository.deleteAll();
        esBlogRepository.save(new EsBlog("登黃鶴樓", "王之渙的等黃鶴樓", "百日依山盡，黃河入海流，欲窮千裏目，更上一層樓"));
        esBlogRepository.save(new EsBlog("相思", "王維的相思", "紅豆生南國，春來發幾枝，願君多采截，此物最相思"));
        esBlogRepository.save(new EsBlog("靜夜思", "李白的靜夜思", "床前明月光，疑是地上霜，舉頭望明月，低頭思故鄉"));
        //查詢獲取
        PageRequest pageRequest=PageRequest.of(pageIndex,pageSize);
        Page<EsBlog> page= esBlogRepository.findDistinctEsBlogByTitleContainingOrSummaryContainingOrContentContaining(title, summary, content, pageRequest);
        return page.getContent();

    }

}

啟動項目，前臺進行訪問：
技術分享圖片

前臺結果打印成功，故我們的Elasticsearch+Spring Boot集成成功

全文檢索ElasticSearch與Spring boot集成實例

ini ng- har .com maven onu ren oot beans 全文檢索1.全文搜索概念：（1）數據結構：·結構化：只具有固定格式或者有限長度的數據，如數據庫，元數據等·非結構化：指不定長或者無固定格式的數據，如郵件，word文檔等（2）非結構化數據的檢索

全文檢索ElasticSearch與Spring boot集成實例

全文檢索ElasticSearch與Spring boot集成實例

Quartz與Spring Boot集成使用

Spring Boot集成ElasticSearch實現簡單的增刪查改接口

Spring Boot集成Hazelcast實現集群與分布式內存緩存

spring-boot集成Springfox-Swagger2

spring boot集成swagger2

spring boot集成redis緩存

spring-boot集成mybatis

Spring Boot系列教程七：Spring boot集成MyBatis

170711、spring boot 集成shiro

spring boot集成mybatis需要的相關依賴

spring boot 集成kafka (多線程,消費者使用kafka的原生api實現,因為@KakfkaListener修改groupId無效)

spring boot集成mybatis+事務控制

玩轉Spring Boot 集成Dubbo

spring boot集成dubbo

spring-boot集成PageHelper和通用Mapper

企業分布式微服務雲SpringCloud SpringBoot mybatis （三十）關於spring boot集成apidoc

spring boot集成模板引擎Thymeleaf中遇到的坑

spring boot 集成axis1.4 java.lang.NoClassDefFoundError: Could not initialize class org.apache.axis.client.AxisClient

Spring Boot 集成 logback日誌

全文檢索ElasticSearch與Spring boot集成實例

相關推薦