服务器之家：专注于服务器技术及软件下载分享
分类导航

PHP教程|ASP.NET教程|Java教程|ASP教程|编程技术|正则表达式|C/C++|IOS|C#|Swift|Android|VB|R语言|JavaScript|易语言|vb.net|

服务器之家 - 编程语言 - Java教程 - Spring boot中使用ElasticSearch的方法详解

Spring boot中使用ElasticSearch的方法详解

2021-07-01 14:54Waiting For You Java教程

这篇文章主要给大家介绍了关于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 测试的，解压就能用

Spring boot中使用ElasticSearch的方法详解

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

1.1安装elasticsearch-head

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

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

?
1
2
3
4
5
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

?
1
2
3
4
5
6
7
8
9
10
connect: {
   server: {
    options: {
     hostname: '0.0.0.0',
     port: 9100,
     base: '.',
     keepalive: true
    }
   }
  }

Spring boot中使用ElasticSearch的方法详解

8082改成你自己的端口

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

Spring boot中使用ElasticSearch的方法详解

0是第一页

application.properties

?
1
2
3
4
#===es start===
spring.data.elasticsearch.repositories.enabled = true
spring.data.elasticsearch.cluster-nodes = 127.0.0.1:9300
#===es end===

2.porm

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
<?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

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
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

?
1
2
3
4
5
6
7
8
9
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

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
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();
 }
 
}

Spring boot中使用ElasticSearch的方法详解

总结

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

原文链接：http://www.waitingfy.com/archives/5256

  • spring boot
  • ElasticSearch

    • 延伸 · 阅读

    精彩推荐
    最近更新
    编辑推荐
    阅读排行
    热门标签
    501 　 406 　 415 　 1433 　 2000 　 401 　 330 　 GOF23 　 堆栈类 　 微信公众号 　 注册服务 　 嵌套循环 　 critical 　 consul 　 spring 　 集合 　 volatile 　 Hibernate 　 Java 　 new 　 double 　 泛型 　 Java编程 　 遍历 　 设计模式 　 supplyAsync 　 制表符 　 回车 　 写入文件 　 JAVA8 　
    © 2019-2024 服务器之家(www.zzvips.com) 版权所有关于我们联系我们版权申明网站地图