好得很程序员自学网

<tfoot draggable='sEl'></tfoot>

浅谈PHP Elasticsearch的简单使用方法
本篇文章给大家介绍一下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 = \Elasticsearch\ClientBuilder::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 Elasticsearch\ClientBuilder;
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 (Elasticsearch\Common\Exceptions\BadRequest400Exception $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);

更多编程相关知识，请访问：编程视频！！

以上就是浅谈PHP Elasticsearch的简单使用方法的详细内容！

查看更多关于浅谈PHP Elasticsearch的简单使用方法的详细内容...

声明：本文来自网络，不代表【好得很程序员自学网】立场，转载请注明出处：http://haodehen.cn/did52576
  阅读：42次

上一篇： 浅谈PHP中的多进程消费队列

下一篇：php5.3.5如何安装

相关资讯