詳解Laravel8 ES封裝及其使用方法

composer?require?elasticsearch/elasticsearch

<?php namespace AppEs; use ElasticsearchClientBuilder; class MyEs {     //ES客戶端鏈接     private $client;     /**      * 構造函數(shù)      * MyElasticsearch constructor.      */     public function __construct()     {         $this->client?=?ClientBuilder::create()-&gt;setHosts(['127.0.0.1:9200'])-&gt;build(); ????} ????/** ?????*?判斷索引是否存在 ?????*?@param?string?$index_name ?????*?@return?bool|mixed|string ?????*/ ????public?function?exists_index($index_name?=?'test_ik') ????{ ????????$params?=?[ ????????????'index'?=&gt;?$index_name ????????]; ????????try?{ ????????????return?$this-&gt;client-&gt;indices()-&gt;exists($params); ????????}?catch?(ElasticsearchCommonExceptionsBadRequest400Exception?$e)?{ ????????????$msg?=?$e-&gt;getMessage(); ????????????$msg?=?json_decode($msg,true); ????????????return?$msg; ????????} ????} ????/** ?????*?創(chuàng)建索引 ?????*?@param?string?$index_name ?????*?@return?array|mixed|string ?????*/ ????public?function?create_index($index_name?=?'test_ik')?{?//?只能創(chuàng)建一次 ????????$params?=?[ ????????????'index'?=&gt;?$index_name, ????????????'body'?=&gt;?[ ????????????????'settings'?=&gt;?[ ????????????????????'number_of_shards'?=&gt;?5, ????????????????????'number_of_replicas'?=&gt;?1 ????????????????] ????????????] ????????]; ????????try?{ ????????????return?$this-&gt;client-&gt;indices()-&gt;create($params); ????????}?catch?(ElasticsearchCommonExceptionsBadRequest400Exception?$e)?{ ????????????$msg?=?$e-&gt;getMessage(); ????????????$msg?=?json_decode($msg,true); ????????????return?$msg; ????????} ????} ????/** ?????*?刪除索引 ?????*?@param?string?$index_name ?????*?@return?array ?????*/ ????public?function?delete_index($index_name?=?'test_ik')?{ ????????$params?=?['index'?=&gt;?$index_name]; ????????$response?=?$this-&gt;client-&gt;indices()-&gt;delete($params); ????????return?$response; ????} ????/** ?????*?添加文檔 ?????*?@param?$id ?????*?@param?$doc?['id'=&gt;100,?'title'=&gt;'phone'] ?????*?@param?string?$index_name ?????*?@param?string?$type_name ?????*?@return?array ?????*/ ????public?function?add_doc($id,$doc,$index_name?=?'test_ik',$type_name?=?'goods')?{ ????????$params?=?[ ????????????'index'?=&gt;?$index_name, ????????????'type'?=&gt;?$type_name, ????????????'id'?=&gt;?$id, ????????????'body'?=&gt;?$doc ????????]; ????????$response?=?$this-&gt;client-&gt;index($params); ????????return?$response; ????} ????/** ?????*?判斷文檔存在 ?????*?@param?int?$id ?????*?@param?string?$index_name ?????*?@param?string?$type_name ?????*?@return?array|bool ?????*/ ????public?function?exists_doc($id?=?1,$index_name?=?'test_ik',$type_name?=?'goods')?{ ????????$params?=?[ ????????????'index'?=&gt;?$index_name, ????????????'type'?=&gt;?$type_name, ????????????'id'?=&gt;?$id ????????]; ????????$response?=?$this-&gt;client-&gt;exists($params); ????????return?$response; ????} ????/** ?????*?獲取文檔 ?????*?@param?int?$id ?????*?@param?string?$index_name ?????*?@param?string?$type_name ?????*?@return?array ?????*/ ????public?function?get_doc($id?=?1,$index_name?=?'test_ik',$type_name?=?'goods')?{ ????????$params?=?[ ????????????'index'?=&gt;?$index_name, ????????????'type'?=&gt;?$type_name, ????????????'id'?=&gt;?$id ????????]; ????????$response?=?$this-&gt;client-&gt;get($params); ????????return?$response; ????} ????/** ?????*?更新文檔 ?????*?@param?int?$id ?????*?@param?string?$index_name ?????*?@param?string?$type_name ?????*?@param?array?$body?['doc'?=&gt;?['title'?=&gt;?'蘋果手機iPhoneX']] ?????*?@return?array ?????*/ ????public?function?update_doc($id?=?1,$index_name?=?'test_ik',$type_name?=?'goods',?$body=[])?{ ????????//?可以靈活添加新字段,最好不要亂添加 ????????$params?=?[ ????????????'index'?=&gt;?$index_name, ????????????'type'?=&gt;?$type_name, ????????????'id'?=&gt;?$id, ????????????'body'?=&gt;?$body ????????]; ????????$response?=?$this-&gt;client-&gt;update($params); ????????return?$response; ????} ????/** ?????*?刪除文檔 ?????*?@param?int?$id ?????*?@param?string?$index_name ?????*?@param?string?$type_name ?????*?@return?array ?????*/ ????public?function?delete_doc($id?=?1,$index_name?=?'test_ik',$type_name?=?'goods')?{ ????????$params?=?[ ????????????'index'?=&gt;?$index_name, ????????????'type'?=&gt;?$type_name, ????????????'id'?=&gt;?$id ????????]; ????????$response?=?$this-&gt;client-&gt;delete($params); ????????return?$response; ????} ????/** ?????*?搜索文檔?(分頁，排序，權重，過濾) ?????*?@param?string?$index_name ?????*?@param?string?$type_name ?????*?@param?array?$body ?????*?$body?=?[ ????????????????'query'?=&gt;?[ ????????????????????'match'?=&gt;?[ ????????????????????????'fang_name'?=&gt;?[ ????????????????????????????'query'?=&gt;?$fangName ????????????????????????] ????????????????????] ????????????????], ????????????????'highlight'=&gt;[ ????????????????????'fields'=&gt;[ ????????????????????????'fang_name'=&gt;[ ????????????????????????????'pre_tags'=&gt;[ ????????????????????????????????'<span>' ????????????????????????????], ????????????????????????????'post_tags'=&gt;[ ????????????????????????????????'</span>' ????????????????????????????] ????????????????????????] ????????????????????] ????????????????] ????????????]; ?????*?@return?array ?????*/ ????public?function?search_doc($index_name?=?"test_ik",$type_name?=?"goods",$body=[])?{ ????????$params?=?[ ????????????'index'?=&gt;?$index_name, ????????????'type'?=&gt;?$type_name, ????????????'body'?=&gt;?$body ????????]; ????????$results?=?$this-&gt;client-&gt;search($params); ????????return?$results; ????} }

public?function?esAdd() ????{ ????????$data?=?Good::get()->toArray(); ????????$es?=?new?MyEs(); ????????if?(!$es->exists_index('goods'))?{ ????????????//創(chuàng)建es索引，es的索引相當于MySQL的數(shù)據(jù)庫 ????????????$es->create_index('goods'); ????????} ????????foreach?($data?as?$model)?{ ????????????$es->add_doc($model['id'],?$model,?'goods',?'_doc'); ????????} ????}

????????//添加至MySQL ????????$res=Good::insertGetId($arr); ????????$es?=?new?MyEs(); ????????if?(!$es->exists_index('goods'))?{ ????????????$es->create_index('goods'); ????????} ????????//添加至es ????????$es->add_doc($res,?$arr,?'goods',?'_doc'); ????????return?$res;

??????//修改MySQL的數(shù)據(jù) ????????$res=Good::where('id',$id)->update($arr); ????????$es?=?new?MyEs(); ????????if?(!$es->exists_index('goods'))?{ ????????????$es->create_index('goods'); ????????} ????????//修改es的數(shù)據(jù) ????????$es->update_doc($id,?'goods',?'_doc',['doc'=>$arr]); ????????return?$res;

public?function?search() ????{ ????????//獲取搜索值 ????????$search?=?request()-&gt;get('search'); ????????if?(!empty($search))?{ ????????????$es?=?new?MyEs(); ????????????$body?=?[ ????????????????'query'?=&gt;?[ ????????????????????'match'?=&gt;?[ ????????????????????????'title'?=&gt;?[ ????????????????????????????'query'?=&gt;?$search ????????????????????????] ????????????????????] ????????????????], ????????????????'highlight'=&gt;[ ????????????????????'fields'=&gt;[ ????????????????????????'title'=&gt;[ ????????????????????????????'pre_tags'=&gt;[ ????????????????????????????????'<span>' ????????????????????????????], ????????????????????????????'post_tags'=&gt;[ ????????????????????????????????'</span>' ????????????????????????????] ????????????????????????] ????????????????????] ????????????????] ????????????]; ????????????$res?=?$es-&gt;search_doc('goods',?'_doc',?$body); ????????????$data?=?array_column($res['hits']['hits'],?'_source'); ????????????foreach?($data?as?$key=&gt;&amp;$v){ ?????????????????$v['title']?=?$res['hits']['hits'][$key]['highlight']['title'][0]; ????????????} ????????????unset($v); ????????????return?$data; ????????} ????????$data?=?Good::get(); ????????return?$data; ????}

<rich-text></rich-text>