站長資訊網本篇文章給大家介紹一下PHP中使用Elasticsearch的簡單方法。有一定的參考價值，有需要的朋友可以參考一下，希望對大家有所幫助。
推薦學習：《PHP視頻教程》
PHP中使用Elasticsearch
composer require elasticsearch/elasticsearch
會自動加載合適的版本！我的php是5.6的，它會自動加載5.3的elasticsearch版本！
Using version ^5.3 for elasticsearch/elasticsearch ./composer.json has been updated Loading composer repositories with package information Updating dependencies (including require-dev) Package operations: 4 installs, 0 updates, 0 removals - Installing react/promise (v2.7.0): Downloading (100%) - Installing guzzlehttp/streams (3.0.0): Downloading (100%) - Installing guzzlehttp/ringphp (1.1.0): Downloading (100%) - Installing elasticsearch/elasticsearch (v5.3.2): Downloading (100%) Writing lock file Generating autoload files
簡單使用
<?php class MyElasticSearch { private $es; // 構造函數 public function __construct() { include('../vendor/autoload.php'); $params = array( '127.0.0.1:9200' ); $this->es = ElasticsearchClientBuilder::create()->setHosts($params)->build(); } public function search() { $params = [ 'index' => 'megacorp', 'type' => 'employee', 'body' => [ 'query' => [ 'constant_score' => [ //非評分模式執行 'filter' => [ //過濾器，不會計算相關度，速度快 'term' => [ //精確查找，不支持多個條件 'about' => '譚' ] ] ] ] ] ]; $res = $this->es->search($params); print_r($res); } }
<?php require "./MyElasticSearch.php"; $es = new MyElasticSearch(); $es->search();
執行結果
Array ( [took] => 2 [timed_out] => [_shards] => Array ( [total] => 5 [successful] => 5 [skipped] => 0 [failed] => 0 ) [hits] => Array ( [total] => 1 [max_score] => 1 [hits] => Array ( [0] => Array ( [_index] => megacorp [_type] => employee [_id] => 3 [_score] => 1 [_source] => Array ( [first_name] => 李 [last_name] => 四 [age] => 24 [about] => 一個PHP程序員，熱愛編程，譚康很帥，充滿激情。 [interests] => Array ( [0] => 英雄聯盟 ) ) ) ) ) )
下面是官方的一些樣例整合，
<?php require '../vendor/autoload.php'; use ElasticsearchClientBuilder; class MyElasticSearch { private $client; // 構造函數 public function __construct() { $params = array( '127.0.0.1:9200' ); $this->client = ClientBuilder::create()->setHosts($params)->build(); } // 創建索引 public function create_index($index_name = 'test_ik') { // 只能創建一次 $params = [ 'index' => $index_name, 'body' => [ 'settings' => [ 'number_of_shards' => 5, 'number_of_replicas' => 0 ] ] ]; try { return $this->client->indices()->create($params); } catch (ElasticsearchCommonExceptionsBadRequest400Exception $e) { $msg = $e->getMessage(); $msg = json_decode($msg,true); return $msg; } } // 刪除索引 public function delete_index($index_name = 'test_ik') { $params = ['index' => $index_name]; $response = $this->client->indices()->delete($params); return $response; } // 創建文檔模板 public function create_mappings($type_name = 'goods',$index_name = 'test_ik') { $params = [ 'index' => $index_name, 'type' => $type_name, 'body' => [ $type_name => [ '_source' => [ 'enabled' => true ], 'properties' => [ 'id' => [ 'type' => 'integer', // 整型 'index' => 'not_analyzed', ], 'title' => [ 'type' => 'string', // 字符串型 'index' => 'analyzed', // 全文搜索 'analyzer' => 'ik_max_word' ], 'content' => [ 'type' => 'string', 'index' => 'analyzed', 'analyzer' => 'ik_max_word' ], 'price' => [ 'type' => 'integer' ] ] ] ] ]; $response = $this->client->indices()->putMapping($params); return $response; } // 查看映射 public function get_mapping($type_name = 'goods',$index_name = 'test_ik') { $params = [ 'index' => $index_name, 'type' => $type_name ]; $response = $this->client->indices()->getMapping($params); return $response; } // 添加文檔 public function add_doc($id,$doc,$index_name = 'test_ik',$type_name = 'goods') { $params = [ 'index' => $index_name, 'type' => $type_name, 'id' => $id, 'body' => $doc ]; $response = $this->client->index($params); return $response; } // 判斷文檔存在 public function exists_doc($id = 1,$index_name = 'test_ik',$type_name = 'goods') { $params = [ 'index' => $index_name, 'type' => $type_name, 'id' => $id ]; $response = $this->client->exists($params); return $response; } // 獲取文檔 public function get_doc($id = 1,$index_name = 'test_ik',$type_name = 'goods') { $params = [ 'index' => $index_name, 'type' => $type_name, 'id' => $id ]; $response = $this->client->get($params); return $response; } // 更新文檔 public function update_doc($id = 1,$index_name = 'test_ik',$type_name = 'goods') { // 可以靈活添加新字段,最好不要亂添加 $params = [ 'index' => $index_name, 'type' => $type_name, 'id' => $id, 'body' => [ 'doc' => [ 'title' => '蘋果手機iPhoneX' ] ] ]; $response = $this->client->update($params); return $response; } // 刪除文檔 public function delete_doc($id = 1,$index_name = 'test_ik',$type_name = 'goods') { $params = [ 'index' => $index_name, 'type' => $type_name, 'id' => $id ]; $response = $this->client->delete($params); return $response; } // 查詢文檔 (分頁，排序，權重，過濾) public function search_doc($keywords = "電腦",$index_name = "test_ik",$type_name = "goods",$from = 0,$size = 2) { $params = [ 'index' => $index_name, 'type' => $type_name, 'body' => [ 'query' => [ 'bool' => [ 'should' => [ [ 'match' => [ 'title' => [ 'query' => $keywords, 'boost' => 3, // 權重大 ]]], [ 'match' => [ 'content' => [ 'query' => $keywords, 'boost' => 2, ]]], ], ], ], 'sort' => ['price'=>['order'=>'desc']] , 'from' => $from, 'size' => $size ] ]; $results = $this->client->search($params); // $maxScore = $results['hits']['max_score']; // $score = $results['hits']['hits'][0]['_score']; // $doc = $results['hits']['hits'][0]['_source']; return $results; } }
<?php require "./MyElasticSearch.php"; $es = new MyElasticSearch(); $r = $es->delete_index(); $r = $es->create_index(); $r = $es->create_mappings(); $r = $es->get_mapping(); print_r($r); $docs = []; $docs[] = ['id'=>1,'title'=>'蘋果手機','content'=>'蘋果手機，很好很強大。','price'=>1000]; $docs[] = ['id'=>2,'title'=>'華為手環','content'=>'榮耀手環，你值得擁有。','price'=>300]; $docs[] = ['id'=>3,'title'=>'小度音響','content'=>'智能生活，快樂每一天。','price'=>100]; $docs[] = ['id'=>4,'title'=>'王者榮耀','content'=>'游戲就玩王者榮耀，快樂生活，很好很強大。','price'=>998]; $docs[] = ['id'=>5,'title'=>'小汪糕點','content'=>'糕點就吃小汪，好吃看得見。','price'=>98]; $docs[] = ['id'=>6,'title'=>'小米手環3','content'=>'秒殺限量，快來。','price'=>998]; $docs[] = ['id'=>7,'title'=>'iPad','content'=>'iPad，不一樣的電腦。','price'=>2998]; $docs[] = ['id'=>8,'title'=>'中華人民共和國','content'=>'中華人民共和國，偉大的國家。','price'=>19999]; foreach ($docs as $k => $v) { $r = $es->add_doc($v['id'],$v); print_r($r); } $r = $es->get_doc(); $r = $es->update_doc(); $r = $es->delete_doc(); $r = $es->exists_doc(); $r = $es->search_doc("手環 電腦"); $r = $es->search_doc("玩"); $r = $es->search_doc("中華"); print_r($r);
