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状态，操作的第三方东西
|
1
2
3
4
5
|
git clone git://github.com/mobz/elasticsearch-head.gitcd elasticsearch-headnpm installnpm run startopen 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 } } } |
8082改成你自己的端口
http://127.0.0.1:8082/swagger-ui.html#/
0是第一页
application.properties
|
1
2
3
4
|
#===es start===spring.data.elasticsearch.repositories.enabled = truespring.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; @componentpublic 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(); } } |
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对服务器之家的支持。
原文链接：http://www.waitingfy.com/archives/5256
