<?php
// 确保Elasticsearch PHP客户端已经安装并可用
if (!class_exists('Elasticsearch\\Client')) {
throw new Exception('Elasticsearch PHP客户端未安装。请运行"composer require elasticsearch/elasticsearch"来安装。');
}
// 创建Elasticsearch客户端实例
$client = new Elasticsearch\Client([
'hosts' => [$_SERVER['ELASTICSEARCH_HOST']],
]);
// 创建Magento的搜索助手类
class Mageflow_Elasticsearch_Helper_Data extends Mage_Core_Helper_Abstract
{
// 使用Elasticsearch客户端进行搜索
public function search($query)
{
$results = $client->search([
'index' => 'magento_products',
'type' => 'product',
'body' => [
'query' => [
'multi_match' => [
'query' => $query,
'fields' => ['name^3', 'description']
]
]
]
]);
return $results;
}
}
// 使用搜索助手类进行搜索
$helper = Mage::helper('mageflow_elasticsearch');
$results = $helper->search('搜索词');
// 处理搜索结果
foreach ($results['hits']['hits'] as $hit) {
// 显示搜索结果
echo $hit['_source']['name'] . ' - ' . $hit['_source']['price'] . ' 元' . PHP_EOL;
}这个代码示例展示了如何在Magento环境中集成Elasticsearch PHP客户端，并使用它来执行搜索查询。代码首先检查Elasticsearch PHP客户端是否可用，然后创建客户端实例。接着，创建了一个Magento的搜索助手类，该类使用Elasticsearch客户端执行搜索操作。最后，演示了如何调用搜索方法并处理返回的结果。