php mysql 一个查询优化的简单例子

 更新时间:2016年11月25日 16:23  点击:1838
PHP+Mysql是一个最经常使用的黄金搭档,它们俩配合使用,能够发挥出最佳性能,当然,如果配合Apache使用,就更加Perfect了。

因此,需要做好对mysql的查询优化。下面通过一个简单的例子,展现不同的SQL语句对于查询速度的影响:

存在这样的一张表test,它有一个自增的id作为主索引。现在要查询id号处于某一个范围内的记录,可以使用如下SQL语句:

 代码如下 复制代码
SELECT *
FROM `test`
order by id asc
limit 208888,50

这条SQL语句的意思是从id号为208888的记录开始向后取50条记录。在一个30万条记录的数据库中测试,在主索引都已经建立好的情况下,执行这条语句的时间为40~50秒。

那么有没有更快SQL语句来执行呢?显然是有的。看看下面这条SQL语句:

 代码如下 复制代码
SELECT *
FROM `test`
WHERE id
BETWEEN 208838
AND 208888

这条语句使用了一个条件进行过滤,在实际中测试的执行时间约为0.06秒。

究其原因,是因为虽然id属性上已经有索引了,但是排序仍然是一个非常高代价的操作,要慎用。而第二个语句,就可以让MySql充分利用数据库中已经建立好的B+树索引,所以查找起来速度相当快,是原来的几百倍。

由此可见,网站开发者在使用SQL语句的时候,一定要小心谨慎,因为一个疏忽大意的SQL语句,可能使得你的网站访问速度急剧下降,后台数据库面临巨大压力,并且很快陷入无法打开页面的窘境

表格展示无限级分类(PHP版)有需要的参考一下。

表格展示无限级分类(PHP版)
  TreeTable是一个能把无限分类展现为表格形式的PHP类库插件,分类的层级表示为表格的列,分类的行数表格分类的总数。单元格显示分类名称。

TreeTable通过对单元格的行合并和列合并实现了无限层级也能较好的展示层级架构。

 

1.构建ID/PID/NAME的数组,后期可通过数据库生成的动态数据。Tree算法请点击

 代码如下 复制代码
?array(
    *      1 => array('id'=>'1','parentid'=>0,'name'=>'一级栏目一'),
    *      2 => array('id'=>'2','parentid'=>0,'name'=>'一级栏目二'),
    *      3 => array('id'=>'3','parentid'=>1,'name'=>'二级栏目一'),
    *      4 => array('id'=>'4','parentid'=>1,'name'=>'二级栏目二'),
    *      5 => array('id'=>'5','parentid'=>2,'name'=>'二级栏目三'),
    *      6 => array('id'=>'6','parentid'=>3,'name'=>'三级栏目一'),
    *      7 => array('id'=>'7','parentid'=>3,'name'=>'三级栏目二')
    *      )
 

2. 导入TreeTable类库。

 代码如下 复制代码

import('@.ORG.Util.TableTree'); //Thinkphp导入方法3. 生成TreeTable HTML代码

$treeTable->init($treearr);
echo $treeTable->get_treetable();

注意:get_treetable()只生产表体部门,<TALBE></TABLE>请自行构建。

 

完整代码

 代码如下 复制代码


<?php
/**
 * File name: TreeTable.class.php
 * Author: run.gao 312854458@qq.com  Date: 2012-07-24 23:22 GMT+8
 * Description: 通用的表格无限级分类
 * */

/**
 * 表格展示无限分类是将无线分类已表格的形式表现出来,更好的能体现出分类的所属关系
 * 使用方法:
 * 1. 实例化分类
 * $treeTable = new TreeTable();
 * 2. 初始化分类,$treearr必须是一个多维数组且包含 id,parentid,name字段
 * $treeTable->init($treearr);
 * 3. 获取无限分类HTML代码
 * echo $treeTable->get_treetable();
 * */

class TreeTable {
    /**
    * 生成树型结构所需要的2维数组
    * @var array
    */
    public $arr = array();

    /**
     * 表格列数
     * @var int
     */
    public $columns = 0;

    /**
     * 表格行数
     * @var int
     */
    public $rows  = 0;
   
