ElasticSearch怎么在Springboot中使用

这期内容当中小编将会给大家带来有关ElasticSearch怎么在Spring boot中使用，文章内容丰富且以专业的角度为大家分析和叙述，阅读完这篇文章希望大家可以有所收获。

邳州网站建设公司创新互联建站,邳州网站设计制作，有大型网站制作公司丰富经验。已为邳州数千家提供企业网站建设服务。企业网站搭建\外贸营销网站建设要多少钱，请找那个售后服务好的邳州做网站的公司定做！

1.安装ElasticSearch

解压，到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

 4.0.0
 
  org.springframework.boot
  spring-boot-starter-parent
  2.1.1.RELEASE
   
 
 com.example
 demo
 0.0.1-SNAPSHOT
 demo
 Demo project for Spring Boot
 jar
 
 
  1.8
 
 
 
  
  
   io.springfox
   springfox-swagger2
   2.6.1
  
  
   io.springfox
   springfox-swagger-ui
   2.6.1
  
  
 
  
   org.springframework.boot
   spring-boot-starter-data-elasticsearch
  
 
  
   org.springframework.boot
   spring-boot-starter
  
 
  
   org.springframework.boot
   spring-boot-starter-test
   test
  
 
  
   org.springframework.boot
   spring-boot-starter-web
  
 
 
 
  
   
    org.springframework.boot
    spring-boot-maven-plugin
   
  
 
 

主要添加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 {
}

这里会帮你封装了很多了

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 = 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 getOne(@RequestParam(required = true) long id){
  Optional 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 search(@RequestParam(required = true) Integer pageNumber, @RequestParam(required = true) String query){
  SearchQuery searchQuery = getEntitySearchQuery(pageNumber, query);
  Page goodsPage = goodsRepository.search(searchQuery);
  return goodsPage.getContent();
 }
 
}

上述就是小编为大家分享的ElasticSearch怎么在Spring boot中使用了，如果刚好有类似的疑惑，不妨参照上述分析进行理解。如果想知道更多相关知识，欢迎关注创新互联行业资讯频道。