es(elasticsearch)整合SpringCloud（SpringBoot）搭建教程詳解

阿新 • • 發佈：2020-06-23

注意：適用於springboot或者springcloud框架

1.首先下載相關檔案
2.然後需要去啟動相關的啟動檔案

請新增圖片描述

3、匯入相關jar包（如果有相關的依賴包不需要匯入）以及配置配置檔案，並且寫一個dao介面繼承一個類，在啟動類上標註地址

<dependency>
 <groupId>org.projectlombok</groupId>
 <artifactId>lombok</artifactId>
</dependency>

<dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>

## ElasticSearch - start
#開啟 Elasticsearch 倉庫(預設值:true)
spring.data.elasticsearch.repositories.enabled=true
spring.data.elasticsearch.cluster-nodes=localhost:9300
spring.data.elasticsearch.cluster-name=myes

Shop：是下面建立的實體類名稱（不能寫錯），String（傳參時的型別，我這裡id也給的String，因為integer報錯）

import com.jk.user.model.Shop;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
public interface EsDao extends ElasticsearchRepository<Shop,String> {
}

啟動類上加上註解，後面跟的是dao的包名

@EnableElasticsearchRepositories(basePackages = "com.jk.web.dao")

4.實體類
indexName相當於資料庫名， type 相當於表名，必須加上id，type 型別，analyzer 分詞器名稱（ik分詞）

@Document(indexName = "zth",type = "t_shangpin")
public class Shop implements Serializable {
 private static final long serialVersionUID = 2006762641515872124L;

 private String id;

 @Field(type = FieldType.Text,analyzer = "ik_max_word")
 //商品名稱
 private String shopname;

 //優惠價格
 private Long reducedprice;
}

5.然後寫controller層（這裡直接注入dao介面），這裡新增我選的是物件迴圈賦值，其實可以直接賦集合（參考）

//elasticsearch 生成表
 // @RequestMapping("el")
 // @ResponseBody
 // public void el(){

 // List<ElasticsearchBean> list=shoppService.queryelasticsearch();
 // for (ElasticsearchBean ss: list) {
 //  ss.setScrenicName(ss.getScrenicName()+""+ss.getHotelName());
 // }
 // elasticsearch.saveAll(list);

 // }

@Autowired
private EsDao esDao;
// 查詢時需要
@Autowired
private ElasticsearchTemplate elasticsearchTemplate ;

//更新es伺服器資料
@RequestMapping("addEs")
public boolean addShopEs() {
 List<TShangpin> list = webUserService.queryShouye();//先去後臺查出資料在賦值
 Shop shop = new Shop();
 try {
 for (int i = 0; i < list.size(); i++) {
  shop.setId(list.get(i).getShopid().toString());
  shop.setShopname(list.get(i).getShopname());
  esDao.save(shop);
 }
 return true;
 } catch (Exception e) {
 e.printStackTrace();
 return false;
 }
}
//es搜尋商品
@RequestMapping("queryShop")
public List ellist(String name,HttpSession session,Integer page,Integer rows){
 if (name==null||"".equals(name)){
 name = session.getAttribute("name").toString();
 }
 page=1;
 rows=3;
 HashMap<String,Object> resultMap = new HashMap<>();
 //建立一個要搜尋的索引庫
 SearchRequestBuilder searchRequestBuilder = elasticsearchTemplate.getClient().prepareSearch("zth").setTypes("t_shangpin");


 //建立組合查詢
 BoolQueryBuilder boolQueryBuilder = new BoolQueryBuilder();

 if (name!=null && !"".equals(name)){
 boolQueryBuilder.should(QueryBuilders.matchQuery("shopname",name));
 }
 //設定查詢的型別
 searchRequestBuilder.setSearchType(SearchType.DFS_QUERY_THEN_FETCH);
 searchRequestBuilder.setQuery(boolQueryBuilder);

 //分頁
 searchRequestBuilder.setFrom((page-1)*rows);
 searchRequestBuilder.setSize(rows);
 //設定高亮欄位
 HighlightBuilder highlightBuilder = new HighlightBuilder();
 highlightBuilder.field("shopname")
  .preTags("<font color='red'>")
  .postTags("</font>");
 searchRequestBuilder.highlighter(highlightBuilder);

 //直接搜尋返回響應資料 （json）
 SearchResponse searchResponse = searchRequestBuilder.get();
 SearchHits hits = searchResponse.getHits();
 //獲取總條數
 long totalHits = hits.getTotalHits();
 resultMap.put("total",totalHits);

 ArrayList<Map<String,Object>> list = new ArrayList<>();
 //獲取Hits中json物件資料
 SearchHit[] hits1 = hits.getHits();
 for (int i=0;i<hits1.length;i++){
 //獲取Map物件
 Map<String,Object> sourceAsMap = hits1[i].getSourceAsMap();
 //獲取高亮欄位
 Map<String,HighlightField> highlightFields = hits1[i].getHighlightFields();
 //！！如果有高亮欄位就取出賦給上面sourceAsMap中原有的名字給他替換掉！！
 if (name!=null && !"".equals(name)){
  sourceAsMap.put("shopname",highlightFields.get("shopname").getFragments()[0].toString());
 }
 list.add(sourceAsMap);
 }

 return list;

}

6.最後如果無法搜尋，可能是需要加一個ik的json檔案，因為在實體類中規定了是ik分詞器，如果不規定當它存進去後其實是還沒有分詞。

film-mapping.json

{ 
"film": 
{ 
"_all":
{
"enabled": true 
},"properties":
{ "id": 
{ 
"type": "integer"
},"name":
{
"type": "text","analyzer": "ikSearchAnalyzer","search_analyzer": "ikSearchAnalyzer","fields":
{ "pinyin": { 
"type": "text","analyzer": "pinyinSimpleIndexAnalyzer","search_analyzer": "pinyinSimpleIndexAnalyzer" 
} } },"nameOri": { "type": "text" 
},"publishDate": 
{ "type": "text" },"type": 
{ "type": "text"
},"language": 
{ "type": "text" 
},"fileDuration":
{ "type": "text" 
},"director":
{ "type": "text","index": "true","analyzer": "ikSearchAnalyzer"
 },"created": 
 {
 "type": "date","format": "yyyy-MM-dd HH:mm:ss||yyyy-MM-dd||epoch_millis" 
 } } } }

film-setting.json

在這裡插入圖片描述

{ "index": { "analysis": 
{ "filter":
{ "edge_ngram_filter": 
{ "type": "edge_ngram","min_gram": 1,"max_gram": 50 
},"pinyin_simple_filter": 
{
 "type": "pinyin","first_letter": "prefix","padding_char": " ","limit_first_letter_length": 50,"lowercase": true
 } 
},"char_filter": 
 { 
"tsconvert": { "type": "stconvert","convert_type": "t2s" 
 } 
},"analyzer":
 { "ikSearchAnalyzer": 
 { "type": "custom","tokenizer": "ik_max_word","char_filter": [ "tsconvert" ]
 },"pinyinSimpleIndexAnalyzer": 
 { "tokenizer": "keyword","filter": [ "pinyin_simple_filter","edge_ngram_filter","lowercase" ] 
 } } } } }

在這裡插入圖片描述