php sphinx 使用初探

   2023-02-09 学习力0
核心提示:  之前一直听说sphinx,感觉高深又神奇,可能是自己太小白了吧。。。。  前段时间组长在开发服务器上搭sphinx环境,一个同事研究写接口,我就搭着顺风车开心了一下~~~~  下面是写的一个简单的sphinx操作类库,此类库基于sphinxapi进行实现(小菜鸟一枚

  之前一直听说sphinx,感觉高深又神奇,可能是自己太小白了吧。。。。

  前段时间组长在开发服务器上搭sphinx环境,一个同事研究写接口,我就搭着顺风车开心了一下~~~~

  下面是写的一个简单的sphinx操作类库,此类库基于sphinxapi进行实现(小菜鸟一枚,请各大神指教)

class TestApi{
    protected static $sp;           // sphinx 客户端
    private static $conf;           // 配置

    /**
     * @param $serverIp  sphinx 服务器ip
     * @param $port sphinx 端口号
     */
    public function __construct($conf=null)
    {
        if (!is_object(self::$sp))
            self::$sp           = new \vendor\sphinx\SphinxClient();

        if (!$conf){
            return json_encode(['code'=>1,'msg'=>'请配置sphinx']);
        }
        self::$conf = $conf;

        self::setSp();      // 获取 sphinx 连接
    }

    /**
     * @return sphinx\SphinxClient
     */
    private static function setSp()
    {
        $conf = self::$conf;    // 获取配置

        // 建立连接
        self::$sp->SetServer($conf['serverIp'],$conf['port']);

        // 超时时间
        self::$sp->SetConnectTimeout($conf['timeOut']);

        // 最大请求时间
        self::$sp->SetMaxQueryTime($conf['maxQueryTime']);

        // 返回数据为数组?
        self::$sp->SetArrayResult($conf['arrayResult']);

        // 匹配模式
        self::$sp->SetMatchMode($conf['matchMode']);

        return self::$sp;

    }

    /**
     * 分组查询
     * @param string $attribute 属性
     * @param int $func 默认 SPH_GROUPBY_DAY,SPH_GROUPBY_WEEK,SPH_GROUPBY_MONTH,SPH_GROUPBY_YEAR,SPH_GROUPBY_ATTR,SPH_GROUPBY_ATTRPAIR
     * DAY,WEEK,MONTH,YEAR这个一般可以用于搜索最近一天,一周,一月或一年的记录。ATTR表示按照指定的属性值分组
     */
    public function groupBy($attribute, $func, $groupsort='@group desc ')
    {
        self::$sp->SetGroupBy($attribute, $func, $groupsort);
        return $this;
    }

    /**
     *  设置字段权重
     * @param array $weights 权重数组,可以按字段名称来设定权重
     */
    public function fieldWeights($weights)
    {
        self::$sp->SetFieldweights($weights);
        return $this;
    }

    /**
     *  设置过滤条件
     * @param string $attribute 属性名(相当于字段名)
     * @param array  $values 值
     * @param boolean $exclude 为true时,相当于$attribute!=$value
    */
    public function setFilter($attribute, $values, $exclude=false)
    {
        self::$sp->SetFilter($attribute, $values, $exclude);
        return $this;
    }

    /**
     * @description 排序模式
     * sortMode 排序方法名 SPH_SORT_RELEVANCE,SPH_SORT_ATTR_DESC,SPH_SORT_ATTR_ASC,SPH_SORT_TIME_SEGMENTS,SPH_SORT_EXTENDED
     * @param string $sortBy 排序字段
     *
     */
    public function sortBy( $sortBy='')
    {
        self::$sp->SetSortMode(self::$conf['sortMode'],$sortBy);
        return $this;
    }

    /**
     * 设置区分属性
     * @param string $distinct
     */
    public function distinct($distinct)
    {
        self::$sp->SetGroupDistinct ( $distinct );
        return $this;
    }

    /**
     * 设置结果集偏移量(分页)
     * @param int $offset   类似于mysql 中 offset
     * @param int $limit    类似于mysql 中 limit
     * @param int $max 搜索请求中返回的最大数据量(搜索全部,返回指定数量)
     * @param int $cutoff 控制查询的数量限制(设置为多少,则搜索数据量达到了,停止搜索)
     */
    public function limit($offset=0, $limit=10, $max=0, $cutoff=0)
    {
        self::$sp->SetLimits($offset, $limit, $max, $cutoff);
        return $this;
    }

    /**
     * 获取查询出的ID
     * @param string $query 查询关键字||查询表达式
     * @param string $index 索引
     * @param string $comment 注释
     * @return string
     */
    public function getID($query, $index='*', $comment='')
    {
        $res=self::$sp->Query($query, $index, $comment);

        $new_array = array();
        if(isset($res['matches'])&&count($res['matches'])>0){
            foreach ($res['matches'] as $key => $value) {
                $new_array[] = $value['id'];
            }
        }
        return $this->getReturn(0,$new_array,"请求成功");
    }

    /**
     *  返回数据封装
     */
    public function getReturn($code, $data, $msg)
    {
        return json_encode(['code'=>$code,"msg"=>$msg,'data'=>$data]);
    }
}

  使用方式:

            $api = new TestApi($conf);

            /**
             * 使用类库并获取主键id
             * 根据自己需要,进行链式调用操作
             */
            $result = $api->limit(0,100, 5)->getID($key,'mysql');
            if($result == "没有记录"){
                echo $result;
                exit(0);
            }

            $result_de = json_decode($result,true);
            $ids = implode(',',$result_de['data']);

            // 根据sphinx查出的主键id,查库检索出所有数据
            $sql = "select * from table where id in(" . $ids . ");";
            $mysql = new Mysql($conf_sql);
            $data = $mysql->findAll($sql);

            foreach($mysql->findAll($sql) as $v){
                unset($v['0'],$v['1'],$v['2']);
                $new_array[] = $v;
            }
       // 返回数据
return json_encode($new_array);

 

 
反对 0举报 0 评论 0
 

免责声明:本文仅代表作者个人观点,与乐学笔记(本网)无关。其原创性以及文中陈述文字和内容未经本站证实,对本文以及其中全部或者部分内容、文字的真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
    本网站有部分内容均转载自其它媒体,转载目的在于传递更多信息,并不代表本网赞同其观点和对其真实性负责,若因作品内容、知识产权、版权和其他问题,请及时提供相关证明等材料并与我们留言联系,本网站将在规定时间内给予删除等相关处理.

  • php-fpm进程管理的三种模式 phpfpm子进程
    php-fpm进程管理的三种模式 phpfpm子进程
    php-fpm解读-进程管理的三种模式—程序媛大丽标明转载以示尊重 感谢原作者的分享。php-fpm进程管理一共有三种模式:ondemand、static、dynamic,我们可以在同一个fpm的master配置三种模式,看下图1。php-fpm的工作模式和nginx类似,都是一个master,多个worke
    03-08
  • nginx和php-fpm 是使用 tcp socket 还是 unix s
    tcp socket允许通过网络进程之间的通信,也可以通过loopback进行本地进程之间通信。unix socket允许在本地运行的进程之间进行通信。分析从上面的图片可以看,unix socket减少了不必要的tcp开销,而tcp需要经过loopback,还要申请临时端口和tcp相关资源。但是
    03-08
  • [PHP8] 我参加了PHP8工程师认证初学者考试beta考试
    [PHP8] 我参加了PHP8工程师认证初学者考试beta
    前几天,2022/08/05,PHP工程师认证机构PHP8 技术员认证初级考试宣布实施考试将于 2023 年春季开始。和 beta 测试完成于 2022/09/11所以我收到了。一般社团法人BOSS-CON JAPAN(代表理事:Tadashi Yoshimasa,地点:东京都世田谷区,以下简称“BOSS-CON JAPAN
    03-08
  • 将 PHP Insights 放入旧版 PJ 不是很好吗?谈论
    将 PHP Insights 放入旧版 PJ 不是很好吗?谈论
    介绍在最近的PHP系统开发中,感觉故事在理所当然包含静态分析工具的前提下进行。我的周围现有代码很脏,我很久以前安装了工具,但几乎没有检查已经观察到许多这样的案例。 (这是小说。而不是像 0 或 100 这样不允许单行错误的静态分析,一点一点,逐渐我想介
    03-08
  • PHP基于elasticsearch全文搜索引擎的开发 php使
    1.概述:全文搜索属于最常见的需求,开源的 Elasticsearch (以下简称 Elastic)是目前全文搜索引擎的首选。Elastic 的底层是开源库 Lucene。但是,你没法直接用 Lucene,必须自己写代码去调用它的接口。Elastic 是 Lucene 的封装,提供了 REST API 的操作接
    02-09
  • php视图操作
    一、视图的基本介绍         视图是虚拟的表。与包含数据的表不一样,视图只包含使用时动态检索数据的查询。        使用视图需要MySQL5及以后的版本支持。        下面是视图的一些常见应用:        重用SQL语句;        简化复杂的S
    02-09
  • php中图像处理的常用函数 php图形图像处理技术
    php中图像处理的常用函数 php图形图像处理技术
    1.imagecreate()函数imagecreate()函数是基于一个调色板的画布。?php $im = imagecreate(200,80);                //创建一个宽200,高80的画布。$white = imagecolorallocate($im,225,35,180);     //设置画布的背景颜色imagegif($im);
    02-09
  • PHP安全之webshell和后门检测
    PHP安全之webshell和后门检测
    基于PHP的应用面临着各种各样的攻击:XSS:对PHP的Web应用而言,跨站脚本是一个易受攻击的点。攻击者可以利用它盗取用户信息。你可以配置Apache,或是写更安全的PHP代码(验证所有用户输入)来防范XSS攻击SQL注入:这是PHP应用中,数据库层的易受攻击点。防范
    02-09
  • php使用时间戳保存时间的意义 PHP获取时间戳
    时间戳记录的是格林尼治时间,使用date格式化的时候会根据你程序设置的不同时区显示不同的时间。如果使用具体时间,则还需要进行多一步转换。
    02-09
  • PHP 获取提交表单数据方法
    PHP $_GET 和 $_POST变量是用来获取表单中的信息的,比如用户输入的信息。PHP表单操作在我们处理HTML表单和PHP表单时,我们要记住的重要一点是:HTML页面中的任何一个表单元素都可以自动的用于PHP脚本:表单举例: htmlbodyform action="welcome.php" method
    02-09
点击排行