zoukankan      html  css  js  c++  java
  • PHP中使用Elasticsearch

    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);
  • 相关阅读:
    系统维护相关问题
    Python环境维护
    哈希表解决字符串问题
    论文笔记二:《A Tutoral on Spectral Clustering》
    论文笔记之哈希学习比较--《Supervised Hashing with Kernels》《Towards Optimal Binary Code Learning via Ordinal Embedding》《Top Rank Supervised Binary Coding for Visual Search》
    Java中String、StringBuffer、StringBuilder的比较与源 代码分析
    浙大pat1040 Longest Symmetric String(25 分)
    浙大pat1039 Course List for Student(25 分)
    浙大pat---1036 Boys vs Girls (25)
    百炼oj-4151:电影节
  • 原文地址:https://www.cnblogs.com/yszr/p/10283220.html
Copyright © 2011-2022 走看看