Spring boot中使用ElasticSearch的方法详解

 更新时间:2019年01月11日 09:49:35   作者:Waiting For You  
这篇文章主要给大家介绍了关于Spring boot中使用ElasticSearch的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

0.版本选择

我这里选择了5.6.x,记得如果spring-boot-starter-parent是1.x可以选择2.x版本的elasticsearch,版本要对应,不然会有莫名其妙的问题

1.安装ElasticSearch

https://www.elastic.co/downloads/past-releases

windows 测试的,解压就能用

解压,到bin目录,双击elasticsearch.bat

1.1安装elasticsearch-head

https://github.com/mobz/elasticsearch-head

elasticsearch-head是一个网页查看elasticsearch状态,操作的第三方东西

git clone git://github.com/mobz/elasticsearch-head.git
cd elasticsearch-head
npm install
npm run start
open http://localhost:9100/

要先安装node.js

config/elasticsearch.yml 文件增加

http.cors.enabled: true
http.cors.allow-origin: “*”

elasticsearch-head/Gruntfile.js

connect: {
   server: {
    options: {
     hostname: '0.0.0.0',
     port: 9100,
     base: '.',
     keepalive: true
    }
   }
  }

8082改成你自己的端口

http://127.0.0.1:8082/swagger-ui.html#/

0是第一页

application.properties

#===es start===
spring.data.elasticsearch.repositories.enabled = true
spring.data.elasticsearch.cluster-nodes = 127.0.0.1:9300
#===es end===

2.porm

<?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>
 <parent>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-parent</artifactId>
  <version>2.1.1.RELEASE</version>
  <relativePath/> <!-- lookup parent from repository -->
 </parent>
 <groupId>com.example</groupId>
 <artifactId>demo</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <name>demo</name>
 <description>Demo project for Spring Boot</description>
 <packaging>jar</packaging>
 
 <properties>
  <java.version>1.8</java.version>
 </properties>
 
 <dependencies>
  <!--Swagger-UI API文档生产工具-->
  <dependency>
   <groupId>io.springfox</groupId>
   <artifactId>springfox-swagger2</artifactId>
   <version>2.6.1</version>
  </dependency>
  <dependency>
   <groupId>io.springfox</groupId>
   <artifactId>springfox-swagger-ui</artifactId>
   <version>2.6.1</version>
  </dependency>
  <!--Swagger-UI API文档生产工具-->
 
  <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
  </dependency>
 
  <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter</artifactId>
  </dependency>
 
  <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-test</artifactId>
   <scope>test</scope>
  </dependency>
 
  <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-web</artifactId>
  </dependency>
 </dependencies>
 
 <build>
  <plugins>
   <plugin>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-maven-plugin</artifactId>
   </plugin>
  </plugins>
 </build>
 
</project>

主要添加spring-boot-starter-data-elasticsearch,注意spring-boot-starter-parent的版本号

3. GoodsInfo

package com.example.demo.domain;
 
import org.springframework.data.elasticsearch.annotations.Document;
 
import java.io.Serializable;
 
@Document(indexName = "testgoods", type = "goods")
public class GoodsInfo implements Serializable {
 private Long id;
 private String name;
 private String description;
 
 public Long getId() {
  return id;
 }
 
 public void setId(Long id) {
  this.id = id;
 }
 
 public String getName() {
  return name;
 }
 
 public void setName(String name) {
  this.name = name;
 }
 
 public String getDescription() {
  return description;
 }
 
 public void setDescription(String description) {
  this.description = description;
 }
 
 public GoodsInfo(Long id, String name, String description) {
  this.id = id;
  this.name = name;
  this.description = description;
 }
 
 public GoodsInfo() {
 }
}

indexName 类似数据库名称,type类似表名字

4. GoodsRepository

package com.example.demo.repository;
 
import com.example.demo.domain.GoodsInfo;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import org.springframework.stereotype.Component;
 
@Component
public interface GoodsRepository extends ElasticsearchRepository<GoodsInfo, Long> {
}

这里会帮你封装了很多了

5. HelloWorldController

package com.example.demo.controller;
 
import com.example.demo.domain.GoodsInfo;
import com.example.demo.repository.GoodsRepository;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiOperation;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.functionscore.FunctionScoreQueryBuilder;
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.data.elasticsearch.core.query.NativeSearchQuery;
import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
import org.springframework.data.elasticsearch.core.query.SearchQuery;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;
 
import java.util.List;
import java.util.Optional;
 
import static org.elasticsearch.index.query.QueryBuilders.queryStringQuery;
 
@Controller
@Api(value = "HelloWorldController|一个用来测试swagger注解的控制器",tags = "HelloWorldController", description = "HelloWorldController")
public class HelloWorldController {
 
 @Autowired
 private GoodsRepository goodsRepository;
 
 @ResponseBody
 @RequestMapping(value = "/hello", method = RequestMethod.GET)
 @ApiOperation(value = "根据用户编号获取用户姓名", notes = "test: 仅1和2有正确返回")
 @ApiImplicitParam(paramType="query", name = "userNumber", value = "用户编号", required = true, dataType = "Integer")
 public String index(@RequestParam Integer userNumber){
  if(userNumber == 1){
   return "小白";
  }
  else if(userNumber == 2){
   return "小红";
  }
  else{
   return "未知";
  }
 }
 @ResponseBody
 @RequestMapping(value = "/save", method = RequestMethod.POST)
 @ApiOperation(value = "新增商品")
 public String save(){
  GoodsInfo goodsInfo = new GoodsInfo(System.currentTimeMillis(), "商品" + System.currentTimeMillis(), "这是一个测试商品");
  goodsRepository.save(goodsInfo);
  return "success";
 }
 