    /**
    * 初始化TreeTable数据
    * @param array 2维数组
    * array(
    *      1 => array('id'=>'1','parentid'=>0,'name'=>'一级栏目一'),
    *      2 => array('id'=>'2','parentid'=>0,'name'=>'一级栏目二'),
    *      3 => array('id'=>'3','parentid'=>1,'name'=>'二级栏目一'),
    *      4 => array('id'=>'4','parentid'=>1,'name'=>'二级栏目二'),
    *      5 => array('id'=>'5','parentid'=>2,'name'=>'二级栏目三'),
    *      6 => array('id'=>'6','parentid'=>3,'name'=>'三级栏目一'),
    *      7 => array('id'=>'7','parentid'=>3,'name'=>'三级栏目二')
    *      )
    */
    public function init($arr=array()){
        if(!is_array($arr)) return false;
       
        foreach ($arr as $k=>$v) {
            $this->arr[$v['id']] = $v;
        }
       
        foreach ($this->arr as $k => $v){
            $this->arr[$k]['column']           = $this->get_level($v['id']); // Y轴位置
            $this->arr[$k]['arrchildid']       = $this->get_arrchildid($v['id']); // 所有子节点
            $this->arr[$k]['arrparentid']      = $this->get_arrparentid($v['id']); // 所有父节点
            $this->arr[$k]['child_bottom_num'] = $this->get_child_count($v['id']); // 所有底层元素节点
        }
       
          $this->columns = $this->get_columns(); // 总行数
        $this->rows    = $this->get_rows(); // 总列数
       
           // 按照arrparentid和id号进行排序
        $this->sort_arr();
       
        foreach ($this->arr as $k => $v){
            $this->arr[$k]['row']     = $this->get_row_location($v['id']);    // X轴位置
            $this->arr[$k]['rowspan'] = $v['child_bottom_num']; // 行合并数   
            $this->arr[$k]['colspan'] = $v['child_bottom_num'] == 0 ? $this->columns - $v['column'] + 1 : 0; //列合并数
        }
       
        return $this->get_tree_arr();
    }
   
    /**
     * 获取数组
     * */
    public function get_tree_arr(){
        return is_array($this->arr) ? $this->arr : false;
    }
   
    /**
     * 按arrparentid/id号依次重新排序数组
     * */
    public function sort_arr(){
       
        // 要进行排序的字段
        foreach ($this->arr as $k => $v){
            $order_pid_arr[$k] = $v['arrparentid'];
            $order_iscost[] = $v['sort'];
            $order_id_arr[$k] = $v['id'];   
        }
       
        // 先根据arrparentid排序,再根据排序,id号排序
        array_multisort(
        $order_pid_arr, SORT_ASC, SORT_STRING,
        $order_iscost, SORT_DESC, SORT_NUMERIC,
        $order_id_arr, SORT_ASC, SORT_NUMERIC,
        $this->arr);
       
        // 获取每一个节点层次
           for ($column = 1; $column <= $this->columns; $column++) {
               $row_level = 0;
               foreach ($this->arr as $key => $node){
                   if ($node['column'] == $column){
                       $row_level++;
                       $this->arr[$key]['column_level']  = $row_level;
                   }
               }
           }
          
           // 重新计算以ID作为键名
        foreach ($this->arr as $k=>$v) {
            $arr[$v['id']] = $v;
        }
       
        $this->arr = $arr;
    }
   
    /**
    * 得到父级数组
    * @param int
    * @return array
    */
    public function get_parent($myid){
        $newarr = array();
        if(!isset($this->arr[$myid])) return false;
        $pid = $this->arr[$myid]['parentid'];
        $pid = $this->arr[$pid]['parentid'];
        if(is_array($this->arr)){
            foreach($this->arr as $id => $a){
                if($a['parentid'] == $pid) $newarr[$id] = $a;
            }
        }
        return $newarr;
    }

    /**
    * 得到子级数组
    * @param int
    * @return array
    */
    public function get_child($myid){
        $a = $newarr = array();
        if(is_array($this->arr)){
            foreach($this->arr as $id => $a){
                if($a['parentid'] == $myid) $newarr[$id] = $a;
            }
        }
        return $newarr ? $newarr : false;
    }
       
    /**
     * 获取当前节点所在的层级
     * @param $myid 当前节点ID号
     * */
    public function get_level($myid, $init = true){
        static $level = 1;
        if($init) $level = 1;
        if ($this->arr[$myid]['parentid']) {
            $level++;
            $this->get_level($this->arr[$myid]['parentid'], false);
        }
        return $level;
    }
   
    /**
     * 获取当前节点所有底层节点(没有子节点的节点)的数量
     * @param $myid 节点ID号
     * @param $init 第一次加载将情况static变量
     * */
    public function get_child_count($myid, $init = true){
        static $count = 0;
        if($init) $count = 0;
        if(!$this->get_child($myid) && $init) return 0;
        if($childarr = $this->get_child($myid)){
            foreach ($childarr as $v){
                $this->get_child_count($v['id'], false);
            }
        }else{
            $count++;
        }
        return $count;
    }
   
    /**
     * 获取节点所有子节点ID号
     * @param $catid 节点ID号
     * @param $init 第一次加载将情况static初始化
     * */
    public function get_arrchildid($myid, $init = true) {
        static $childid;
        if($init) $childid = '';
        if(!is_array($this->arr)) return false;
        foreach($this->arr as $id => $a){
            if($a['parentid'] == $myid) {
                $childid = $childid ? $childid.','.$a['id'] : $a['id'];
                $this->get_arrchildid($a['id'], false);
            }
        }
        return $childid ;
    }
   
    /**
     * 获取该节点所有父节点ID号
     * @param $id 节点ID号
     * */
    public function get_arrparentid($id, $arrparentid = '') {
        if(!is_array($this->arr)) return false;
        $parentid = $this->arr[$id]['parentid'];
        if($parentid > 0) $arrparentid = $arrparentid ? $parentid.','.$arrparentid : $parentid;
        if($parentid) $arrparentid = $this->get_arrparentid($parentid, $arrparentid);
        return $arrparentid;
    }
   
