广场 › 编程语言 › Spring boot中使用ElasticSearch的方法详解

浅沫记忆 发表于 2021-10-5 22:20:47

Spring boot中使用ElasticSearch的方法详解

这篇文章主要给大家介绍了关于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();
}

}

总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对CodeAE代码之家的支持。
原文链接：http://www.waitingfy.com/archives/5256

http://www.zzvips.com/article/174860.html

查看完整版本: Spring boot中使用ElasticSearch的方法详解