hyperf/elasticsearch 主要為 elasticsearch-php 進行了使用者端物件建立的工廠類封裝，elasticsearch-php 預設使用 Guzzle Ring 使用者端，在 hyperf/guzzle 中我們實現了協程版本的 Handler，所以可以直接使用 Hyperf\Elasticsearch\ClientBuilderFactory 建立一個新的 Builder。
composer require hyperf/elasticsearch
class ElasticsearchService
{
protected $container;
protected Client $es_client;
public function _initialize(): void
{
$this->container = ApplicationContext::getContainer();
$client_builder = $this->container->get(ClientBuilderFactory::class);
$builder = $client_builder->create();
$host = [
'https://賬號:密碼@地址:9200'
];
$this->es_client = $builder->setHosts($host)->build();
}
}
這裡的賬號密碼指的是建立 elasticsearch 的時候的賬號密碼。如果是用阿里雲或者騰訊雲服務，建立好了之後一樣會有
這裡只是建立了協程使用者端，裡面的實際方法是要自己重新定義的
1 安裝 es 服務，也可以是騰訊雲或者阿里雲，騰訊雲阿里雲也只是提供 es 服務而已，並不是能直接看到資料。資料還是要在 kibana 裡面檢視。
2 建立協程使用者端
3 建立 index。index 相當於 mysql 裡面的庫
4 建立 mapping mapping 可以理解成表。要儲存資料要先定義好表。
5 index 方法推播單條資料。bulk 批次推播資料
6 search 搜尋資料。
備註：
以下全網最全了
https://blog.csdn.net/qq_41911898/article/details/110089644 可以在這裡檢視每個方法的資料格式。
https://blog.csdn.net/qq_18361349/article/details/106369551 參考
<?php
namespace App\Service\Common;
use App\Service\Service;
use Elasticsearch\Client;
use Hyperf\Elasticsearch\ClientBuilderFactory;
use Hyperf\Utils\ApplicationContext;
/**
*
*/
class ElasticsearchService extends Service
{
/**
* @var
*/
protected $container;
/**
* @var Client
*/
protected Client $es_client;
public function _initialize(): void
{
$this->container = ApplicationContext::getContainer();
$client_builder = $this->container->get(ClientBuilderFactory::class);
$builder = $client_builder->create();
$host = [
'https://賬號:密碼@地址:9200'
];
$this->es_client = $builder->setHosts($host)->build();
}
/**
* 建立index - 相當於MySQL的資料庫
* @param string $index
* @return array
*/
public function createIndex(string $index): array
{
$params = [
'index' => $index,
];
return $this->es_client->indices()->create($params);
}
/**
* 設定mapping
* @param $params
* @return array
*/
public function putMapping($params): array
{
return $this->es_client->indices()->putMapping($params);
}
/**
* 獲取mapping
* @param $params
* @return array
*/
public function getMapping($params): array
{
return $this->es_client->indices()->getMapping($params);
}
/**
* 判斷索引是否存在
* @param string $index
* @return bool
*/
public function indexExistsEs(string $index): bool
{
$params = [
'index' => $index,
];
return $this->es_client->indices()->exists($params);
}
/**
* 刪除索引
* @param string $index
* @return array|callable
*/
public function deleteIndex(string $index): callable|array
{
$params = [
'index' => $index
];
return $this->es_client->indices()->delete($params);
}
/**
* 建立檔案
* @param array $params
* @return array|callable
*/
public function indexEs(array $params): callable|array
{
$index_data = [
'index' => $params['index'],
'body' => $params['body'],
];
return $this->es_client->index($index_data);
}
/**
* 批次建立檔案
* @param array $params
* @return callable|array
*/
public function bulk(array $params): callable|array
{
return $this->es_client->bulk($params);
}
/**
* 更新檔案
* @param array $params
* $params = [
* 'index' => 'chat_data',
* 'id' => '檔案id',
* 'doc' => [
* '欄位名1' => '要修改的值',
* '欄位名2' => '要修改的值',
* '欄位名3' => '要修改的值',
* ]
* ]
* @return array|callable
*/
public function update(array $params): callable|array
{
$params = [
'index' => $params['index'],
'id' => $params['id'],
'body' => [
'doc' => $params['doc']
]
];
return $this->es_client->update($params);
}
/**
* 刪除檔案
* @param $params
* @return array|callable
*/
public function deleteEs($params): callable|array
{
extract($params);
$delete_data = [
'index' => $index,
'type' => $type,
'id' => $id,
];
return $this->es_client->delete($delete_data);
}
/**
* es搜尋資料
* @param array $params
* @param int $page
* @param int $size
* @return array|callable
*/
public function search(array $params, int $page = 1, int $size = 15): callable|array
{
$search = $params['search'];
$params = [
'index' => $params['index'],
'from' => ($page <= 0) ? 0 : $page - 1,
'size' => $size
];
// 只有一個搜尋欄位時
if (count($search) == 1) {
$query = [
'match_phrase' => $search
];
} else {
$must = [];
foreach ($search as $k => $v) {
// 一定要把時間篩選弄出來，因為這裡的條件類似where('xxxx','xxxx')
if(!in_array($k,['start_time','end_time'])) {
$must[] = ['match' => [$k => $v]];
}
}
$query['bool']['must'] = $must;
// 時間搜尋
if(!empty($search['start_time'])) {
$filter = [
'range' => [
'start_time' =>[
'gte' => $search['start_time'],
'lte' => $search['end_time']
]
]
];
$query['bool']['filter'] = $filter;
}
}
$params['body'] = [
'query' => $query,
];
return $this->es_client->search($params);
}
}