    /**
     * 获取节点所在地行定位
     * @param $myid 节点ID号
     */
    public function get_row_location($myid){
           $nodearr = $this->arr;
           // 获取每一个节点所在行的位置
          foreach ($nodearr as $key => $node){
              if($myid == $node['id']) {
                  $node_row_count = 0;
                $arrparentid = explode(',', $node['arrparentid']);
                // 所有父节点小于当前节点层次的底层节点等于0的元素
                foreach ($arrparentid as $pid){
                    foreach ($nodearr as $node_row){
                        if($node_row['column'] == $nodearr[$pid]['column'] && $nodearr[$pid]['column_level'] > $node_row['column_level'] && $node_row['child_bottom_num'] == 0){
                            $node_row_count ++;
                        }
                    }   
                }
                // 所有当前节点并且节点层次(rowid_level)小于当前节点层次的个数
                foreach ($nodearr as $node_row){
                    if($node['column'] == $node_row['column'] && $node_row['column_level'] <  $node['column_level']){
                        $node_row_count += $node_row['child_bottom_num'] ? $node_row['child_bottom_num'] : 1;
                    }
                }
                $node_row_count++;
                break;
            }
        }
        return $node_row_count;   
    }
   
    /**
     * 获取表格的行数
     * */
    public function get_rows(){
        $row = 0;
        foreach ($this->arr as $key => $node){
            if($node['child_bottom_num'] == 0){
                $rows++; // 总行数
            }
        }
        return $rows;
    }
   
    /**
     * 获取表格的列数
     * */
    public function get_columns(){
        $columns = 0 ;
        foreach ($this->arr as $key => $node){
            if($node['column'] > $columns){
                $columns = $node['column']; // 总列数
            }
        }
        return $columns;
    }
   
    /**
     * 获取分类的表格展现形式(不包含表头)
     * */
    public function get_treetable(){
        $table_string = '';
        for($row = 1; $row <= $this->rows; $row++){
            $table_string .= "rt<tr>";
            foreach ($this->arr as $v){
                if($v['row'] == $row){
                    $rowspan = $v['rowspan'] ? "rowspan='{$v['rowspan']}'" : '';
                    $colspan = $v['colspan'] ? "colspan='{$v['colspan']}'" : '';
                    $table_string .= "rtt<td {$rowspan} {$colspan}>
                    {$v['name']}
                    </td>";
                }
            }
            $table_string .= "rt</tr>";
        }
        return $table_string;
    }
}
?>

一般情况下我们出现大量数据传输理希望减少服务器的带宽压力,会采取一种方式来压缩文件传输,php中用zlib也可以实现gzip压缩输出,下面我们来看GZIP压缩输出各种方法总结.

GZIP(GNU-ZIP)是一种压缩技术。经过GZIP压缩后页面大小可以变为原来的30%甚至更小。这样用户浏览的时候就会感觉很爽很愉快!

准备工作

1、找不到php_zlib.dll文件?

自php4.3开始zlib压缩就已经内置在php中了,所以至少Windows环境下是不需要安装zlib的。

2、安装搭建php运行环境

  由于光通过php.ini配置文件开启gzip配置实现php gzip压缩输出是不行的的,其需要apache的支持,所以建议安装搭建php+apache+mysql运行环境。

php gzip配置步骤

一、打开php.ini配置文件,找到zlib.output_compression = Off,将


 zlib.output_compression = Off
;zlib.output_compression_level = -1

修改为

zlib.output_compression = On
zlib.output_compression_level = 6

 

实例1

PHP使用zlib扩展实现页面GZIP压缩输出

代码

 代码如下 复制代码

function ob_gzip($content) // $content 就是要压缩的页面内容

