Spring和Elasticsearch全文搜索整合详解

SpringElasticsearch_0">Spring和Elasticsearch全文搜索整合详解

一、概述

ElasticSearch是一个基于Lucene的搜索服务器。它提供了一个分布式多用户能力的全文搜索引擎，基于RESTful web接口。Elasticsearch是用Java开发的，并作为Apache许可条款下的开放源码发布，是当前流行的企业级搜索引擎。

ES是ElasticSearch的缩写；

ELK是三个开源软件的缩写，分别表示：Elasticsearch , Logstash, Kibana , 它们都是开源软件。

一般公司都是用ELK做日志分析，社区搜索之类的，很少单独使用ElasticSearch。但是单独使用ElasticSearch也很广泛，没有ELK的时候都是这样玩的。

比如我的社区网站(https://www.pomit.cn)就用了ElasticSearch做社区搜索，一开始做搜索的时候，曾有三种方案：

  • Mysql的全文搜索，据说很慢，而且我的mysql版本也不支持中文，还要升级。

  • 搜索引擎的支持，搜索引擎可以传入keyword、site对网站的某个网页做搜索，但是依赖于搜索引擎的收录情况。特别是百度渣渣，求它收录都难，必应还是蛮快的。但是都不够快。

  • ElasticSearch做社区搜索，需要安装ElasticSearch。用了一段时间，感觉还可以。

首发地址：
品茗IT-同步发布

品茗IT 提供在线支持：

一键快速构建Spring项目工具

一键快速构建SpringBoot项目工具

一键快速构建SpringCloud项目工具

一站式Springboot项目生成

Mysql一键生成Mybatis注解Mapper

如果大家正在寻找一个java的学习环境，或者在开发中遇到困难，可以加入我们的java学习圈，点击即可加入，共同学习，节约学习时间，减少很多在学习中遇到的难题。

二、环境配置

本文假设你已经引入Spring必备的一切了，已经是个Spring项目了,如果不会搭建，可以打开这篇文章看一看《Spring和Spring Mvc 5整合详解》。

2.1 maven依赖

使用elasticsearch需要引入spring-data-elasticsearch，而且要保证版本和安装的elasticsearch对应。

<?xml version="1.0"?>
<project
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"
	xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
	<modelVersion>4.0.0</modelVersion>
	<parent>
		<groupId>cn.pomit</groupId>
		<artifactId>SpringWork</artifactId>
		<version>0.0.1-SNAPSHOT</version>
	</parent>
	<artifactId>Elasticsearch</artifactId>
	<packaging>jar</packaging>
	<name>Elasticsearch</name>
	<url>http://maven.apache.org</url>
	<properties>
	    <!-- redis 版本 -->
	    <elasticsearch.version>3.1.6.RELEASE</elasticsearch.version>
	    
	</properties>
	<dependencies>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-web</artifactId>
		</dependency>
		<dependency>
		    <groupId>org.springframework.data</groupId>
		    <artifactId>spring-data-elasticsearch</artifactId>
		    <version>${elasticsearch.version}</version>
		</dependency>
		<dependency>
		    <groupId>org.springframework.data</groupId>
		    <artifactId>spring-data-commons</artifactId>
		    <version>2.1.6.RELEASE</version>
		</dependency>
	</dependencies>
	<build>
		<finalName>Elasticsearch</finalName>
	</build>
</project>

父模块可以在https://www.pomit.cn/spring/SpringWork/pom.xml获取。

Spring_88">2.2 Spring配置

需要配置elasticsearchTemplate和elasticsearch:transport-client。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:elasticsearch="http://www.springframework.org/schema/data/elasticsearch"
    xmlns:context="http://www.springframework.org/schema/context"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
                            http://www.springframework.org/schema/data/elasticsearch http://www.springframework.org/schema/data/elasticsearch/spring-elasticsearch.xsd
                            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
   	
   	<bean id="annotationPropertyConfigurerElasticsearch"
		class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
		<property name="order" value="1" />
		<property name="ignoreUnresolvablePlaceholders" value="true" />
		<property name="locations">
			<list>
				<value>classpath:elasticsearch.properties</value>
			</list>
		</property>
	</bean>
   
    <elasticsearch:transport-client id="client"
        cluster-nodes="${elasticsearch.cluster-nodes}" cluster-name="${elasticsearch.cluster-name}" />

    <bean name="elasticsearchTemplate"
        class="org.springframework.data.elasticsearch.core.ElasticsearchTemplate">
        <constructor-arg ref="client" />
    </bean>
    
     <elasticsearch:repositories base-package="cn.pomit.springwork.elasticsearch.dao" />
</beans>

elasticsearch.properties中存放elasticsearch的地址端口信息。

elasticsearch.properties：

elasticsearch.cluster-name=elasticsearch
elasticsearch.cluster-nodes=127.0.0.1:9300

Elasticsearch_134">三、Elasticsearch访问数据层

我们直接使用Spring-data-elasticsearch, 一切都会变的特别简单。Spring-data-elasticsearch支持快速查询，也支持@Query之定义查询，要注意它的写法，和elasticsearch原生写法略有不同。

QuestionElasticsearchRepository :

package cn.pomit.springwork.elasticsearch.dao;

import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.data.elasticsearch.annotations.Query;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;

import cn.pomit.springwork.elasticsearch.domain.FQuestionElasticssearch;

public interface QuestionElasticsearchRepository extends ElasticsearchRepository<FQuestionElasticssearch, Long> {

	Page<FQuestionElasticssearch> findByCatory(String catory, Pageable pageable);

	@Query("{ \"bool\":{ \"must\":[ { \"multi_match\": { \"query\": \"?0\", \"type\": \"most_fields\", \"fields\": [ \"title\", \"content\" ] } }, { \"match\": { \"catory\": \"?1\" } } ] } } ")
	Page<FQuestionElasticssearch> searchByKeyWordsAndCatory(String keyword, String catory, Pageable pageable);

}

这个写法和Spring-data-jpa基本上一样，应该说Spring-data系列的写法都是类同的。

注意，FQuestionElasticssearch实体需要加上@Document注解指明Elasticssearch中的index和type。

四、测试Elasticssearch

我们定义一个service和web接口来做测试。

QuestionElasticsearchService：

package cn.pomit.springwork.elasticsearch.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;

import cn.pomit.springwork.elasticsearch.dao.QuestionElasticsearchRepository;
import cn.pomit.springwork.elasticsearch.domain.FQuestionElasticssearch;

@Service
public class QuestionElasticsearchService {
	@Autowired
	QuestionElasticsearchRepository questionElasticsearchRepository;

	public Page<FQuestionElasticssearch> pageByOpenAndCatory(Integer page, Integer size, String catory,
			String keyWord) {
		Pageable pageable = PageRequest.of(page, size);
		if (StringUtils.isEmpty(keyWord)) {
			return questionElasticsearchRepository.findByCatory(catory, pageable);

		} else {
			return questionElasticsearchRepository.searchByKeyWordsAndCatory(keyWord, catory, pageable);

		}
	}
}

ElasticsearchRest：

package cn.pomit.springwork.elasticsearch.web;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import cn.pomit.springwork.elasticsearch.domain.FQuestionElasticssearch;
import cn.pomit.springwork.elasticsearch.service.QuestionElasticsearchService;

@RestController
@RequestMapping("/elsearch")
public class ElasticsearchRest {

	@Autowired
	QuestionElasticsearchService questionElasticsearchService;

	@RequestMapping(value = "/test", method = { RequestMethod.GET })
	public List<FQuestionElasticssearch> test(@RequestParam(value = "value", required = false) String value) {
		return questionElasticsearchService.pageByOpenAndCatory(0, 10, "Spring专题", value).getContent();
	}
}

五、过程中用到的实体

FQuestionElasticssearch：

详细完整的实体，可以访问品茗IT-博客《Spring和Elasticsearch全文搜索整合详解》进行查看

全部代码可以在Spring组件化构建https://www.pomit.cn/java/spring/spring.html中的E组件中查看，并下载。

快速构建项目

Spring组件化构建

SpringBoot组件化构建

SpringCloud服务化构建

喜欢这篇文章么，喜欢就加入我们一起讨论SpringBoot技术吧！
品茗IT交流群


http://www.niftyadmin.cn/n/1050905.html

相关文章

红-黑树——C++实现

红-黑树——C++实现

红-黑树基本概念 红-黑树(Red-Black tree)是一种特殊的二叉查找树&#xff0c;因此具有二叉查找树的特征&#xff1a;任意一个节点所包含的关键字&#xff0c;大于左孩子的关键字&#xff0c;小于右孩子的关键字。树中每一个节点的颜色或者是黑色或者是红色&#xff0c;和AVL树…
阅读更多...
java线程基础巩固---如何给你的应用程序注入钩子程序

java线程基础巩固---如何给你的应用程序注入钩子程序

这次做一个比较有意思的实验&#xff0c;我们知道当一个程序如果抛异常了其程序肯定会挂掉&#xff0c;那有木有可能在程序异常退出时能执行一段咱们自己的代码&#xff0c;比如说服务器在异常退出时需要做一些额外的资源清理&#xff0c;像这种场景就正好是这里有实验的&#…
阅读更多...
android之Fragment（官网资料翻译）

android之Fragment（官网资料翻译）

Fragment要点 Fragment作为Activity界面的一部分组成出现可以在一个Activity中同时出现多个Fragment&#xff0c;并且&#xff0c;一个Fragment亦可在多个Activity中使用。在Activity运行过程中&#xff0c;可以添加、移除或者替换Fragment&#xff08;add()、remove()、replac…
阅读更多...
Web基础配置篇（五）: Nginx的配置及代理转发

Web基础配置篇（五）: Nginx的配置及代理转发

Web基础配置篇&#xff08;五&#xff09;: Nginx的配置及代理转发 一、概述 Nginx (engine x) 是一个高性能的HTTP和反向代理web服务器。 说到web服务器&#xff0c;你可以疑惑&#xff0c;前面说的tomcat不也是web服务器么&#xff0c;为啥要用nginx&#xff1f; 这里要说…
阅读更多...
Django基本配置数据库mysql(1)（python3.7）

Django基本配置数据库mysql(1)（python3.7）

1. 下载Mysqlclient3.7版本 下载链接地址&#xff1a;Python Extension Packages 按CtrlG&#xff0c;页面出现弹框&#xff0c;输入mysqlclient 定位到如图所示位置处&#xff0c;选择与pyton一致的版本下载&#xff08;如cp36-->python版本3.6.*&#xff09; 2. 安装Mysql…
阅读更多...
SpringBoot入门建站全系列（十六）整合Swagger文档中心

SpringBoot入门建站全系列（十六）整合Swagger文档中心

SpringBoot入门建站全系列&#xff08;十六&#xff09;整合Swagger文档中心 一、概述 Swagger 是一个规范和完整的框架&#xff0c;用于生成、描述、调用和可视化 RESTful 风格的 Web 服务。总体目标是使客户端和文件系统作为服务器以同样的速度来更新 。接口的方法&#xf…
阅读更多...
Django 之模版初探

Django 之模版初探

为什么80%的码农都做不了架构师&#xff1f;>>> 话说看完了Django 第四章模版 有必要随便写篇文章来大概的记录一下自己的理解&#xff0c;这文章主要是对Django 第四章模版的一个精简概要&#xff0c;以备日后闲来无事看看自己学习的记录。 让我们从一个简单的例…
阅读更多...
[Luogu] P3225 [HNOI2012]矿场搭建

[Luogu] P3225 [HNOI2012]矿场搭建

题目描述 煤矿工地可以看成是由隧道连接挖煤点组成的无向图。为安全起见&#xff0c;希望在工地发生事故时所有挖煤点的工人都能有一条出路逃到救援出口处。于是矿主决定在某些挖煤点设立救援出口&#xff0c;使得无论哪一个挖煤点坍塌之后&#xff0c;其他挖煤点的工人都有一条…
阅读更多...
最新文章

Copyright @ 2022~2023