SpringBoot整合ElasticSearch实现增删改查基本示例

　　Spring Boot整合ElasticSearch实现增删改查基本示例
　　ElasticSearch被命名为大数据搜索引擎，在文件检索、数据存储方面具有天然的优势。而SpringBoot作为服务整合中间件，在服务组装方面是一款万能粘合器，本文主要提供Spring Boot整合ElasticSearch基本增删改示例。一、ElasticSearch安装
　　ElasticSearch安装过程可参考博主之前笔文:
　　https://www.toutiao.com/i6827758978567504392/二、ElasticSearch基本介绍
　　ElasticSearch基本介绍可参考博主之前笔文：
　　https://www.toutiao.com/i6884427730096488971/三、Spring Boot项目引入ElasticSearch坐标
　　Maven工程引入:
　　org.springframework.boot
　　spring-boot-starter-data-elasticsearch
　　
　　注意:ElasticSearch版本号与Spring Boot版本号是有关联的，本文笔者Spring Boot版本号是2.1.6，因此安装的ElasticSearch版本号是7.7.0。四、声明ElasticSearch Model层工具
　　package com.opendi.generator.elasticsearch.model;
　　import lombok.Data;
　　import org.springframework.data.annotation.Id;
　　import org.springframework.data.elasticsearch.annotations.Document;
　　import org.springframework.data.elasticsearch.annotations.Field;
　　import org.springframework.data.elasticsearch.annotations.FieldType;
　　import java.util.List;
　　@Data
　　@Document(indexName=＂post＂, type=＂post＂,shards=1,replicas = 0)
　　public class Post {
　　@Id
　　private String id;
　　private String title;
　　@Field(type=FieldType.Nested)
　　private List tags;
　　}
　　package com.opendi.generator.model;
　　import lombok.Data;
　　import org.springframework.data.annotation.Id;
　　import org.springframework.data.elasticsearch.annotations.Document;
　　import org.springframework.data.elasticsearch.annotations.Field;
　　import org.springframework.data.elasticsearch.annotations.FieldType;
　　@Data
　　@Document(indexName = ＂book＂, type = ＂_doc＂, shards = 1, replicas = 0)
　　public class BookBean {
　　@Id
　　private String id;
　　@Field(type = FieldType.Keyword)
　　private String title;
　　@Field(type = FieldType.Keyword)
　　private String author;
　　@Field(type = FieldType.Keyword)
　　private String postDate;
　　public BookBean(){}
　　public BookBean(String id, String title, String author, String postDate){
　　this.id=id;
　　this.title=title;
　　this.author=author;
　　this.postDate=postDate;
　　}
　　public String getId() {
　　return id;
　　}
　　public void setId(String id) {
　　this.id = id;
　　}
　　public String getTitle() {
　　return title;
　　}
　　public void setTitle(String title) {
　　this.title = title;
　　}
　　public String getAuthor() {
　　return author;
　　}
　　public void setAuthor(String author) {
　　this.author = author;
　　}
　　public String getPostDate() {
　　return postDate;
　　}
　　public void setPostDate(String postDate) {
　　this.postDate = postDate;
　　}
　　@Override
　　public String toString() {
　　return ＂BookBean{＂ +
　　＂id=＂＂ + id + ＂＂＂ +
　　＂, title=＂＂ + title + ＂＂＂ +
　　＂, author=＂＂ + author + ＂＂＂ +
　　＂, postDate=＂＂ + postDate + ＂＂＂ +
　　＂}＂;
　　}
　　}
　　声明文档类为ElasticSearch类型的Document文档，字段Field类型也为ES里面的Field类型。五、声明ElasticSearch处理的DAO层工具
　　package com.opendi.generator.elasticsearch.mapper;
　　import com.opendi.generator.elasticsearch.model.Post;
　　import org.springframework.data.domain.Page;
　　import org.springframework.data.domain.Pageable;
　　import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
　　public interface PostRepository extends ElasticsearchRepository {
　　Page findByTitle(String title, Pageable pageable);
　　}
　　package com.opendi.generator.dao;
　　import com.opendi.generator.model.BookBean;
　　import org.springframework.data.domain.Page;
　　import org.springframework.data.domain.Pageable;
　　import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
　　/**
　　* 接口关系：
　　* ElasticsearchRepository --> ElasticsearchCrudRepository --> PagingAndSortingRepository --> CrudRepository
　　*/
　　public interface BookRepository extends ElasticsearchRepository {
　　//Optional findById(String id);
　　Page findByAuthor(String author, Pageable pageable);
　　Page findByTitle(String title, Pageable pageable);
　　}
　　使用了ElasticSearch里面的操作工具对数据进行操作。六、声明ElasticSearch里面的Service层
　　声明Service层操作工具，来源于ElasticSearch工具类，自动进行增删改操作:
　　package com.opendi.generator.elasticsearch.service;
　　import com.opendi.generator.elasticsearch.model.Post;
　　import org.springframework.data.domain.Page;
　　import org.springframework.data.domain.PageRequest;
　　import java.util.Optional;
　　public interface PostService {
　　Post save(Post post);
　　Optional findOne(String id);
　　Iterable findAll();
　　Page findByTitle(String title, PageRequest pageRequest);
　　}
　　指定操作对象:
　　package com.opendi.generator.elasticsearch.service.impl;
　　import com.opendi.generator.elasticsearch.mapper.PostRepository;
　　import com.opendi.generator.elasticsearch.model.Post;
　　import com.opendi.generator.elasticsearch.service.PostService;
　　import org.springframework.beans.factory.annotation.Autowired;
　　import org.springframework.data.domain.Page;
　　import org.springframework.data.domain.PageRequest;
　　import org.springframework.stereotype.Service;
　　import java.util.Optional;
　　@Service
　　public class PostServiceImpl implements PostService {
　　@Autowired
　　private PostRepository postRepository;
　　@Override
　　public Post save(Post post) {
　　postRepository.save(post);
　　return post;
　　}
　　@Override
　　public Optional findOne(String id) {
　　return postRepository.findById(id);
　　}
　　@Override
　　public Iterable findAll() {
　　return postRepository.findAll();
　　}
　　@Override
　　public Page findByTitle(String title, PageRequest pageRequest) {
　　return postRepository.findByTitle(title, pageRequest);
　　}
　　}
　　package com.opendi.generator.service;
　　import com.opendi.generator.model.BookBean;
　　import org.springframework.data.domain.Page;
　　import org.springframework.data.domain.PageRequest;
　　import java.util.List;
　　import java.util.Optional;
　　public interface BookService {
　　Optional findById(String id);
　　BookBean save(BookBean blog);
　　void delete(BookBean blog);
　　Optional findOne(String id);
　　List findAll();
　　Page findByAuthor(String author, PageRequest pageRequest);
　　Page findByTitle(String title, PageRequest pageRequest);
　　}
　　package com.opendi.generator.service.impl;
　　import com.opendi.generator.dao.BookRepository;
　　import com.opendi.generator.model.BookBean;
　　import com.opendi.generator.service.BookService;
　　import org.springframework.beans.factory.annotation.Autowired;
　　import org.springframework.beans.factory.annotation.Qualifier;
　　import org.springframework.data.domain.Page;
　　import org.springframework.data.domain.PageRequest;
　　import org.springframework.stereotype.Service;
　　import java.util.List;
　　import java.util.Optional;
　　@Service(＂blogService＂)
　　public class BookServiceImpl implements BookService {
　　@Autowired
　　@Qualifier(＂bookRepository＂)
　　private BookRepository bookRepository;
　　@Override
　　public Optional findById(String id) {
　　//CrudRepository中的方法
　　return bookRepository.findById(id);
　　}
　　@Override
　　public BookBean save(BookBean blog) {
　　return bookRepository.save(blog);
　　}
　　@Override
　　public void delete(BookBean blog) {
　　bookRepository.delete(blog);
　　}
　　@Override
　　public Optional findOne(String id) {
　　return bookRepository.findById(id);
　　}
　　@Override
　　public List findAll() {
　　return (List) bookRepository.findAll();
　　}
　　@Override
　　public Page findByAuthor(String author, PageRequest pageRequest) {
　　return bookRepository.findByAuthor(author,pageRequest);
　　}
　　@Override
　　public Page findByTitle(String title, PageRequest pageRequest) {
　　return bookRepository.findByTitle(title,pageRequest);
　　}
　　}
　　会调用ElasticSearch底层功能进行操作，能够实现ElasticSearch增删改操作。七、增加服务器配置
　　连接服务器ElasticSearch连接配置:
　　spring:
　　data:
　　elasticsearch:
　　cluster-name: es2018
　　cluster-nodes: 10.172.8.154:9300
　　repositories:
　　enabled: true
　　elasticsearch:
　　jest:
　　uris: http:// 10.172.8.154:9200
　　增加连接配置,这样就能连接ElasticSearch客户端了。八、ElasticSearch Controller层操作
　　ElasticSearch在Controller操作:
　　package com.opendi.generator.controller;
　　import com.opendi.generator.model.BookBean;
　　import com.opendi.generator.service.BookService;
　　import org.springframework.beans.factory.annotation.Autowired;
　　import org.springframework.web.bind.annotation.PathVariable;
　　import org.springframework.web.bind.annotation.RequestMapping;
　　import org.springframework.web.bind.annotation.ResponseBody;
　　import org.springframework.web.bind.annotation.RestController;
　　import java.util.Optional;
　　@RestController
　　public class ElasticController {
　　@Autowired
　　private BookService bookService;
　　@RequestMapping(＂/book/{id}＂)
　　@ResponseBody
　　public BookBean getBookById(@PathVariable String id){
　　Optional opt =bookService.findById(id);
　　BookBean book=opt.get();
　　System.out.println(book);
　　return book;
　　}
　　@RequestMapping(＂/save＂)
　　@ResponseBody
　　public void Save(){
　　System.setProperty(＂es.set.netty.runtime.available.processors＂, ＂false＂);
　　BookBean book=new BookBean(＂1＂,＂ES入门教程＂,＂程裕强＂,＂2018-10-01＂);
　　System.out.println(book);
　　bookService.save(book);
　　}
　　}
　　package com.opendi.generator.elasticsearch.controller;
　　import com.opendi.generator.elasticsearch.model.Post;
　　import com.opendi.generator.elasticsearch.model.Tag;
　　import com.opendi.generator.elasticsearch.service.PostService;
　　import io.swagger.annotations.Api;
　　import io.swagger.annotations.ApiOperation;
　　import org.springframework.beans.factory.annotation.Autowired;
　　import org.springframework.data.domain.Page;
　　import org.springframework.data.domain.PageRequest;
　　import org.springframework.web.bind.annotation.GetMapping;
　　import org.springframework.web.bind.annotation.RestController;
　　import java.util.ArrayList;
　　import java.util.Arrays;
　　import java.util.List;
　　@Api(tags=＂ElasticSearch示例＂)
　　@RestController
　　public class PostController {
　　@Autowired
　　private PostService postService;
　　@ApiOperation(value=＂得到ES结果＂)
　　@GetMapping(value=＂getList＂)
　　public List> getList()
　　{
　　List> list = new ArrayList>();
　　Tag tag = new Tag();
　　tag.setId(＂1＂);
　　tag.setName(＂tech＂);
　　Tag tag2 = new Tag();
　　tag2.setId(＂2＂);
　　tag2.setName(＂elasticSearch＂);
　　Post post = new Post();
　　post.setId(＂1＂);
　　post.setTitle(＂This is post＂);
　　post.setTags(Arrays.asList(tag,tag2));
　　postService.save(post);
　　Post post2 = new Post();
　　post2.setId(＂2＂);
　　post2.setTitle(＂Biding2＂);
　　post2.setTags(Arrays.asList(tag));
　　postService.save(post2);
　　Page posts = postService.findByTitle(＂This is post＂, new PageRequest(0, 10));
　　Page posts2 = postService.findByTitle(＂Biding2＂, new PageRequest(0,10));
　　Page posts3 = postService.findByTitle(＂Biding2＂, new PageRequest(0,10));
　　list.add(posts);
　　list.add(posts2);
　　list.add(posts3);
　　return list;
　　}
　　}九、运行效果
　　控制台打印: