浅谈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(&#39;../vendor/autoload.php&#39;);
        $params = array(
            &#39;127.0.0.1:9200&#39;
        );
        $this->es = \Elasticsearch\ClientBuilder::create()->setHosts($params)->build();
    }

    public function search() {
        $params = [
            &#39;index&#39; => &#39;megacorp&#39;,
            &#39;type&#39; => &#39;employee&#39;,
            &#39;body&#39; => [
                &#39;query&#39; => [
                    &#39;constant_score&#39; => [ //非评分模式执行
                        &#39;filter&#39; => [ //过滤器，不会计算相关度，速度快
                            &#39;term&#39; => [ //精确查找，不支持多个条件
                                &#39;about&#39; => &#39;谭&#39;
                            ]
                        ]

                    ]
                ]
            ]
        ];

        $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 &#39;../vendor/autoload.php&#39;;
use Elasticsearch\ClientBuilder;
class MyElasticSearch
{
    private $client;
    // 构造函数
    public function __construct()
    {
        $params = array(
            &#39;127.0.0.1:9200&#39;
        );
        $this->client = ClientBuilder::create()->setHosts($params)->build();
    }

    // 创建索引
    public function create_index($index_name = &#39;test_ik&#39;) { // 只能创建一次
        $params = [
            &#39;index&#39; => $index_name,
            &#39;body&#39; => [
                &#39;settings&#39; => [
                    &#39;number_of_shards&#39; => 5,
                    &#39;number_of_replicas&#39; => 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 = &#39;test_ik&#39;) {
        $params = [&#39;index&#39; => $index_name];
        $response = $this->client->indices()->delete($params);
        return $response;
    }

    // 创建文档模板
    public function create_mappings($type_name = &#39;goods&#39;,$index_name = &#39;test_ik&#39;) {

        $params = [
            &#39;index&#39; => $index_name,
            &#39;type&#39; => $type_name,
            &#39;body&#39; => [
                $type_name => [
                    &#39;_source&#39; => [
                        &#39;enabled&#39; => true
                    ],
                    &#39;properties&#39; => [
                        &#39;id&#39; => [
                            &#39;type&#39; => &#39;integer&#39;, // 整型
                            &#39;index&#39; => &#39;not_analyzed&#39;,
                        ],
                        &#39;title&#39; => [
                            &#39;type&#39; => &#39;string&#39;, // 字符串型
                            &#39;index&#39; => &#39;analyzed&#39;, // 全文搜索
                            &#39;analyzer&#39; => &#39;ik_max_word&#39;
                        ],
                        &#39;content&#39; => [
                            &#39;type&#39; => &#39;string&#39;,
                            &#39;index&#39; => &#39;analyzed&#39;,
                            &#39;analyzer&#39; => &#39;ik_max_word&#39;
                        ],
                        &#39;price&#39; => [
                            &#39;type&#39; => &#39;integer&#39;
                        ]
                    ]
                ]
            ]
        ];

        $response = $this->client->indices()->putMapping($params);
        return $response;
    }

    // 查看映射
    public function get_mapping($type_name = &#39;goods&#39;,$index_name = &#39;test_ik&#39;) {
        $params = [
            &#39;index&#39; => $index_name,
            &#39;type&#39; => $type_name
        ];
        $response = $this->client->indices()->getMapping($params);
        return $response;
    }

    // 添加文档
    public function add_doc($id,$doc,$index_name = &#39;test_ik&#39;,$type_name = &#39;goods&#39;) {
        $params = [
            &#39;index&#39; => $index_name,
            &#39;type&#39; => $type_name,
            &#39;id&#39; => $id,
            &#39;body&#39; => $doc
        ];

        $response = $this->client->index($params);
        return $response;
    }

    // 判断文档存在
    public function exists_doc($id = 1,$index_name = &#39;test_ik&#39;,$type_name = &#39;goods&#39;) {
        $params = [
            &#39;index&#39; => $index_name,
            &#39;type&#39; => $type_name,
            &#39;id&#39; => $id
        ];

        $response = $this->client->exists($params);
        return $response;
    }


    // 获取文档
    public function get_doc($id = 1,$index_name = &#39;test_ik&#39;,$type_name = &#39;goods&#39;) {
        $params = [
            &#39;index&#39; => $index_name,
            &#39;type&#39; => $type_name,
            &#39;id&#39; => $id
        ];

        $response = $this->client->get($params);
        return $response;
    }

    // 更新文档
    public function update_doc($id = 1,$index_name = &#39;test_ik&#39;,$type_name = &#39;goods&#39;) {
        // 可以灵活添加新字段,最好不要乱添加
        $params = [
            &#39;index&#39; => $index_name,
            &#39;type&#39; => $type_name,
            &#39;id&#39; => $id,
            &#39;body&#39; => [
                &#39;doc&#39; => [
                    &#39;title&#39; => &#39;苹果手机iPhoneX&#39;
                ]
            ]
        ];

        $response = $this->client->update($params);
        return $response;
    }

    // 删除文档
    public function delete_doc($id = 1,$index_name = &#39;test_ik&#39;,$type_name = &#39;goods&#39;) {
        $params = [
            &#39;index&#39; => $index_name,
            &#39;type&#39; => $type_name,
            &#39;id&#39; => $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 = [
            &#39;index&#39; => $index_name,
            &#39;type&#39; => $type_name,
            &#39;body&#39; => [
                &#39;query&#39; => [
                    &#39;bool&#39; => [
                        &#39;should&#39; => [
                            [ &#39;match&#39; => [ &#39;title&#39; => [
                                &#39;query&#39; => $keywords,
                                &#39;boost&#39; => 3, // 权重大
                            ]]],
                            [ &#39;match&#39; => [ &#39;content&#39; => [
                                &#39;query&#39; => $keywords,
                                &#39;boost&#39; => 2,
                            ]]],
                        ],
                    ],
                ],
                &#39;sort&#39; => [&#39;price&#39;=>[&#39;order&#39;=>&#39;desc&#39;]]
                , &#39;from&#39; => $from, &#39;size&#39; => $size
            ]
        ];

        $results = $this->client->search($params);
//        $maxScore  = $results[&#39;hits&#39;][&#39;max_score&#39;];
//        $score = $results[&#39;hits&#39;][&#39;hits&#39;][0][&#39;_score&#39;];
//        $doc   = $results[&#39;hits&#39;][&#39;hits&#39;][0][&#39;_source&#39;];
        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[] = [&#39;id&#39;=>1,&#39;title&#39;=>&#39;苹果手机&#39;,&#39;content&#39;=>&#39;苹果手机，很好很强大。&#39;,&#39;price&#39;=>1000];
$docs[] = [&#39;id&#39;=>2,&#39;title&#39;=>&#39;华为手环&#39;,&#39;content&#39;=>&#39;荣耀手环，你值得拥有。&#39;,&#39;price&#39;=>300];
$docs[] = [&#39;id&#39;=>3,&#39;title&#39;=>&#39;小度音响&#39;,&#39;content&#39;=>&#39;智能生活，快乐每一天。&#39;,&#39;price&#39;=>100];
$docs[] = [&#39;id&#39;=>4,&#39;title&#39;=>&#39;王者荣耀&#39;,&#39;content&#39;=>&#39;游戏就玩王者荣耀，快乐生活，很好很强大。&#39;,&#39;price&#39;=>998];
$docs[] = [&#39;id&#39;=>5,&#39;title&#39;=>&#39;小汪糕点&#39;,&#39;content&#39;=>&#39;糕点就吃小汪，好吃看得见。&#39;,&#39;price&#39;=>98];
$docs[] = [&#39;id&#39;=>6,&#39;title&#39;=>&#39;小米手环3&#39;,&#39;content&#39;=>&#39;秒杀限量，快来。&#39;,&#39;price&#39;=>998];
$docs[] = [&#39;id&#39;=>7,&#39;title&#39;=>&#39;iPad&#39;,&#39;content&#39;=>&#39;iPad，不一样的电脑。&#39;,&#39;price&#39;=>2998];
$docs[] = [&#39;id&#39;=>8,&#39;title&#39;=>&#39;中华人民共和国&#39;,&#39;content&#39;=>&#39;中华人民共和国，伟大的国家。&#39;,&#39;price&#39;=>19999];

foreach ($docs as $k => $v) {
    $r = $es->add_doc($v[&#39;id&#39;],$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的简单使用方法的详细内容，更多请关注其它相关文章！