当前位置:首页 > PHP教程 > php高级应用 > 列表

php从memcache读取数据再批量写入mysql的方法

发布:smiling 来源: PHP粉丝网  添加日期:2021-05-05 12:47:19 浏览: 评论:0 

这篇文章主要介绍了php从memcache读取数据再批量写入mysql的方法,可利用memcache缓解服务器读写压力,并实现数据库数据的写入操作,非常具有实用价值,需要的朋友可以参考下

本文实例讲述了php从memcache读取数据再批量写入mysql的方法。分享给大家供大家参考。具体分析如下:

用 Memcache 可以缓解 php和数据库压力下面代码是解决高负载下数据库写入瓶颈问题,遇到最实用的:写入ip pv uv的时候,用户达到每分钟几万访问量,要记录这些数据,实时写入数据库必定奔溃.

用以下技术就能解决,还有如用户注册,同一时间断内,大量用户注册,可以缓存后一次性写入到数据库,代码如下:

  1. public function cldata(){ 
  2. $memcache_obj = new Memcache; 
  3.     $memcache_obj->connect('127.0.0.1''11211'); 
  4.     $all_items = $memcache_obj->getExtendedStats('items'); 
  5.     foreach($all_items as $option=>$vall){ 
  6.         if (isset($all_items[$option]['items'])) { 
  7.                  $items = $all_items[$option]['items']; 
  8.                  foreach ($items as $number => $item) { 
  9.                        $str    = $memcache_obj->getExtendedStats('cachedump'$number, 0); 
  10.                        $line   = $str[$option]; 
  11. if(is_array($line) && count($line) > 0){ 
  12.     foreach($line as $key => $value) { 
  13.         $keys[] = $key
  14.  
  15.     dump(count($keys));//获取到key 
  16.     if(count($keys)>50){//要写入的数据条数       
  17.         $end=50; 
  18.     }else
  19.         $end=count($keys); 
  20.     } 
  21.       
  22.     for($i=0;$i<=$end;$i++){ 
  23.         if(!strstr($keys[$i],'datadb')) continue;       
  24.         $ksv = str_replace('datadb','',$keys[$i]); 
  25.           
  26.     /*$logdata = unserialize(S('login'.$ksv));//登录写入 
  27.     if(is_array($logdata)){ 
  28.         $this->addsuidinlogin($logdata[0],$logdata[1],$logdata[2],1);        
  29.     }   */ 
  30.           
  31.         /*$sdata = unserialize(S('regadd'.$ksv));//注册写入 
  32.     if(is_array($sdata)){ 
  33.         $this->baiduad($sdata[0],$sdata[1],$sdata[2],$sdata[3],$sdata[4],1);     
  34.     } 
  35.     */ 
  36.         $regdata = unserialize(S('datadb'.$ksv));       
  37.         $ress[]=$regdata
  38.         S('datadb'.$ksv,null); 
  39.       
  40.     }   
  41.     $addb = M()->db(66,C('DB_WEB_AD'));//批量写入 addall 
  42.     $addb->table('mj_ad_count')->addall($ress); 
  43.     echo M()->getLastSql();    

补充:可以使用的工具如:memadmin 还有memadmin 文档.

Tags: memcache 批量写入mysql

分享到: