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;
}
}九、运行效果
控制台打印: