浅谈PHP Elasticsearch的简单使用方法【PHP教程】

概述浅谈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 updatedLoading composer repositorIEs with package informationUpdating 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 fileGenerating autoload files

简单使用

<?PHPclass 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);    }}

<?PHPrequire "./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] => 英雄联盟                                        )                                )                        )                )        ))

下面是官方的一些样例整合，

<?PHPrequire '../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;    }}

<?PHPrequire "./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的简单使用方法所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。