elasticsearch
ElasticSearch是一個基于Lucene的搜索服務器颁独。它提供了一個分布式多用戶能力的全文搜索引擎彩届，基于RESTful web接口。Elasticsearch是用Java開發(fā)的誓酒，并作為Apache許可條款下的開放源碼發(fā)布樟蠕，是當前流行的企業(yè)級搜索引擎。設計用于[云計算]中靠柑，能夠達到實時搜索寨辩，穩(wěn)定，可靠歼冰，快速靡狞，安裝使用方便。
spring boot操作elasticsearch需要通過spring data elasticsearch來實現(xiàn)
添加依賴：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
實現(xiàn)效果：
微信截圖_20180521120057.png
實體類：
package com.example.demo.entity;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
/**
* Created by linziyu on 2018/5/19.
* 實體類
*
*
*/
//定義索引名字及類型
@Document(indexName = "poem",type = "poem",shards = 1, replicas = 0)
public class Poem {
@Id
private long id;
private String title;
private String content;
public Poem(long id, String title, String content) {
this.id = id;
this.title = title;
this.content = content;
}
public Poem(String title, String content) {
this.title = title;
this.content = content;
}
public Poem() {
}
public long getId() {
return id;
}
public void setId(long id) {
this.id = id;
}
public String getTitle() {
return title;
}
public void setTitle(String title) {
this.title = title;
}
public String getContent() {
return content;
}
public void setContent(String content) {
this.content = content;
}
}
dao層
package com.example.demo.repository;
import com.example.demo.entity.Poem;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
/**
* Created by linziyu on 2018/5/19.
* dao層
*
*/
public interface PoemRepository extends ElasticsearchRepository<Poem,Long>{
Page<Poem> findByTitleLikeOrContentLike(String title, String content, Pageable pageable);
Page<Poem> findByContentLike(String content,Pageable pageable);
}
只需要繼承ElasticsearchRepository即可隔嫡，與JpaRepository相似甸怕，里面封裝好了基本的CRUD操作方法。
ElasticsearchRepository源碼：
//
// Source code recreated from a .class file by IntelliJ IDEA
// (powered by Fernflower decompiler)
//
package org.springframework.data.elasticsearch.repository;
import java.io.Serializable;
import org.elasticsearch.index.query.QueryBuilder;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.data.elasticsearch.core.query.SearchQuery;
import org.springframework.data.elasticsearch.repository.ElasticsearchCrudRepository;
import org.springframework.data.repository.NoRepositoryBean;
@NoRepositoryBean
public interface ElasticsearchRepository<T, ID extends Serializable> extends ElasticsearchCrudRepository<T, ID> {
<S extends T> S index(S var1);
Iterable<T> search(QueryBuilder var1);
Page<T> search(QueryBuilder var1, Pageable var2);
Page<T> search(SearchQuery var1);
Page<T> searchSimilar(T var1, String[] var2, Pageable var3);
void refresh();
Class<T> getEntityClass();
}
業(yè)務邏輯接口：
package com.example.demo.service;
import com.example.demo.entity.Poem;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
/**
* Created by linziyu on 2018/5/19.
* 業(yè)務邏輯
*
*/
public interface PoemService {
//保存Poem實體
void save (Poem poem);
//基于title和content進行搜索腮恩，返回分頁
Page<Poem> search(String title, String content, Pageable pageable);
//基于content進行搜索梢杭，返回分頁
Page<Poem> search(String content,Pageable pageable);
//返回所有數(shù)據(jù)集合
Page<Poem> findAll(Pageable pageable);
}
業(yè)務邏輯實現(xiàn)類：
package com.example.demo.service;
import com.example.demo.entity.Poem;
import com.example.demo.repository.PoemRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.stereotype.Service;
/**
* Created by linziyu on 2018/5/19.
*/
@Service
public class PoemServiceImpl implements PoemService{
@Autowired
private PoemRepository poemRepository;
@Override
public void save(Poem poem) {
poemRepository.save(poem);
}
@Override
public Page<Poem> search(String title, String content, Pageable pageable) {
return poemRepository.findByTitleLikeOrContentLike(title,content,pageable);
}
@Override
public Page<Poem> search(String content, Pageable pageable) {
return poemRepository.findByContentLike(content,pageable);
}
@Override
public Page<Poem> findAll(Pageable pageable) {
return poemRepository.findAll(pageable);
}
}
Controller層：
package com.example.demo.controller;
import com.example.demo.entity.Poem;
import com.example.demo.service.PoemServiceImpl;
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.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import java.util.ArrayList;
import java.util.List;
/**
* Created by linziyu on 2018/5/19.
* 控制層
*
*/
@Controller
public class WebController {
@Autowired
private PoemServiceImpl poemService;
// @RequestMapping("/")
// public String index(){
// List<Poem> poems = new ArrayList<>();
// poems.add(new Poem(4,"湘春夜月·近清明","近清明,翠禽枝上消魂,可惜一片清歌，都付與黃昏庆揪。欲共柳花低訴式曲，怕柳花輕薄，不解傷春缸榛。念楚鄉(xiāng)旅宿吝羞，柔情別緒，誰與溫存内颗。"));
// poems.add(new Poem(5,"卜算子·不是愛風塵","不是愛風塵钧排，似被前緣誤【模花落花開自有時恨溜，總賴東君主。\n" +
// "去也終須去找前，住也如何自阍！若得山花插滿頭躺盛，莫問奴歸處"));
// poems.add(new Poem(6,"御街行·秋日懷舊","紛紛墜葉飄香砌项戴。夜寂靜，寒聲碎槽惫。真珠簾卷玉樓空周叮，天淡銀河垂地辩撑。年年今夜，月華如練仿耽，長是人千里合冀。"));
//
// for(int i=0;i<poems.size();i++){
// poemService.save(poems.get(i));
// }
//
//
// return "/index";
//
// }
@RequestMapping("/tt")
public String index1(
@RequestParam(value="pageIndex",required=false,defaultValue="0") int pageIndex,
@RequestParam(value="pageSize",required=false,defaultValue="10") int pageSize,
Model model) {
Pageable pageable = new PageRequest(pageIndex,pageSize);
Page<Poem> poems = poemService.findAll(pageable);
List<Poem> poems1 = poems.getContent();
model.addAttribute("poems",poems);
return "/index";
}
@RequestMapping("/t")
public String index2(@RequestParam(value="content",required=false,defaultValue="香") String content,
@RequestParam(value="pageIndex",required=false,defaultValue="0") int pageIndex,
@RequestParam(value="pageSize",required=false,defaultValue="10") int pageSize,
Model model) {
Pageable pageable = new PageRequest(pageIndex,pageSize);
Page<Poem> poems = poemService.search(content,pageable);
List<Poem> list = poems.getContent();
model.addAttribute("poems",list);
return "/t";
}
@RequestMapping("/search")
public String search(String content, @RequestParam(value="pageIndex",required=false,defaultValue="0") int pageIndex,
@RequestParam(value="pageSize",required=false,defaultValue="10") int pageSize,Model model) {
Pageable pageable = new PageRequest(pageIndex,pageSize);
Page<Poem> poems = poemService.search(content,pageable);
List<Poem> list = poems.getContent();
model.addAttribute("poems",list);
return "/list";
}
}
配置文件：
#存儲索引的位置
#spring.data.elasticsearch.properties.path.home=target/elastic
#連接超時的時間
#server.port=8081
spring.data.elasticsearch.properties.transport.tcp.connect_timeout=120s
spring.data.elasticsearch.repositories.enabled=true
spring.data.elasticsearch.cluster-nodes=localhost:9300 //連接本地elasticsearch
運行整個Demo是需要先開啟本地的elasticsearch服務
整個Demo在我的GitHub：
https://github.com/LinZiYU1996/Spring-Boot-Elasticsearch/tree/master
