PHP Elasticsearch의 간단한 사용에 대한 간략한 토론
- 青灯夜游앞으로
- 2021-03-04 18:06:263078검색
이 글에서는 PHP에서 Elasticsearch를 사용하는 간단한 방법을 소개합니다. 도움이 필요한 친구들이 모두 참고할 수 있기를 바랍니다.
추천 학습: "PHP 비디오 튜토리얼"
PHP에서 Elasticsearch를 사용
composer require elasticsearch/elasticsearch
하면 적절한 버전이 자동으로 로드됩니다! 내 PHP는 5.6이며 자동으로 5.3 Elasticsearch 버전을 로드합니다!
Using version ^5.3 for elasticsearch/elasticsearch ./composer.json has been updated Loading composer repositories with package information Updating dependencies (including require-dev) Package operations: 4 installs, 0 updates, 0 removals - Installing react/promise (v2.7.0): Downloading (100%) - Installing guzzlehttp/streams (3.0.0): Downloading (100%) - Installing guzzlehttp/ringphp (1.1.0): Downloading (100%) - Installing elasticsearch/elasticsearch (v5.3.2): Downloading (100%) Writing lock file Generating autoload files
사용이 간편함
<?php
class MyElasticSearch
{
private $es;
// 构造函数
public function __construct()
{
include('../vendor/autoload.php');
$params = array(
'127.0.0.1:9200'
);
$this->es = \Elasticsearch\ClientBuilder::create()->setHosts($params)->build();
}
public function search() {
$params = [
'index' => 'megacorp',
'type' => 'employee',
'body' => [
'query' => [
'constant_score' => [ //非评分模式执行
'filter' => [ //过滤器，不会计算相关度，速度快
'term' => [ //精确查找，不支持多个条件
'about' => '谭'
]
]
]
]
]
];
$res = $this->es->search($params);
print_r($res);
}
}
<?php require "./MyElasticSearch.php"; $es = new MyElasticSearch(); $es->search();
실행 결과
Array ( [took] => 2 [timed_out] => [_shards] => Array ( [total] => 5 [successful] => 5 [skipped] => 0 [failed] => 0 ) [hits] => Array ( [total] => 1 [max_score] => 1 [hits] => Array ( [0] => Array ( [_index] => megacorp [_type] => employee [_id] => 3 [_score] => 1 [_source] => Array ( [first_name] => 李 [last_name] => 四 [age] => 24 [about] => 一个PHP程序员，热爱编程，谭康很帅，充满激情。 [interests] => Array ( [0] => 英雄联盟 ) ) ) ) ) )
다음은 공식 샘플 통합입니다.
<?php
require '../vendor/autoload.php';
use Elasticsearch\ClientBuilder;
class MyElasticSearch
{
private $client;
// 构造函数
public function __construct()
{
$params = array(
'127.0.0.1:9200'
);
$this->client = ClientBuilder::create()->setHosts($params)->build();
}
// 创建索引
public function create_index($index_name = 'test_ik') { // 只能创建一次
$params = [
'index' => $index_name,
'body' => [
'settings' => [
'number_of_shards' => 5,
'number_of_replicas' => 0
]
]
];
try {
return $this->client->indices()->create($params);
} catch (Elasticsearch\Common\Exceptions\BadRequest400Exception $e) {
$msg = $e->getMessage();
$msg = json_decode($msg,true);
return $msg;
}
}
// 删除索引
public function delete_index($index_name = 'test_ik') {
$params = ['index' => $index_name];
$response = $this->client->indices()->delete($params);
return $response;
}
// 创建文档模板
public function create_mappings($type_name = 'goods',$index_name = 'test_ik') {
$params = [
'index' => $index_name,
'type' => $type_name,
'body' => [
$type_name => [
'_source' => [
'enabled' => true
],
'properties' => [
'id' => [
'type' => 'integer', // 整型
'index' => 'not_analyzed',
],
'title' => [
'type' => 'string', // 字符串型
'index' => 'analyzed', // 全文搜索
'analyzer' => 'ik_max_word'
],
'content' => [
'type' => 'string',
'index' => 'analyzed',
'analyzer' => 'ik_max_word'
],
'price' => [
'type' => 'integer'
]
]
]
]
];
$response = $this->client->indices()->putMapping($params);
return $response;
}
// 查看映射
public function get_mapping($type_name = 'goods',$index_name = 'test_ik') {
$params = [
'index' => $index_name,
'type' => $type_name
];
$response = $this->client->indices()->getMapping($params);
return $response;
}
// 添加文档
public function add_doc($id,$doc,$index_name = 'test_ik',$type_name = 'goods') {
$params = [
'index' => $index_name,
'type' => $type_name,
'id' => $id,
'body' => $doc
];
$response = $this->client->index($params);
return $response;
}
// 判断文档存在
public function exists_doc($id = 1,$index_name = 'test_ik',$type_name = 'goods') {
$params = [
'index' => $index_name,
'type' => $type_name,
'id' => $id
];
$response = $this->client->exists($params);
return $response;
}
// 获取文档
public function get_doc($id = 1,$index_name = 'test_ik',$type_name = 'goods') {
$params = [
'index' => $index_name,
'type' => $type_name,
'id' => $id
];
$response = $this->client->get($params);
return $response;
}
// 更新文档
public function update_doc($id = 1,$index_name = 'test_ik',$type_name = 'goods') {
// 可以灵活添加新字段,最好不要乱添加
$params = [
'index' => $index_name,
'type' => $type_name,
'id' => $id,
'body' => [
'doc' => [
'title' => '苹果手机iPhoneX'
]
]
];
$response = $this->client->update($params);
return $response;
}
// 删除文档
public function delete_doc($id = 1,$index_name = 'test_ik',$type_name = 'goods') {
$params = [
'index' => $index_name,
'type' => $type_name,
'id' => $id
];
$response = $this->client->delete($params);
return $response;
}
// 查询文档 (分页，排序，权重，过滤)
public function search_doc($keywords = "电脑",$index_name = "test_ik",$type_name = "goods",$from = 0,$size = 2) {
$params = [
'index' => $index_name,
'type' => $type_name,
'body' => [
'query' => [
'bool' => [
'should' => [
[ 'match' => [ 'title' => [
'query' => $keywords,
'boost' => 3, // 权重大
]]],
[ 'match' => [ 'content' => [
'query' => $keywords,
'boost' => 2,
]]],
],
],
],
'sort' => ['price'=>['order'=>'desc']]
, 'from' => $from, 'size' => $size
]
];
$results = $this->client->search($params);
// $maxScore = $results['hits']['max_score'];
// $score = $results['hits']['hits'][0]['_score'];
// $doc = $results['hits']['hits'][0]['_source'];
return $results;
}
}
<?php
require "./MyElasticSearch.php";
$es = new MyElasticSearch();
$r = $es->delete_index();
$r = $es->create_index();
$r = $es->create_mappings();
$r = $es->get_mapping();
print_r($r);
$docs = [];
$docs[] = ['id'=>1,'title'=>'苹果手机','content'=>'苹果手机，很好很强大。','price'=>1000];
$docs[] = ['id'=>2,'title'=>'华为手环','content'=>'荣耀手环，你值得拥有。','price'=>300];
$docs[] = ['id'=>3,'title'=>'小度音响','content'=>'智能生活，快乐每一天。','price'=>100];
$docs[] = ['id'=>4,'title'=>'王者荣耀','content'=>'游戏就玩王者荣耀，快乐生活，很好很强大。','price'=>998];
$docs[] = ['id'=>5,'title'=>'小汪糕点','content'=>'糕点就吃小汪，好吃看得见。','price'=>98];
$docs[] = ['id'=>6,'title'=>'小米手环3','content'=>'秒杀限量，快来。','price'=>998];
$docs[] = ['id'=>7,'title'=>'iPad','content'=>'iPad，不一样的电脑。','price'=>2998];
$docs[] = ['id'=>8,'title'=>'中华人民共和国','content'=>'中华人民共和国，伟大的国家。','price'=>19999];
foreach ($docs as $k => $v) {
$r = $es->add_doc($v['id'],$v);
print_r($r);
}
$r = $es->get_doc();
$r = $es->update_doc();
$r = $es->delete_doc();
$r = $es->exists_doc();
$r = $es->search_doc("手环 电脑");
$r = $es->search_doc("玩");
$r = $es->search_doc("中华");
print_r($r);
더 많은 프로그래밍 관련 지식을 보려면 프로그래밍 비디오를 방문하세요! !
위 내용은 PHP Elasticsearch의 간단한 사용에 대한 간략한 토론의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
성명：
이 기사는 cnblogs.com에서 복제됩니다. 침해가 있는 경우 admin@php.cn으로 문의하시기 바랍니다. 삭제