ElasticSearch是一個基於Lucene的搜索服務器。它提供了一個分布式多用戶能力的全文搜索引擎，基於RESTful web接口。Elasticsearch是用Java開發的，並作為Apache許可條款下的開放源碼發布，是當前流行的企業級搜索引擎。設計用於雲計算中，能夠達到實時搜索，穩定，可靠，快速，安裝使用方便。
我們建立一個網站或應用程序，並要添加搜索功能，但是想要完成搜索工作的創建是非常困難的。我們希望搜索解決方案要運行速度快，我們希望能有一個零配置和一個完全免費的搜索模式，我們希望能夠簡單地使用JSON通過HTTP來索引數據，我們希望我們的搜索服務器始終可用，我們希望能夠從一台開始並擴展到數百台，我們要實時搜索，我們要簡單的多租戶，我們希望建立一個雲的解決方案。因此我們利用Elasticsearch來解決所有這些問題以及可能出現的更多其它問題。
我們需要將這中搜索模式集中到我們的項目中去，從而實現大量數據的搜索功能，性能遠遠超越數據庫查詢!
ElasticSearch : You Know, for Search！
前期安裝
這里安裝不在過多的贅述，這里推薦官方的中文文檔，安裝指引 安裝完成之后，運行啟動，打開瀏覽器，訪問http://localhost:9200 將看到一下信息（cluster_name非常重要后面的代碼要用到）:
{
"name" : "2g-ucq2",
"cluster_name" : "elasticsearch",
"cluster_uuid" : "tpMpsSenRpaBPugKlG7QaA",
"version" : {
"number" : "5.5.0",
"build_hash" : "260387d",
"build_date" : "2017-06-30T23:16:05.735Z",
"build_snapshot" : false,
"lucene_version" : "6.6.0"
},
"tagline" : "You Know, for Search"
}
Maven支持庫安裝
我們使用Maven，因此需要修改POM文件內容，添加如下依賴即可。
<!--ElasticSearch支持文件-->
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>transport</artifactId>
<version>5.5.0</version>
</dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-core</artifactId>
<version>2.7</version>
</dependency>
添加log4j的配置文件
在classpath源目錄下創建log4j2.properties文件,內容信息如下
appender.console.type =Console
appender.console.name =Console
appender.console.layout.type =PatternLayout
appender.console.layout.pattern = [%t] %-5p %c - %m%n
rootLogger.lever = info
rootLogger.appenderRef.console.ref = Console
創建Client客戶端
我們將核心的client對象，使用配置注解進行配置，方便日后取用
package com.tao.spring.config;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.transport.client.PreBuiltTransportClient;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.net.InetAddress;
import java.net.UnknownHostException;
/**
* 本文件由周濤創建,位於com.tao.spring.config包下
* 創建時間2018/1/26 20:42
* 郵箱:zhoutao@xiaodouwangluo.com
* 作用:創建ES的client對象，方便后期使用
*/
@Configuration
public class ElasticSearchConfig {
@Bean
public TransportClient client() throws UnknownHostException{
//注意這里的端口是TCP端口9300,而非HTTP接口9200
InetSocketTransportAddress node = new InetSocketTransportAddress(InetAddress.getByName("localhost"),9300);
//機器名稱，可以首頁查詢，這個不能出現錯誤，否則無法連接ES
Settings settings=Settings.builder().put("cluster.name","elasticsearch").build();
TransportClient client = new PreBuiltTransportClient( settings);
client.addTransportAddress(node);
return client;
}
}
實現增刪改查以及符合查詢
下面將依次實現數據的增刪改查，以及符合查詢，這里我們的的類型是book，其具有兩個屬性分別是bookid和bookprice，具體說明參考注釋。
首先需要注入對象
@Autowired
TransportClient client;
實現查詢數據
需求:實現根據bookid獲取數據的信息
/**
* 使用ES進行簡單的搜索操作
* @param bookid
* @return
*/
@RequestMapping(value = "/get",method = RequestMethod.GET,produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ResponseBody
public String getInfoById(@RequestParam(name = "bookid") String bookid){
if (Strings.isNullOrEmpty(bookid)){
return "缺少參數,或參數格式不正確";
}
//tao指定的書索引，book指的是類型，后面相同，不在做敘述
GetResponse getFields = client.prepareGet("tao", "book", bookid).get();
//這里需要做些判斷，沒有沒有判斷，在沒有查到的情況，會拋出異常信息
if ( getFields ==null || !getFields.isExists()){
return "沒有查詢到結果信息";
}else{
return getFields.getSource().toString();
}
}
實現添加數據
需求:提供bookid和bookprice來插入數據到ES
/**
* 插入一條數據到ES中
* @param bookid
* @param bookprice
* @return
**/
@RequestMapping(value = "/add",method = RequestMethod.GET,produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ResponseBody
public String addInfoToES(String bookid,float bookprice){
if (Strings.isNullOrEmpty(bookid) || bookprice <= 0){
return "參數不存在或者參數格式異常!";
}
try {
//構造JSON數據，方便使用
XContentBuilder xContentBuilder = XContentFactory.jsonBuilder().startObject()
.field("bookid", bookid)
.field("bookprice", bookprice)
.endObject();
IndexResponse indexResponse = client.prepareIndex("tao","book").setSource(xContentBuilder).get();
return "新增圖書信息完成，圖書信息ID為:"+indexResponse.getId();
}catch (IOException ex){
ex.printStackTrace();
return "新增圖書信息失敗,失敗信息:"+ex.getMessage();
}
}
實現刪除數據
需求:根據給定的id,來刪除數據信息
/**
* 從ES中刪除一條數據
* @param bookid
* @return
*/
@RequestMapping(value = "/del",method = RequestMethod.GET,produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ResponseBody
public String delInfo(String bookid){
if (Strings.isNullOrEmpty(bookid)){
return "參數不存在或者參數異常";
}
DeleteResponse deleteResponse = client.prepareDelete("tao", "book", bookid).get();
//將會返回兩個結果:NOT_FOUND 未發現 DELETED 已刪除
return deleteResponse.getResult().toString() ;
}
實現修改數據
修改指定id的數據信息
/**
* 根據Id簡單的修改信息
* @param bookid
* @param bookprice
* @return
*/
@RequestMapping(value = "/modify",method = RequestMethod.GET,produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ResponseBody
public String nodify(String bookid,@RequestParam(required = false) Float bookprice){
UpdateRequest request = new UpdateRequest("tao","book",bookid);
try {
XContentBuilder xContentBuilder = XContentFactory.jsonBuilder().startObject();
if (bookprice.floatValue() <= 0){
return "參數異常或者參數格式錯誤!";
}else {
xContentBuilder.field("bookprice",bookprice).endObject();
}
request.doc(xContentBuilder);
UpdateResponse updateResponse = client.update(request).get();
return updateResponse.getResult().toString();
}catch (Exception e) {
e.printStackTrace();
return "更新數據出現異常,異常信息:"+e.getMessage();
}
}
實現復合查詢數據
需求：精准查詢bookid，范圍查詢bookprice，gt_bookprice 最小的價格，lt_bookprice 最大價格
/**
* 使用ES進行復雜查詢
* @param bookid
* @param gt_bookprice
* @param lt_bookprice
* @return
*/
@RequestMapping(value = "/getConditon",method = RequestMethod.GET,produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ResponseBody
public String querty(@RequestParam(required = false) String bookid,@RequestParam(defaultValue = "0.0") Float gt_bookprice,@RequestParam(required = false)Float lt_bookprice){
//構造查詢條件
BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
if (!Strings.isNullOrEmpty(bookid)){
boolQueryBuilder.must(QueryBuilders.matchQuery( "bookid",bookid));
}
//構造范圍查詢
RangeQueryBuilder rangeQuery = QueryBuilders.rangeQuery("bookprice").from(gt_bookprice,true);
if(lt_bookprice!=null && lt_bookprice.floatValue() > 0){
rangeQuery.to(lt_bookprice);
}
//整合為一個查詢條件
boolQueryBuilder.filter(rangeQuery);
SearchRequestBuilder searchRequestBuilder = client.prepareSearch("tao")
.setTypes("book")
.setSearchType(SearchType.DFS_QUERY_THEN_FETCH)
.setQuery(boolQueryBuilder)
.setFrom(0)
.setSize(10);
//可以直接輸出，方便查看請求體
System.out.println("查詢條件:"+searchRequestBuilder);
SearchResponse searchResponse = searchRequestBuilder.get();
List<Map> result = new ArrayList<>();
//從查詢接口中遍歷數據進行封裝操作
for (SearchHit hitFields:searchResponse.getHits()){
result.add(hitFields.getSource());
}
return result.toString();
}