对于Elasticsearch与Elasticsearch-php的安装，网上有比较多的教程，这里不再累述。只是要注意Elasticsearch、Elasticsearch-php与php的版本。这里笔者使用的是Elasticsearch 5.6.8 windows版、php 5.6 、php onethink框架（以下简称ot）、Elasticsearch-php composer如下：（PHP Composer 视频教程）

{      "require":{          "elasticsearch/elasticsearch" : "~5.0"      }  }

一、连接Elasticsearch：

1、Elasticsearch开启之后，可以直接通过http://127.0.0.1:9200/查看基本信息。

2、将composer vendor下的文件复制到ot ThinkPHP\Library\Vendor\elasticsearch目录下。

3、连接Elasticsearch，

    public $es;    /**     * 初始化     */    public function _initialize()    {        Vendor('elasticsearch.autoload');        //host数组可配置多个节点        $params = array(            '127.0.0.1:9200'        );        $this->es = \Elasticsearch\ClientBuilder::create()->setHosts($params)->build();    }

其中build()方法会将ClientBuilder 对象转换为一个Client对象。

立即学习“PHP免费学习笔记（深入）”；

二、Elasticsearch-php使用：

1、创建index：

关于index与type，这里特别纠正一个说法，index 就像关系型数据库里的 database, type 就像 database 里的 table，这种理解是错误的。

    /**     * 创建索引     */    public function createIndex(){        $params = [            'index' => 'test', //索引名称            'body' => [                'settings'=> [ //配置                    'number_of_shards'=> 3,//主分片数                    'number_of_replicas'=> 1 //主分片的副本数                ],                'mappings'=> [  //映射                    '_default_' => [ //默认配置，每个类型缺省的配置使用默认配置                        '_all'=>[   //  关闭所有字段的检索                            'enabled' => 'false'                        ],                        '_source'=>[   //  存储原始文档                            'enabled' => 'true'                        ],                        'properties'=> [ //配置数据结构与类型                            'name'=> [ //字段1                                'type'=>'string',//类型 string、integer、float、double、boolean、date                                'index'=> 'analyzed',//索引是否精确值  analyzed not_analyzed                            ],                            'age'=> [ //字段2                                'type'=>'integer',                            ],                            'sex'=> [ //字段3                                'type'=>'string',                                'index'=> 'not_analyzed',                             ],                        ]                    ],                    'my_type' => [                         'properties' => [                            'phone'=> [                                 'type'=>'string',                            ],                                                    ]                    ],                ],            ]        ];        $res = $this->es->indices()->create($params);    }

在使用Elasticsearch-php API的时候，参数$params一般是用数组来，因为数组结构能很方便的转换为json。其中

_default_是默认配置，其他配置的缺省值都与_default_的相同。

_all设置true会将所有原始文档拼接在一起额外存储，

_source设置为true会存储原始文档，设置false一般用在只需要索引出文档的标题或者Url，通过Url去访问文档，而不需要在es中保存一份文档内容的场景。

最后，注意同一index下不同type中的同名称字段的数据类型与配置也必须相同！

2、删除index：

    /**     * 删除索引     */     public function deleteIndex(){        $params = [            'index' => 'test'        ];        $res = $this->es->indices()->ｄｅｌｅｔｅ($params);     }

3、查看Mappings：

    public function getMappings(){        $params = [            'index' => 'test'        ];        $res = $this->es->indices()->getMapping($params);    }

4、修改Mappings:

    public function putMappings(){        $params = [                       'index' => 'test',            'type' => 'my_type',            'body' => [                'my_type' => [                    'properties' => [                        'idcard' => [                            'type' => 'integer'                        ]                    ]                ]            ]        ];         $res = $this->es->indices()->putMapping($params);          }

注意:修改Mappings的API必须要指明type，且只能添加，不能修改已有的属性。

5、插入单条 Document：

    public function postSinDoc(){        $params = [            'index' => 'test',            'type' => 'my_type',            'body' => [                 'age' => 17,                'name' => 'saki',                'sex' => '女性',                'idcard' => 1112,                'phone' => '1245789',            ]        ];        $res = $this->es->index($params);    }

6、插入多条 Document：

    public function postBulkDoc(){        for($i = 0; $i < 5; $i++) {            $params[&#39;body&#39;][] = [                &#39;index&#39; => [                    &#39;_index&#39; => &#39;test&#39;,                    &#39;_type&#39; => &#39;my_type&#39;,                ]            ];            $params[&#39;body&#39;][] = [                &#39;age&#39; => 17+$i,                &#39;name&#39; => &#39;reimu&#39;.$i,                &#39;sex&#39; => &#39;女性&#39;,                &#39;idcard&#39; => 1112+$i,                &#39;phone&#39; => &#39;1245789&#39;.$i,            ];        }        $res = $this->es->bulk($params);    }

7、通过id获取Document:

    public function getDocById(){        $params = [            'index' => 'test',            'type' => 'my_type',            'id' => 'AWIDV5l2A907wJBVKu6k'        ];        $res = $this->es->get($params);    }

8、通过id更新Document:

    public function updateDocById(){        $params = [            'index' => 'test',            'type' => 'my_type',            'id' => 'AWIDV5l2A907wJBVKu6k',            'body' => [                'doc' => [ //将doc中的文档与现有文档合并                    'name' => 'marisa'                ]            ]        ];        $res = $this->es->ｕｐｄａｔｅ($params);    }

9、通过id删除Document：

    public function deleteDocById(){        $params = [            'index' => 'test',            'type' => 'my_type',            'id' => 'AWIDV5l2A907wJBVKu6k'        ];        $res = $this->es->ｄｅｌｅｔｅ($params);    }

注意：以上通过id的三个操作，如果未找到id，Elasticsearch-php会直接报错！

10、搜索Document：

    public function searchDoc(){        $params = [            'index' => 'test',            'type' => 'my_type',            'body' => [                'query' => [                    'constant_score' => [ //非评分模式执行                        'filter' => [ //过滤器，不会计算相关度，速度快                            'term' => [ //精确查找，不支持多个条件                                'name' => 'reimu0'                            ]                        ]                                            ]                ]            ]        ];        $res = $this->es->search($params);

这里只是搜索的一个示例。

相关推荐：

实例详解MySQL 与 Elasticsearch 数据不对称问题

Elasticsearch是什么？Elasticsearch 能够被用在什么地方？

Elasticsearch索引和文档操作实例教程