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();
 }
 
}

总结

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