php中memcache 基本操作实例
程序员文章站
2022-10-12 09:26:46
php中memcache 基本操作实例
php中memcache 基本操作实例
<!doctype html>
<html>
<head>
<title>memcache demo</title>
<meta http-equiv="content-type"content="text/html;chatset=utf-8">
</head>
<body>
<?php
$server_ip = '127.0.0.1';
$server_port = 11211;
$memcache = new memcache();
$memcache->connect($server_ip,$server_port);
$memcache->add("name1","user_name1",memcache_compressed,0);
$memcache->add("name2","user_name2",memcache_compressed,0);
$array1 = array('name1' => 'jiajiam1',
'age1'=>12,
'country'=>'china');
$memcache->add("other",$array1,memcache_compressed,20);
$memcache->set("name3","user_name3",memcache_compressed,0);
$memcache->replace("name1","user_name_relpace",memcache_compressed,0);
$memcache->replace("123","12345");
echo"name1:".$memcache->get("name1")."<br/>";
$memcache->delete("name1");
echo"name1:".$memcache->get("name1")."<br/>";
$array_get = array("name1","name2","name3");
$result_get = $memcache->get($array_get);
foreach ($result_get as $key => $value) {
echo"$key:--->$value<br/>";
}
foreach ($memcache->getstats() as $key => $value) {
echo"$key:--->$value<br/>";
};
echo"<br/>";
foreach($memcache->getextendedstats() as $key => $value) {
echo"$key:--->$value<br/>";
}
$memcache->close();
?>
</body>
</html>
我们再来看个更加具体些的实例
<?php
include('inc/common.inc.php');
if (! isset($city) || ! is_array($city) ) {
exit;
}
//print_r ($city);exit;
$mem = new memcache();
$mem-> connect('localhost', '11211');
$expires=15*60;
//check if cache exits
if(($value = $mem-> get($city)) != false) {
echo "get key from memcache: "."<br />";
// $return=$mem->get($city);
// echo json_encode($return);
}//if
else {
$resultjson=fetch_data();
echo count($resultjson)."<br />";
if(count($resultjson)==1 || empty($resultjson)){
//从mysql中取值
echo "get key from mysql:"."<br />";
$query="select * from pm25";
$result=mysql_query ($query) ;
while ($row = mysql_fetch_assoc($result)){
$rows[]=$row;
}
//将获取的值数组存入memcache
for($i=0;$i<count($rows);$i++){
$k[$i]=$rows[$i]['city'];
$v[$i]['city']=$rows[$i]['city'];
$v[$i]['pm25']=$rows[$i]['pm25'];
$mem -> set($k[$i], $v[$i], false, $expires);
}
// $return=$mem->get($city);
// echo json_encode($return);
}//if
else{
echo "get key from new_writed mysql:"."<br />";
write_db($resultjson);
$query="select * from pm25";
$result=mysql_query ($query) ;
while ($row = mysql_fetch_assoc($result)){
$rows[]=$row;
}
//write memcache
for($i=0;$i<count($rows);$i++){
$k[$i]=$rows[$i]['city'];
$v[$i]['city']=$rows[$i]['city'];
$v[$i]['pm25']=$rows[$i]['pm25'];
$mem -> set($k[$i], $v[$i], false, $expires);
}
// $return=$mem->get($city);
// echo json_encode($return);
}//else
}//else
foreach ($city as $k=>$v){
$return[$k]=$mem->get($v);
}
echo json_encode($return);
function fetch_data() {
$url="http://www.example.com";
//$url="";
$data = http_get($url);
$getjson = json_decode($data, true);
return $getjson;
} //func fetch_data
function write_db($getjson){
$sql="delete from pm25";
mysql_query($sql);
//sort the json.txt
foreach ($getjson as $key => $row) {
$area[$key] = $row['area'];
$pm2_5[$key]= $row['pm2_5'];
}
array_multisort($area, sort_asc,$pm2_5,sort_asc,$getjson);
for($i=0;$i<count($getjson)-1;$i++){
if($getjson[$i]['pm2_5']==0)
$count=0;
else
$count=1;
$sum=$getjson[$i]['pm2_5'];
for($j=$i+1;$j<count($getjson);$j++,$i++){
if(strcmp($getjson[$j]['area'],$getjson[$i]['area'])==0 ){
if($getjson[$j]['pm2_5']==0 ){
continue;
}
else{
$count++;
$sum+=$getjson[$j]['pm2_5'];
$pm2_5=$sum/$count;
}
}
else{
//insert into mysql
$result['city']=$getjson[$i]['area'];
$result['pm25']=intval($pm2_5);
$query="insert into pm25(city,pm25) values ('".$result['city']."',".$result['pm25'].")";
mysql_query($query);
break;
}
}
}
return $getjson;
}//func write_db
$mem -> close();
?>
以上所述就是本文的全部内容了，希望大家能够喜欢。
下一篇： php中关于socket的系列函数总结