• 之前写这个博客源码的时候,只会最简单的php和mysql的组合,当时给这个博客做的搜索是用的like语句,随着自学的知识越来越多,学习笔记也越来越多,用mysql的模糊查询搜索出来的结果不尽如人意
  • 现在用elasticsearch做右上角搜索功能,体验比之前mysql强很多,毕竟全文检索不是mysql的强项,也算是做了花了2天时间,总结一下内容

elasticsearch选择

接触elasticsearch时间不长,第一个接触的版本是6.6.0,这次做搜索引擎用的是6.7.0,主要考虑这个版本距离6.6.0最近,还有一个考虑6.7.0的kibana有中文界面,万一以后做日志分析就算提前熟悉了,搜索的内容是中文,配合中文分词的插件,参考之前部署的文档

elasticsearch-PHP

一切比较赶时间,虽然知道底层是用http操作es,但至少还是得找工具去操作es,连官方的文档中都提到了用composter去下载工具,可能是国外的原因,没装上,网上找的其他人的工具,至少可以用,有时间再改进一下

解压后直接放到tp5的vendor目录下

676372-20180402223813573-1454144023.png

操作部分,结合curl的格式

<?php
namespace app\index\controller;
use think\Controller;
class Ec extends Controller
{
    public function _initialize()
    {

        Vendor('Elasticsearch.autoload');
        $params['hosts'] = array(
            '192.168.9.155:9200'
        );
        $this->client = new \Elasticsearch\Client($params);
    }
    public function index(){
        $this->search();
    }

    //创建索引
    //现在我们开始添加一个新的索引和一些自定义设置：
    public function create_index()
    {
        $indexParams['index'] = 'myindex';                         //索引名称  
        $indexParams['type'] = 'mytype';                          //类型名称  
        $indexParams['body']['settings']['number_of_shards'] = 1;   //当前只有一台ES，1就可以了
        $indexParams['body']['settings']['number_of_replicas'] = 0; //副本0，因为只有一台ES
        $this->client->create($indexParams);
    }
    //插入索引数据
    public function add_document()
    {
        $params = array();
        $params['body'] = array(
            'product_name' => '要插入的商品名称'，
            'prodcut_id' => 5
        );
        $params['index'] = 'myindex';  //索引名称 
        $params['type'] = 'mytype';   //类型名称  
        $params['id'] = '12345678';     //不指定id，系统会自动生成唯一id  
        $ret = $this->client->index($params);
    }
    //删除索引
    //由于 elasticsearch 的动态性质，我们添加第一个文档的时候自动创建了索引和一些默认设置。让我们删除这个索引，因为我们以后想要指定自己的设置：
    public function delete_index()
    {
        $deleteParams['index'] = 'myindex';
        $this->client->indices()->delete($deleteParams);
    }
    //删除文档
    public function delete_document()
    {
        $deleteParams = array();
        $deleteParams['index'] = 'myindex';
        $deleteParams['type'] = 'mytype';
        $deleteParams['id'] = '123';
        $retDelete = $this->client->delete($deleteParams);
    }
    //更改文档
    public function update_document()
    {
        $updateParams = array();
        $updateParams['index'] = 'myindex';
        $updateParams['type'] = 'mytype';
        $updateParams['id'] = 'my_id';
        $updateParams['body']['doc']['product_name']  = '新商品名';
       $response = $this->client->update($updateParams);

    }
    //查询
    public function search()
    {
        $searchParams['index'] = 'myindex';
        $searchParams['type'] = 'mytype';
        $searchParams['from'] = 0;
        $searchParams['size'] = 100;
        $searchParams['sort'] = array(
            '_score' => array(
                'order' => 'id'
            )
        );
        //相当于sql语句：  select * from hp_product where prodcut_name like '茶'  limit 0,100 order by id desc; 
        $searchParams['body']['query']['match']['product_name'] = '茶';
        $retDoc = $this->client->search($searchParams);

        echo '<pre>';
        print_r($retDoc);
        //相当于sql语句： select * from hp_product where product_name like '茶'  and product_id = 20 limit 200,10;  
        // $searchParams['body']['query']['bool']['must'] = array(  
        //     array('match' => array('product_name' => '茶')),  
        //     array('match' => array('product_id' => 20))  
        //    );  
        // $searchParams['size'] = 10;  
        // $searchParams['from'] = 200;  
        // 
        //  
        // 当于sql语句：select * from hp_product where product_name like '茶' or product_id = 20 limit 200,10; 
        // $searchParams['body']['query']['bool']['should'] = array(  
        //        array('match' => array('product_name' => '茶')),  
        //        array('match' => array('product_id' => 20))  
        //      );  
        //$searchParams['size'] = 10;  
        //$searchParams['from'] = 200; 
        //
        //
        // 当于sql语句： select * from hp_product where product_name like '茶' and product_id != 20 limit 200,10; 
        // $searchParams['body']['query']['bool']['must_not'] = array(  
        //        array('match' => array('product_name' => '茶')),  
        //        array('match' => array('product_id' => 20))  
        //      );  
        //$searchParams['size'] = 10;  
        //$searchParams['from'] = 200; 
        //
        //
        //当于sql语句：select * from hp_product where id>=20 and id<30  limit 200,10; 
        // $searchParams['body']['query']['range'] = array(  
        //        'id' => array('gte' => 20,'lt' => 30);  
        //      );  
        //$searchParams['size'] = 10;  
        //$searchParams['from'] = 200; 
    }
    //获取文档
    public function get_document()
    {
        $getParams = array();
        $getParams['index'] = 'myindex';
        $getParams['type'] = 'mytype';
        $getParams['id'] = '12344';
        $retDoc = $this->client->get($getParams);
        print_r($retDoc);
    }
}
?>

tp5分页问题

之前使用mysql做分页,用的也是tp5自带的分页,现在用es做搜索引擎,还是避不开分页的问题,研究分页可能要花点时间,为了能尽快用上,只是用es做全文搜索获得文章的主键,再通过所有的主键从mysql获取内容,这样不需要修改太多的内容至少搜索性能也能比之前提升.es提供的搜索内容根据匹配度进行排序,从mysql获取数据使用的是in语句,默认会根据主键升序排列,所以需要保持es提供的顺序

#MySQL按照in语句的顺序返回结果
SELECT * FROM EVENT WHERE eventId IN(443,419,431,440,420,414,509) ORDER BY INSTR(',443,419,431,440,420,414,509,',CONCAT(',',eventId,','))

#Oracle按照in语句的顺序返回结果
select name from order where oderid in（111,222,333,444,555,666）order by instr('111,222,333,444,555,666',orderid)