ThinkPHP如何集成Elasticsearch搜索_自定义搜索驱动开发-ThinkPHP-PHP中文网

ThinkPHP 6 的 Elasticsearch 驱动不能直接用 think-elastic，因其依赖过时的 Elasticsearch\Client v5.x，而 TP6 要求 elasticsearch/elasticsearch v8.x，存在命名空间、方法签名及返回结构的全面断层，导致 Class not found 或参数错误。

thinkphp如何集成elasticsearch搜索_自定义搜索驱动开发

ThinkPHP 6 的 Elasticsearch 驱动为什么不能直接用 `think-elastic`

因为 think-elastic 是 TP5 时代的产物，底层依赖 Elasticsearch\Client v5.x，而 TP6 默认使用 PHP 7.4+、Elasticsearch 7.x/8.x，官方客户端已升级为 elasticsearch/elasticsearch v8.x（命名空间、方法签名、返回结构全变了）。直接安装旧包会报 Class 'Elasticsearch\Client' not found 或 ArgumentCountError —— 这不是配置问题，是协议和 SDK 断层。

如何手动注册自定义搜索驱动（以 TP6.1+ 为例）

TP6 的搜索能力由 think\facade\Search 提供，但它本身不绑定具体引擎，靠 think\contract\SearchInterface 实现解耦。你需要自己写一个实现类，并在 app/provider.php 中注册：

1. 创建驱动类 app/search/ElasticsearchDriver.php：

namespace app\search;

use think\contract\SearchInterface;
use Elasticsearch\ClientBuilder;

class ElasticsearchDriver implements SearchInterface
{
    protected $client;

    public function __construct(array $config = [])
    {
        $this->client = ClientBuilder::create()
            ->setHosts($config['hosts'] ?? ['http://127.0.0.1:9200'])
            ->setBasicAuthentication($config['username'] ?? '', $config['password'] ?? '')
            ->build();
    }

    public function search(string $index, array $params): array
    {
        try {
            $result = $this->client->search(['index' => $index, 'body' => $params]);
            return [
                'total' => $result['hits']['total']['value'] ?? 0,
                'list'  => $result['hits']['hits'] ?? [],
                'took'  => $result['took'] ?? 0,
            ];
        } catch (\Exception $e) {
            throw new \think\Exception('ES search failed: ' . $e->getMessage());
        }
    }

    public function index(string $index, array $data, string $id = null): bool
    {
        $params = ['index' => $index, 'body' => $data];
        if ($id) $params['id'] = $id;
        try {
            $this->client->index($params);
            return true;
        } catch (\Exception $e) {
            return false;
        }
    }
}

2. 在 app/provider.php 中注册：

return [
    // ...
    \think\facade\Search::class => \app\search\ElasticsearchDriver::class,
];

3. 配置 config/search.php：

return [
    'default' => 'elasticsearch',
    'drivers' => [
        'elasticsearch' => [
            'hosts'     => ['http://127.0.0.1:9200'],
            'username'  => '',
            'password'  => '',
        ],
    ],
];

`search()` 方法传参必须适配 ES 7+/8+ 的 DSL 结构

TP 自带的 where()、limit() 不会自动转成 ES 查询语法，你得自己拼 body。常见错误是照搬 MySQL 写法，比如：

错：用 ['title' => 'PHP'] 当作 $params → ES 会报 "Unknown key for a VALUE"
对：必须用完整 DSL，如 ['query' => ['match' => ['title' => 'PHP']]]
分页注意：from/size 替代 limit，sort 必须是数组形式：['created_at' => ['order' => 'desc']]
高亮要显式开启：'highlight' => ['fields' => ['title' => new \stdClass()]]，否则返回里没有 highlight 字段

ES 8.x 的兼容要点：禁用 type、启用 API key 认证

ES 8 默认禁用 _type，所以 index() 方法里不能传 type 参数；同时推荐用 API key 替代 Basic Auth（更安全）：

初始化 client 时改用：->setApiKey($config['api_key'] ?? '')
删除所有含 'type' => '_doc' 的参数，ES 8 已废弃
建索引前先检查 mapping：$this->client->indices()->create(['index' => $index, 'body' => $mapping])，否则中文分词可能失效
如果用 IK 分词器，确保 config/elasticsearch.yml 加了 discovery.type: single-node（开发环境），否则启动失败

ES 和 TP 之间没银弹，DSL 结构、版本差异、错误处理粒度——这些地方一松手就进日志排查半天。别指望封装一层就完全屏蔽复杂性。