 @ResponseBody
 @RequestMapping(value = "/delete", method = RequestMethod.POST)
 @ApiOperation(value = "删除商品")
 @ApiImplicitParam(paramType="query", name = "id", value = "商品id", required = true, dataType = "long")
 public String delete(@RequestParam(required = true) long id){
  goodsRepository.deleteById(id);
  return "success";
 }
 
 @ResponseBody
 @RequestMapping(value = "/update", method = RequestMethod.POST)
 @ApiOperation(value = "更新商品")
 @ApiImplicitParam(paramType="query", name = "id", value = "商品id", required = true, dataType = "long")
 public String update(@RequestParam(required = true) long id,
       @RequestParam(required = false) String name,
       @RequestParam(required = false) String description){
  Optional<GoodsInfo> goodsInfo = goodsRepository.findById(id);
  if(goodsInfo.isPresent()){
   if(name != null){
    goodsInfo.get().setName(name);
   }
   if(description != null){
    goodsInfo.get().setDescription(description);
   }
   goodsRepository.save(goodsInfo.get());
   return "success";
  }else{
   return "no find";
  }
 
 }
 
 @ResponseBody
 @RequestMapping(value = "/getOne", method = RequestMethod.GET)
 @ApiOperation(value = "得到一个商品")
 @ApiImplicitParam(paramType="query", name = "id", value = "商品id", required = true, dataType = "long")
 public Optional<GoodsInfo> getOne(@RequestParam(required = true) long id){
  Optional<GoodsInfo> goodsInfo = goodsRepository.findById(id);
  return goodsInfo;
 }
 
 private SearchQuery getEntitySearchQuery(int pageNumber, String searchContent){
  Pageable pageable = PageRequest.of(pageNumber, 20);
  SearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(queryStringQuery(searchContent)).withPageable(pageable).build();
  return searchQuery;
 }
 
 @ResponseBody
 @RequestMapping(value = "/search", method = RequestMethod.GET)
 @ApiOperation(value = "搜索商品")
 public List<GoodsInfo> search(@RequestParam(required = true) Integer pageNumber, @RequestParam(required = true) String query){
  SearchQuery searchQuery = getEntitySearchQuery(pageNumber, query);
  Page<GoodsInfo> goodsPage = goodsRepository.search(searchQuery);
  return goodsPage.getContent();
 }
 
}

总结

以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对脚本之家的支持。

相关文章

  • SpringBoot参数校验与国际化使用教程

    SpringBoot参数校验与国际化使用教程

    这篇文章主要给大家介绍了关于SpringBoot参数校验与国际化使用教程的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-11-11
  • 解决Spring Cloud Feign 请求时附带请求头的问题

    解决Spring Cloud Feign 请求时附带请求头的问题

    这篇文章主要介绍了解决Spring Cloud Feign 请求时附带请求头的问题,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-10-10
  • java实战小技巧之优雅的实现字符串拼接

    java实战小技巧之优雅的实现字符串拼接

    字符串拼接是我们在Java代码中比较经常要做的事情,就是把多个字符串拼接到一起,这篇文章主要给大家介绍了关于java实战小技巧之优雅的实现字符串拼接的相关资料,需要的朋友可以参考下
    2021-08-08
  • 两天没解决的问题chatgpt用了5秒搞定隐藏bug

    两天没解决的问题chatgpt用了5秒搞定隐藏bug

    这篇文章主要为大家描述了我用了两天没解决的问题chatgpt用了5秒搞定的全程介绍,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-04-04
  • Spring中基于Java的配置@Configuration和@Bean用法详解

    Spring中基于Java的配置@Configuration和@Bean用法详解

    这篇文章主要介绍了Spring中基于Java的配置@Configuration和@Bean用法详解,Spring中为了减少xml中配置,可以声明一个配置类(例如SpringConfig)来对bean进行配置。,需要的朋友可以参考下
    2019-06-06
  • 如何基于Springboot完成新增员工功能并设置全局异常处理器

    如何基于Springboot完成新增员工功能并设置全局异常处理器

    最近工作中遇到了做一个管理员工信息的功能,下面这篇文章主要给大家介绍了关于如何基于Springboot完成新增员工功能并设置全局异常处理器的相关资料,文中通过图文介绍的非常详细,需要的朋友可以参考下
    2022-11-11
  • Java压缩文件夹最实用简单的方法

    Java压缩文件夹最实用简单的方法

    在本篇内容里小编给大家整理的是一篇关于Java压缩文件夹最实用简单的方法以及相关实例,有需要的朋友们可以跟着学习下。
    2022-11-11
  • springboot框架的全局异常处理方案详解

    springboot框架的全局异常处理方案详解

    这篇文章主要介绍了springboot框架的全局异常处理方案,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2021-03-03
  • 利用Java实现动态加载数据库

    利用Java实现动态加载数据库

    这篇文章主要为大家详细介绍了一个java小案例,即动态加载数据库信息,文中的示例代码简洁易懂,具有一定的学习价值,感兴趣的小伙伴可以了解一下
    2023-10-10
  • 深入理解java三种工厂模式

    深入理解java三种工厂模式

    下面小编就为大家带来一篇深入理解java三种工厂模式。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2016-06-06

最新评论