{

if(!headers_sent() && extension_loaded("zlib") && strstr($_SERVER["HTTP_ACCEPT_ENCODING"],"gzip"))//判断页面头部信息是否输出,PHP中zlib扩展是否已经加载,浏览器是否支持GZIP技术
{
$content = gzencode($content." n//此页已压缩",9); //为准备压缩的内容贴上“//此页已压缩”的注释标签,然后用zlib提供的gzencode()函数执行级别为9的压缩,这个参数值范围是0-9,0表示无压缩,9表示最大压缩,当然压缩程度越高越费CPU。
//用header()函数给浏览器发送一些头部信息,告诉浏览器这个页面已经用GZIP压缩过了!
header(“Content-Encoding: gzip”);
header(“Vary: Accept-Encoding”);
header(“Content-Length: “.strlen($content));
}
return $content; //返回压缩的内容

函数写好后,就用ob_start调用它,于是原来的ob_start()变成

ob_start('ob_gzip'); //给ob_start()加一个参数,参数名就是刚才的函数名。这样当内容进入缓冲区后PHP就会调用ob_gzip函数把它压缩了。

最后结束缓冲区

ob_end_flush(); //结束缓冲区,输出内容。当然,不用这个函数也行,因为程序执行到最后会自动将缓冲区内容输出。

最终完整的实例

 代码如下 复制代码

<?php
//调用一个函数名为ob_gzip的内容进行压缩
ob_start('ob_gzip');
//输出内容
ob_end_flush();
//这是ob_gzip函数

function ob_gzip($content)
{
if(!headers_sent()&&extension_loaded("zlib")
&&strstr($_SERVER["HTTP_ACCEPT_ENCODING"],"gzip"))
{
$content = gzencode($content." n//此页已压缩",9);
header("Content-Encoding: gzip");
header("Vary: Accept-Encoding");
header("Content-Length: ".strlen($content));
}
return $content;
}
?>

实例2

zlib压缩和解压缩swf文件的代码

文件的例子:

 代码如下 复制代码
//没有加入判断swf文件是否已经压缩,入需要可以根据文件的第一个字节是'F'或者'C'来判断
压缩swf文件:
//--------------------------------------------------------------------------------------------------
//文件名
$filename = "test.swf";
//打开文件
$rs = fopen($filename,"r");
//读取文件的数据
$str = fread($rs,filesize($filename));
//设置swf头文件
$head = substr($str,1,8);
$head = "C".$head;
//获取swf文件内容
$body = substr($str,8);
//压缩文件内容,使用最高压缩级别9
$body = gzcompress($body, 9);
//合并文件头和内容
$str = $head.$body;
//关闭读取的文件流
fclose($rs);
//创建一个新的文件
$ws = fopen("create.swf","w");
//写文件
fwrite($ws,$str);
//关闭文件留
fclose($ws);
//----------------------------------------------------------------------------------------------------
?>
解压缩swf文件:
//----------------------------------------------------------------------------------------------------
//文件名
$filename = "test.swf";
//打开文件
$rs = fopen($filename,"r");
//读取文件的数据
$str = fread($rs,filesize($filename));
//设置swf头文件
$head = substr($str,1,8);
$head = "F".$head;
//获取swf文件内容
$body = substr($str,8);
//解压缩文件内容
$body = gzuncompress($body);
//合并文件头和内容
$str = $head.$body;
//关闭读取的文件流
fclose($rs);
//创建一个新的文件
$ws = fopen("create.swf","w");
//写文件
fwrite($ws,$str);
//关闭文件留
fclose($ws);
//----------------------------------------------------------------------------------------------------
?>

实例3

开启php zlib(gzip)压缩输出


php gzip配置知识点:

1、默认php是不开启zlib整站压缩输出的,而是通过对需要压缩输出的页面使用ob_gzhandler函数实现,两者只能二选一,否则会报错。

2、zlib.output_compression默认值为Off,你可以将其设置为On,或者output buffer size(默认为4k)

3、zlib.output_compression_level代表压缩比,默认推荐设置压缩比值为6,可选范围为1-9,-1代表关闭php zlib(gzip)压缩

二、保存php.ini配置文件,并重启apache服务器

三、打开apache 配置文件httpd.conf,配置装载deflate_module

这一步是最关键的开启php gzip压缩输出配置步骤,很多网友会说我已经开启了php.ini配置文件中的php gzip配置怎么还是没有实现php gzip压缩,就是因为没有让apache装载deflate_module,方法如下,将

 代码如下 复制代码
#LoadModule deflate_module modules/mod_deflate.so

去除开头的#号,并重启apache即可。

有些信息比方经常不变的,但是还是能变的信息放在缓存中以加快显示速度,这是很有价值的,所谓的缓存,通俗的理解就是一些保存在服务器端的共用信息.它是于服务器同生死的,我们在保存缓存的时候可以指定下次更新的时间的判断,比方要在5分钟更新一次

数据缓存:这里所说的数据缓存是指数据库查询PHP缓存机制,每次访问页面的时候,都会先检测相应的缓存数据是否存在,如果不存在,就连接数据库,得到数据,并把查询结果序列化后保存到文件中,以后同样的查询结果就直接从缓存表或文件中获得。

用的最广的例子看Discuz的搜索功能,把结果ID缓存到一个表中,下次搜索相同关键字时先搜索缓存表。

举个常用的方法,多表关联的时候,把附表中的内容生成数组保存到主表的一个字段中,需要的时候数组分解一下,这样的好处是只读一个表,坏处就是两个数据同步会多不少步骤,数据库永远是瓶颈,用硬盘换速度,是这个的关键点。

页面缓存:

每次访问页面的时候,都会先检测相应的缓存页面文件是否存在,如果不存在,就连接数据库,得到数据,显示页面并同时生成缓存页面文件,这样下次访问的时候页面文件就发挥作用了。(模板引擎和网上常见的一些PHP缓存机制类通常有此功能)

时间触发缓存:

检查文件是否存在并且时间戳小于设置的过期时间,如果文件修改的时间戳比当前时间戳减去过期时间戳大,那么就用缓存,否则更新缓存。

内容触发缓存:

当插入数据或更新数据时,强制更新PHP缓存机制。

静态缓存:

这里所说的静态缓存是指静态化,直接生成HTML或XML等文本文件,有更新的时候重生成一次,适合于不太变化的页面,这就不说了。

以上内容是代码级的解决方案,我直接CP别的框架,也懒得改,内容都差不多,很容易就做到,而且会几种方式一起用,但下面的内容是服务器端的缓存方案,非代码级的,要有多方的合作才能做到

内存缓存:

Memcached是高性能的,分布式的内存对象PHP缓存机制系统,用于在动态应用中减少数据库负载,提升访问速度。

php的缓冲器:

有eaccelerator, apc, phpa,xcache,这个这个就不说了吧,搜索一堆一堆的,自己看啦,知道有这玩意就OK

MYSQL缓存:

这也算非代码级的,经典的数据库就是用的这种方式,看下面的运行时间,0.09xxx之类的
我贴段根据蓝色那家伙修改后部分my.ini吧,2G的MYISAM表可以在0.05S左右,据说他前后改了有快一年

基于反向代理的Web缓存:

如Nginx,SQUID,mod_proxy(apache2以上又分为mod_proxy和mod_cache)
NGINX的例子

用google找到一些 php缓存技术方法

发个PHP缓存实现,实现了apc和文件缓存,继承Cache_Abstract即可实现调用第三方的缓存工具。
参考shindig的缓存类和apc。

Php代码

 代码如下 复制代码
<?php  
class CacheException extends Exception {}  
/** 
 * 缓存抽象类 
 */  
abstract class Cache_Abstract {  
    /** 
     * 读缓存变量 
     * 
     * @param string $key 缓存下标 
     * @return mixed 
     */  
    abstract public function fetch($key);  
      
    /** 
     * 缓存变量 
     * 
     * @param string $key 缓存变量下标 
     * @param string $value 缓存变量的值 
     * @return bool 
     */  
    abstract public function store($key, $value);  
      
    /** 
     * 删除缓存变量 
     * 
     * @param string $key 缓存下标 
     * @return Cache_Abstract 
     */  
    abstract public function delete($key);  
      
    /** 
     * 清(删)除所有缓存 
     * 
     * @return Cache_Abstract 
     */  
    abstract public function clear();  
      
    /** 
     * 锁定缓存变量 
     * 
     * @param string $key 缓存下标 
     * @return Cache_Abstract 
     */  
    abstract public function lock($key);  
  
    /** 
     * 缓存变量解锁 
     * 
     * @param string $key 缓存下标 
     * @return Cache_Abstract 
     */  
    abstract public function unlock($key);  
  
    /** 
     * 取得缓存变量是否被锁定 
     * 
     * @param string $key 缓存下标 
     * @return bool 
     */  
    abstract public function isLocked($key);  
  
    /** 
     * 确保不是锁定状态 
     * 最多做$tries次睡眠等待解锁,超时则跳过并解锁 
     * 
     * @param string $key 缓存下标 
     */  
    public function checkLock($key) {  
        if (!$this->isLocked($key)) {  
            return $this;  
        }  
          
        $tries = 10;  
        $count = 0;  
        do {  
            usleep(200);  
            $count ++;  
        } while ($count <= $tries && $this->isLocked($key));  // 最多做十次睡眠等待解锁,超时则跳过并解锁  
  
        $this->isLocked($key) && $this->unlock($key);  
          
        return $this;  
    }  
}  
  
  
/** 
 * APC扩展缓存实现 
 *  
 *  
 * @category   Mjie 
 * @package    Cache 
 * @author     流水孟春 
 * @copyright  Copyright (c) 2008- <cmpan(at)qq.com> 
 * @license    New BSD License 
 * @version    $Id: Cache/Apc.php 版本号 2010-04-18 23:02 cmpan $ 
 */  
class Cache_Apc extends Cache_Abstract {  
      
    protected $_prefix = 'cache.mjie.net';  
      
    public function __construct() {  
        if (!function_exists('apc_cache_info')) {  
            throw new CacheException('apc extension didn't installed');  
        }  
    }  
      
    /** 
     * 保存缓存变量 
     * 
     * @param string $key 
     * @param mixed $value 
     * @return bool 
     */  
    public function store($key, $value) {  
        return apc_store($this->_storageKey($key), $value);  
    }  
      
    /** 
     * 读取缓存 
     * 
     * @param string $key 
     * @return mixed 
     */  
    public function fetch($key) {  
        return apc_fetch($this->_storageKey($key));  
    }  
      
    /** 
     * 清除缓存 
     * 
     * @return Cache_Apc 
     */  
    public function clear() {  
        apc_clear_cache();  
        return $this;  
    }  
      
    /** 
     * 删除缓存单元 
     * 
     * @return Cache_Apc 
     */  
    public function delete($key) {  
        apc_delete($this->_storageKey($key));  
        return $this;  
    }  
      
    /** 
     * 缓存单元是否被锁定 
     * 
     * @param string $key 
     * @return bool 
     */  
    public function isLocked($key) {  
        if ((apc_fetch($this->_storageKey($key) . '.lock')) === false) {  
            return false;  
        }  
          
        return true;  
    }  
      
    /** 
     * 锁定缓存单元 
     * 
     * @param string $key 
     * @return Cache_Apc 
     */  
    public function lock($key) {  
        apc_store($this->_storageKey($key) . '.lock', '', 5);  
        return $this;  
    }  
      
    /** 
     * 缓存单元解锁 
     * 
     * @param string $key 
     * @return Cache_Apc 
     */  
    public function unlock($key) {  
        apc_delete($this->_storageKey($key) . '.lock');  
        return $this;  
    }  
      
    /** 
     * 完整缓存名 
     * 
     * @param string $key 
     * @return string 
     */  
    private function _storageKey($key) {  
        return $this->_prefix . '_' . $key;  
    }  
}  
  
/** 
 * 文件缓存实现 
 *  
 *  
 * @category   Mjie 
 * @package    Cache 
 * @author     流水孟春 
 * @copyright  Copyright (c) 2008- <cmpan(at)qq.com> 
 * @license    New BSD License 
 * @version    $Id: Cache/File.php 版本号 2010-04-18 16:46 cmpan $ 
 */  
class Cache_File extends Cache_Abstract {  
    public $useSubdir     = false;  
      
    protected $_cachesDir = 'cache';  
      
    public function __construct() {  
        if (defined('DATA_DIR')) {  
            $this->_setCacheDir(DATA_DIR . '/cache');  
        }  
    }  
      
    /** 
     * 获取缓存文件 
     * 
     * @param string $key 
     * @return string 
     */  
    protected function _getCacheFile($key) {  
        $subdir = $this->useSubdir ? substr($key, 0, 2) . '/' : '';  
        return $this->_cachesDir . '/' . $subdir . $key . '.php';  
    }  
  
    /** 
     * 读取缓存变量 
     * 为防止信息泄露,缓存文件格式为php文件,并以"<?php exit;?>"开头 
     *  
     * @param string $key 缓存下标 
     * @return mixed 
     */  
    public function fetch($key) {  
        $cacheFile = self::_getCacheFile($key);  
        if (file_exists($cacheFile) && is_readable($cacheFile)) {  
            // include 方式  
            //return include $cacheFile;  
            // 系列化方式  
  
            return unserialize(@file_get_contents($cacheFile, false, NULL, 13));  
        }  
  
        return false;  
    }  
  
    /** 
     * 缓存变量 
     * 为防止信息泄露,缓存文件格式为php文件,并以"<?php exit;?>"开头 
     * 
     * @param string $key 缓存变量下标 
     * @param string $value 缓存变量的值 
     * @return bool 
     */  
    public function store($key, $value) {  
        $cacheFile = self::_getCacheFile($key);  
        $cacheDir  = dirname($cacheFile);  
  
        if(!is_dir($cacheDir)) {  
            if(!@mkdir($cacheDir, 0755, true)) {  
                throw new CacheException("Could not make cache directory");  
            }  
        }  
    // 用include方式  
        //return @file_put_contents($cacheFile, '<?php return ' . var_export($value, true). ';');  
  
        return @file_put_contents($cacheFile, '<?php exit;?>' . serialize($value));  
    }  
  
    /** 
     * 删除缓存变量 
     * 
     * @param string $key 缓存下标 
     * @return Cache_File 
     */  
    public function delete($key) {  
        if(emptyempty($key)) {  
            throw new CacheException("Missing argument 1 for Cache_File::delete()");  
        }  
          
        $cacheFile = self::_getCacheFile($key);  
        if(!@unlink($cacheFile)) {  
            throw new CacheException("Cache file could not be deleted");  
        }  
  
        return $this;  
    }  
  
    /** 
     * 缓存单元是否已经锁定 
     * 
     * @param string $key 
     * @return bool 
     */  
    public function isLocked($key) {  
        $cacheFile = self::_getCacheFile($key);  
        clearstatcache();  
        return file_exists($cacheFile . '.lock');  
    }  
  
    /** 
     * 锁定 
     * 
     * @param string $key 
     * @return Cache_File 
     */  
    public function lock($key) {  
        $cacheFile = self::_getCacheFile($key);  
        $cacheDir  = dirname($cacheFile);  
        if(!is_dir($cacheDir)) {  
            if(!@mkdir($cacheDir, 0755, true)) {  
                if(!is_dir($cacheDir)) {  
                    throw new CacheException("Could not make cache directory");  
                }  
            }  
        }  
  
        // 设定缓存锁文件的访问和修改时间  
        @touch($cacheFile . '.lock');  
        return $this;  
    }  
    
    /** 
     * 解锁 
     * 
     * @param string $key 
     * @return Cache_File 
     */  
    public function unlock($key) {  
        $cacheFile = self::_getCacheFile($key);  
        @unlink($cacheFile . '.lock');  
        return 
本文章详细的介绍了关于PHP中实现异步调用多线程方法,下面我们以给1000个用户发送一封推荐邮件,用户输入或者导入邮件账号了提交服务器执行发送来讲述。

比如现在有一个场景,给1000个用户发送一封推荐邮件,用户输入或者导入邮件账号了提交服务器执行发送。

 代码如下 复制代码

<?php

$sqlserver/42852.htm target=_blank >count=count($emailarr);

for($i=0;$i<$count;$i )

{

  sendmail(.....);//发送邮件

}

?>

这段代码用户体验极差,也无法实际运用,首先发送这么多邮件会产生服务器运行超时,其实漫长的用户等待时间会让用户对系统产品怀疑和失去信心。但是用户不需要等待到1000封邮件都发送完毕了才提交发送成功,我们完全可以提交后台后直接给用户提示发送成功,然后让后台程序静默依次发送。

这个时候我们就需要“异步执行”技术来执行代码,异步执行的特点是后台静默执行,用户无需等待代码的执行结果,使用异步执行的好处:

1.摆脱了应用程序对单个任务的依赖性

2.提高了程序的执行效率

3.提高了程序的扩展性

4.在一定场景提高了用户体验

5.因为PHP不支持多线程,使用异步调用的请求多个HTTP的方式达到了程序并行执行效果,但是注意的是请求的HTTP过多的话,会大大加大了系统的开销


用户体验:用户等待->发送完毕
朋友们就会问,怎么缺少发信环节?
OK,发信环节就在用户提交请求的时候,把发信任务转给了一个单独处理发信的php程序处理了,当用户看见“发送完毕”的时候其实信还没发送完,这个时候,发信程序正在后台努力的工作着,一封一封的向外发送

sendmail.php

 代码如下 复制代码

<?php
$domain="www.***.com";
$url="/system_mail.php";
$par="email=".implode(',',$emailarr)."&........";
$header = "POST $url HTTP/1.0rn";
$header .= "Content-Type: application/x-www-form-urlencodedrn";
$header .= "Content-Length: " . strlen($par) . "rnrn";
$fp = @fsockopen ($domain, 80, $errno, $errstr, 30);
fputs ($fp, $header . $par);
fclose($fp);

echo ''发送完毕';
?>
system_mail.php
<?php
ini_set("ignore_user_abort",true);
ignore_user_abort(true);//此处的代码需要php.ini开启相关的选项,保证php执行不超时的,不明白,参考我的另一篇文章 “关闭浏览器后,php脚本会不会继续运行”
//获取email地址,发信,此处为发信代码
?>

好了,改成异步方式后,用户提交信息,可以立即得到结果“发送完毕”。信呢,会在后台一封一封的发送,直到发送完毕。


经过试验,总结出来几种方法,和大家share:
1. 最简单的办法,就是在返回给客户端的HTML代码中,嵌入AJAX调用,或者,嵌入一个img标签,src指向要执行的耗时脚本。
这种方法最简单,也最快。服务器端不用做任何的调用。
但是缺点是,一般来说Ajax都应该在onLoad以后触发,也就是说,用户点开页面后,就关闭,那就不会触发我们的后台脚本了。
而使用img标签的话,这种方式不能称为严格意义上的异步执行。用户浏览器会长时间等待php脚本的执行完成,也就是用户浏览器的状态栏一直显示还在load。
当然,还可以使用其他的类似原理的方法,比如script标签等等。

2. popen()

resource popen ( string command, string mode );
//打开一个指向进程的管道,该进程由派生给定的 command 命令执行而产生。打开一个指向进程的管道,该进程由派生给定的 command 命令执行而产生。

所以可以通过调用它,但忽略它的输出。

 代码如下 复制代码
pclose(popen("/home/xinchen/backend.php &", 'r'));

这个方法避免了第一个方法的缺点,并且也很快。但是问题是,这种方法不能通过HTTP协议请求另外的一个WebService,只能执行本地的脚本文件。并且只能单向打开,无法穿大量参数给被调用脚本。
并且如果,访问量很高的时候,会产生大量的进程。如果使用到了外部资源,还要自己考虑竞争。

3. 使用CURL
这个方法,设置CUROPT_TIMEOUT为1(最小为1,郁闷)。也就是说,客户端至少必须等待1秒钟。

 代码如下 复制代码

$ch = curl_init();

 $curl_opt = array(CURLOPT_URL, 'http://www.example.com/backend.php',

                            CURLOPT_RETURNTRANSFER, 1,

                            CURLOPT_TIMEOUT, 1,);

 

curl_setopt_array($ch, $curl_opt);

 

curl_exec($ch);

 

curl_close($ch);

4. 使用fsockopen
这个方法应该是最完美的,但是缺点是,你需要自己拼出HTTP的header部分。

 代码如下 复制代码

$fp = fsockopen("www.example.com", 80, $errno, $errstr, 30);

if (!$fp) {

    echo "$errstr ($errno)<br />n";

} else {

    $out = "GET /backend.php / HTTP/1.1rn";

    $out .= "Host: www.example.comrn";

    $out .= "Connection: Closernrn";

 

    fwrite($fp, $out);

    /*忽略执行结果

while (!feof($fp)) {

echo fgets($fp, 128);

}*/

    fclose($fp);

}

[!--infotagslink--]

相关文章

  • Mybatis Plus select 实现只查询部分字段

    这篇文章主要介绍了Mybatis Plus select 实现只查询部分字段的操作,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-09-01
  • MyBatisPlus-QueryWrapper多条件查询及修改方式

    这篇文章主要介绍了MyBatisPlus-QueryWrapper多条件查询及修改方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2022-06-27
  • Oracle使用like查询时对下划线的处理方法

    这篇文章主要介绍了Oracle使用like查询时对下划线的处理方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2021-03-16
  • 解决mybatis-plus 查询耗时慢的问题

    这篇文章主要介绍了解决mybatis-plus 查询耗时慢的问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-07-04
  • Mysql效率优化定位较低sql的两种方式

    关于mysql效率优化一般通过以下两种方式定位执行效率较低的sql语句。通过慢查询日志定位那些执行效率较低的 SQL 语句,用 --log-slow-queries[=file_name] 选项启动时, mysqld 会 写一个包含所有执行时间超过 long_quer...2015-11-08
  • MySQL针对Discuz论坛程序的基本优化教程

    过了这么久,discuz论坛的问题还是困扰着很多网友,其实从各论坛里看到的问题总结出来,很关键的一点都是因为没有将数据表引擎转成InnoDB导致的,discuz在并发稍微高一点的环境下就表现的非常糟糕,产生大量的锁等待,这时候如果...2015-11-24
  • Android用MemoryFile文件类读写进行性能优化

    java开发的Android应用,性能一直是一个大问题,,或许是Java语言本身比较消耗内存。本文我们来谈谈Android 性能优化之MemoryFile文件读写。 Android匿名共享内存对外A...2016-09-20
  • 101个MySQL的配置和优化以及备份的经验提示

    MySQL是一个功能强大的开源数据库。随着越来越多的数据库驱动的应用程序,人们一直在推动MySQL发展到它的极限。这里是101条调节和优化 MySQL安装的技巧。一些技巧是针对特定的安装环境的,但这些思路是通用的。我已经把...2013-09-11
  • Angular性能优化之第三方组件和懒加载技术

    这篇文章主要介绍了Angular性能优化之第三方组件和懒加载技术,对性能优化感兴趣的同学,可以参考下...2021-05-11
  • MySQL中在查询结果集中得到记录行号的方法

    如果需要在查询语句返回的列中包含一列表示该条记录在整个结果集中的行号, ISO SQL:2003 标准提出的方法是提供 ROW_NUMBER() / RANK() 函数。 Oracle 中可以使用标准方法(8i版本以上),也可以使用非标准的 ROWNUM ; MS SQL...2015-03-15
  • Node实现搜索框进行模糊查询

    这篇文章主要为大家详细介绍了Node实现搜索框进行模糊查询,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2021-06-28
  • C#程序优化-有效减少CPU占用率

    本文给大家介绍的是C#程序优化的小技巧,通过此方法可以有效的降低CPU的占用率,十分的简单实用,有需要的小伙伴可以参考下。...2020-06-25
  • 利用 Chrome Dev Tools 进行页面性能分析的步骤说明(前端性能优化)

    这篇文章主要介绍了利用 Chrome Dev Tools 进行页面性能分析的步骤说明(前端性能优化),本文给大家介绍的非常想详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2021-02-24
  • Mybatis用注解写in查询的实现

    这篇文章主要介绍了Mybatis用注解写in查询的实现方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-07-13
  • 网站广告怎么投放最好?首屏广告投放类型优化和广告位布局优化的案例

    网站广告怎么投放最好?一个网站中广告位置最好的是哪几个地方呢,许多的朋友都不知道如何让自己的网站广告收效最好了,今天我们就一起来看看吧。 在说到联盟优化前,...2016-10-10
  • JavaScript提高网站性能优化的建议(二)

    这篇文章主要介绍了JavaScript提高网站性能优化的建议(二)的相关资料,需要的朋友可以参考下...2016-07-29
  • PHP+Mysql+jQuery查询和列表框选择操作实例讲解

    本文讲解如何通过ajax查询mysql数据,并将返回的数据显示在待选列表中,再通过选择最终将选项加入到已选区,可以用在许多后台管理系统中。本文列表框的操作依赖jquery插件。HTML <form id="sel_form" action="post.php" me...2015-10-23
  • 详解Vue开发网站seo优化方法

    这篇文章主要介绍了Vue开发网站seo优化方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-05-07
  • Element-ui 自带的两种远程搜索(模糊查询)用法讲解

    这篇文章主要介绍了Element-ui 自带的两种远程搜索(模糊查询)用法讲解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-01-29
  • CocosCreator ScrollView优化系列之分帧加载

    这篇文章主要介绍了CocosCreator ScrollView的优化,从分帧加载进行了讲解,对性能优化感兴趣的同学,一定要看一下...2021-04-15