ThinkPHP6接入ElasticSearch

You konw.For Search.

安装

1.安装ThinkPHP6框架

ThinkPHP6官方文档

$ composer create-project topthink/think es

2.引入elasticSearch扩展包

elasticsearch扩展包地址

$ composer require elasticsearch/elasticsearch

开发

1.封装操作方法

注意:查找和删除指定id文档时,若此id无对应文档,将会抛出异常

url请求时的参数在该扩展包中使用方法一致,把json格式转换成对应的数组格式即可

创建model文件app\model\ElasticSearch.php

<?php

namespace app\model;

use Elasticsearch\ClientBuilder;
use think\Exception;

class ElasticSearch
{
    //es实例
    protected $client;

    public function __construct()
    {
        $params = array(
            '127.0.0.1:9200'
        );
        $this->client = ClientBuilder::create()->setHosts($params)->build();
    }

    /**
     * 创建索引
     * @param $index
     * @return array
     */
    public function createIndex(string $index, array $body)
    {
        /*$body = [
            'settings' => [
                'number_of_shards' => 5,
                'number_of_replicas' => 0
            ],
            'mappings' => [
                'properties' => [
                    'username' => [
                        'type' => 'text'
                    ]
                ]
            ]
        ];*/
        $params = [
            'index' => $index,
            'body' => $body
        ];

        try {
            $res = $this->client->indices()->create($params);
        }catch (\Exception $e){
            $res = false;
        }

        return $res;
    }

    /**
     * 删除索引
     * @param $index
     * @return array
     */
    public function deleteIndex(string $index)
    {
        $params = [
            'index' => $index
        ];

        try {
            $res = $this->client->indices()->delete($params);
        }catch (\Exception $e){
            $res = false;
        }

        return $res;
    }

    /**
     * 创建文档
     * @param string $index
     * @param string $id
     * @param array $body
     * @return array|callable
     */
    public function createDocument(string $index, string $id, array $body)
    {
        $params = [
            'index' => $index,
            'id' => $id,
            'body' => $body
        ];

        try {
            $res = $this->client->index($params);
        }catch (\Exception $e){
            $res = false;
        }

        return $res;
    }

    /**
     * 获取文档
     * @param $index
     * @param $id
     * @return array|callable
     */
    public function getDocument(string $index, string $id)
    {
        $params = [
            'index' => $index,
            'id' => $id
        ];

        try {
            $res = $this->client->get($params);
        }catch (\Exception $e){
            $res = false;
        }

        return $res;
    }

    /**
     * 查找文档
     * @param string $index
     * @param array $match
     * @return array|callable
     */
    public function searchDocument(string $index, array $body)
    {
        /*$body = [
            'query' => [
                'match' => [
                    'name'  =>  '测试'
                ]
            ]
        ];*/
        $params = [
            'index' => $index,
            'body' => $body
        ];

        try {
            $res = $this->client->search($params);
        }catch (\Exception $e){
            $res = false;
        }

        return $res;
    }

    /**
     * 删除文档
     * @param string $index
     * @param string $id
     * @return array|callable
     */
    public function deleteDocument(string $index, string $id)
    {
        $params = [
            'index' => $index,
            'id' => $id
        ];

        try {
            $res = $this->client->delete($params);
        }catch (\Exception $e){
            $res = false;
        }

        return $res;
    }
}

2.调用方法

修改控制器文件app\controller\Index.php

<?php
namespace app\controller;

use app\BaseController;

class Index extends BaseController
{
    public function index()
    {

        $elasticSearch = new \app\model\ElasticSearch();

        $index = 'php_test_index2';
        //1.创建索引
        //body中参数众多,还需多多研究
//        $createIndexBody = [
//            'settings' => [
//                'number_of_shards' => 5,
//                'number_of_replicas' => 0
//            ],
//            'mappings' => [
//                'properties' => [
//                    'username' => ['type' => 'text'],
//                    'nickname' => ['type' => 'text'],
//                    'mobile' => ['type' => 'text'],
//                    'money' => ['type' => 'double'],
//                    'score' => ['type' => 'double'],
//                ]
//            ]
//        ];
//        $res = $elasticSearch->createIndex($index, $createIndexBody);

        //2.删除索引
//        $res = $elasticSearch->deleteIndex($index);

        //3.添加文档
//        $id = 1;
//        $createDocumentBody = [
//            'username' => 'test1',
//            'nickname' => 'test1',
//            'mobile' => '17539592164',
//            'money' => 9999,
//            'score' => 6666,
//        ];
//        $id = 2;
//        $createDocumentBody = [
//            'username' => 'test2',
//            'nickname' => 'test2',
//            'mobile' => '17539592165',
//            'money' => 8888,
//            'score' => 7777,
//        ];
//        $res = $elasticSearch->createDocument($index, $id, $createDocumentBody);

        //4.获取文档
//        $id = 1;
//        $id = 333;
//        $res = $elasticSearch->getDocument($index, $id);

        //5.查找文档
        //body中参数众多,还需多多研究
//        $searchDocumentBody = [
//            'from'  =>  0,
//            'size'  =>  10,
//            'query' => [
//                'prefix' => [
//                    'username'  =>  'test'
//                ]
//            ]
//        ];
//        $res = $elasticSearch->searchDocument($index, $searchDocumentBody);

        //6.删除文档
        $res = $elasticSearch->deleteDocument($index, 333);

        var_dump($res);die;
    }
}

• 本文作者： 小蜗牛
• 本文链接： https://vitaminvi.github.io/2020/07/23/ThinkPHP6接入ElasticSearch/
• 版权声明： 本博客所有文章除特别声明外，均采用 MIT 许可协议。转载请注明出处！