Thinkphp5使用Elasticsearch7.0（或以上）

Elastic 7.0以上的版本跟6.0的版本差距非常大&＃xff0c;主要是没有type了&＃xff0c;网上很多都是老版本的教程。导致我走了很多弯路。

一、使用composer安装Elasticsearch

composer require elasticsearch/elasticsearch


二、新建一个文件ElasticSearch.php

namespace app\common\library;use Elasticsearch\ClientBuilder;
use think\Config;
use think\Exception;/*** ES专用操作类*/
class ElasticSearch
{private $_host;private $_client &＃61; null;private $_index_prefix &＃61; &＃39;&＃39;;private $error &＃61; &＃39;&＃39;;public function __construct(){$this->setHost();$this->_client &＃61; ClientBuilder::create()->setHosts($this->_host)->build();$this->_index_prefix &＃61; \app\common\library\Help::getEnvDiffPrefix();}/*** 设置配置*/private function setHost(){//实例化一个客户端$cfg &＃61; Config::get(&＃39;eshosts&＃39;);$this->_host &＃61; [$cfg[0][&＃39;scheme&＃39;] . &＃39;://&＃39; . $cfg[0][&＃39;user&＃39;] . &＃39;:&＃39; . $cfg[0][&＃39;pass&＃39;] . &＃39;&＃64;&＃39; . $cfg[0][&＃39;host&＃39;] . &＃39;:&＃39; . $cfg[0][&＃39;port&＃39;]];}/*** 创建索引* &＃64;param string $index 文档名称* &＃64;param array $body 文档主体内容(数组)* &＃64;return mixed*/public function createIndex($index &＃61;&＃39;test&＃39;, $body&＃61;[]){$params &＃61; [&＃39;index&＃39; &＃61;> $this->_index_prefix . $index, //索引名称&＃39;body&＃39; &＃61;> [&＃39;settings&＃39; &＃61;> [ //配置&＃39;number_of_shards&＃39; &＃61;> 3, //主分片数&＃39;number_of_replicas&＃39; &＃61;> 1 //主分片的副本数],&＃39;mappings&＃39; &＃61;> [ //映射 &＃39;_source&＃39; &＃61;> [ // 存储原始文档&＃39;enabled&＃39; &＃61;> &＃39;true&＃39;],&＃39;properties&＃39; &＃61;> [ //配置数据结构与类型&＃39;title&＃39; &＃61;> [ //字段1&＃39;type&＃39; &＃61;> &＃39;text&＃39;, //类型 text、integer、float、double、boolean、date&＃39;index&＃39; &＃61;> &＃39;true&＃39;, //是否索引&＃39;analyzer&＃39; &＃61;> &＃39;ik_max_word&＃39; //使用中文IK分词器]]],]];$this->_client->indices()->create($params);}public function add_doc($index, $id, $body){$index &＃61; $this->_index_prefix . $index;try {$data &＃61; [&＃39;index&＃39; &＃61;> $index,&＃39;body&＃39; &＃61;> $body,&＃39;id&＃39; &＃61;> $id];$this->_client->index($data);} catch (Exception $e) {$this->error &＃61; $e->getMessage();return false;}return true;}/*** 更新索引* &＃64;param string $index 文档名称* &＃64;param string|int $id 文档ID* &＃64;param array $body 文档主体内容(数组)* &＃64;param string $type 文档类型(默认为doc)* &＃64;return bool*/public function updateIndex($index, $id, $body, $type &＃61; &＃39;doc&＃39;){$chk &＃61; $this->checkParams($index, $id, $body);if ($chk &＃61;&＃61;&＃61; false) {return false;}$index &＃61; $this->_index_prefix . $index;try {$data &＃61; [&＃39;index&＃39; &＃61;> $index,&＃39;type&＃39; &＃61;> $type,&＃39;id&＃39; &＃61;> $id,&＃39;body&＃39; &＃61;> [&＃39;doc&＃39; &＃61;> $body]];$this->_client->update($data);} catch (Exception $e) {$this->error &＃61; $e->getMessage();return false;}return true;}/*** 检测索引是否存在,只能单个索引名称检测* &＃64;param string $index 索引名称* &＃64;return bool*/public function indexExists($index){$response &＃61; $this->_client->indices()->exists([&＃39;index&＃39; &＃61;> $index]);return $response;}/*** 获取索引* &＃64;param string $index 文档名称* &＃64;param string|int $id 文档ID* &＃64;param string $type 文档类型(默认为doc)* &＃64;return mixed*/public function getIndex($index, $id, $type &＃61; &＃39;doc&＃39;){$index &＃61; $this->_index_prefix . $index;try {$params &＃61; [&＃39;index&＃39; &＃61;> $index,&＃39;type&＃39; &＃61;> $type,&＃39;id&＃39; &＃61;> $id];$response &＃61; $this->_client->get($params);return $response[&＃39;_source&＃39;];} catch (Exception $e) {$this->error &＃61; $e->getMessage();return false;}}/*** 获取索引文档数据列表* &＃64;param array $params 参数数组集合* &＃64;param string $type 文档类型(默认为doc)* &＃64;return mixed*/public function getList($index, $keywords, $limit &＃61; 10, $page &＃61; 1){$offset &＃61; ((int)$page - 1) * (int)$limit;$params &＃61; [&＃39;index&＃39; &＃61;> $this->_index_prefix . $index,&＃39;type&＃39; &＃61;> &＃39;_doc&＃39;, //这里注意&＃xff0c;一定是要_doc,不能是doc 踩了很久的坑&＃39;body&＃39; &＃61;> [&＃39;query&＃39; &＃61;> [&＃39;match&＃39; &＃61;> [&＃39;title&＃39; &＃61;> $keywords]],&＃39;sort&＃39; &＃61;> [[&＃39;id&＃39; &＃61;> [&＃39;order&＃39; &＃61;> &＃39;desc&＃39;]]],&＃39;from&＃39; &＃61;> $offset,&＃39;size&＃39; &＃61;> $limit]];$response &＃61; $this->_client->search($params);//$response[&＃39;hits&＃39;][&＃39;hits&＃39;]是具体的数据列表return $response;}/*** 删除文档(删除数据记录)* &＃64;param string $index 文档名称* &＃64;param string|int $id 文档ID* &＃64;param string $type 文档类型(默认为doc)* &＃64;return bool*/public function delDoc($index, $id, $type &＃61; &＃39;doc&＃39;){$chk &＃61; $this->checkParams($index, $id, [&＃39;def_key&＃39; &＃61;> &＃39;only_for_delete_doc&＃39;]); //参数3无实际意义,仅用过能通过验证而已if ($chk &＃61;&＃61;&＃61; false) {return false;}$index &＃61; $this->_index_prefix . $index;try {$data &＃61; [&＃39;index&＃39; &＃61;> $index,&＃39;type&＃39; &＃61;> $type,&＃39;id&＃39; &＃61;> $id];$this->_client->delete($data);} catch (Exception $e) {$this->error &＃61; $e->getMessage();return false;}return true;}/*** 删除索引(相当于删除表)* &＃64;param string $index 文档名称* &＃64;return bool*/public function delIndex($index){$chk &＃61; $this->checkParams($index, &＃39;10000&＃39;, [&＃39;def_key&＃39; &＃61;> &＃39;only_for_delete_doc&＃39;]); //参数2,3无实际意义,仅用过能通过验证而已if ($chk &＃61;&＃61;&＃61; false) {return false;}$index &＃61; $this->_index_prefix . $index;try {$data &＃61; [&＃39;index&＃39; &＃61;> $index];$this->_client->indices()->delete($data);} catch (Exception $e) {$this->error &＃61; $e->getMessage();return false;}return true;}/*** 获取ES操作实例*/public function getInstance(){if (!$this->_client) {$this->setHost();$this->_client &＃61; ClientBuilder::create()->setHosts($this->_host)->build();}return $this->_client;}/*** 获取索引前缀*/public function getIndexPrefix(){return $this->_index_prefix;}/*** 参数验证* &＃64;param string $index 索引文档的名称* &＃64;param string|int $id 索引文档的ID* &＃64;param array $body 主体内容* &＃64;return bool*/private function checkParams($index, $id, $body){// if (empty($index) || !is_string($index)) {// $this->error &＃61; &＃39;必须正确输入索引文档的名称&＃39;;// return false;// }// if (empty($id) || !is_string($id) || !is_numeric($id)) {// $this->error &＃61; &＃39;必须正确输入索引文档的ID&＃39;;// return false;// }// if (empty($body) || !is_array($body)) {// $this->error &＃61; &＃39;必须正确输入索引文档的主体内容&＃39;;// return false;// }$result &＃61; true;foreach ($body as $key &＃61;> $value) {if (!isset($key) || empty($key)) {$result &＃61; false;break;}}if ($result &＃61;&＃61;&＃61; false) {$this->error &＃61; &＃39;索引文档的主体内容输入不正确&＃39;;return false;}return true;}/***返回异常信息*/public function getError(){return $this->error;}
}

三、封号号ES类后&＃xff0c;新建一个Index.php文件测试

namespace app\api\controller;use app\common\library\ElasticSearch; //根据自己路径来引入/*** 测试接口*/
class Index
{protected $_es &＃61; null;public function __construct(){$this->_es &＃61; new ElasticSearch();}public function create(){$this->_es->createIndex(&＃39;test&＃39;);}public function add(){$id &＃61; 1;$data &＃61; [&＃39;id&＃39; &＃61;> $id,&＃39;title&＃39; &＃61;> &＃39;我爱天安门&＃39;,];$this->_es->add_doc(&＃39;test&＃39;, $id, $data);}public function search(){$data &＃61; $this->_es->getList(&＃39;test&＃39;, &＃39;天安门&＃39;);dump($data);}public function del(){$this->_es->delIndex(&＃39;test&＃39;);}
}


完成。