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

PHP结合Redis+MySQL实现冷热数据交换应用案例详解

发布:smiling 来源: PHP粉丝网  添加日期:2021-12-04 13:26:46 浏览: 评论:0 

这篇文章主要介绍了PHP结合Redis+MySQL实现冷热数据交换应用案例,结合具体实例形式详细分析了Redis+MySQL冷热数据交换原理、实现方法及相关操作技巧,需要的朋友可以参考下。

本文实例讲述了PHP结合Redis+MySQL实现冷热数据交换应用案例,分享给大家供大家参考,具体如下:

场景:某网站需要对其项目做一个投票系统,投票项目上线后一小时之内预计有100万用户进行投票,希望用户投票完就能看到实时的投票情况

这个场景可以使用redis+mysql冷热数据交换来解决。

何为冷热数据交换?

冷数据:之前使用的数据,热数据:当前使用的数据。

交换:将Redis中的数据周期的存储到MySQL中

业务流程

用户进行投票后,首先将投票数据保存到Redis中,这些数据就是热数据,然后定期(如5s)将热数据保存到MySQL中,这些数据就变为冷数据,然后将冷数据从Redis中删除,周而复始,知道一个小时投票结束。

项目结构图

Redis+MySQL PHP冷热数据交换

index.html文件

这是投票的首页,有3个投票按钮,模拟给3个用户投票,点击按钮,使用ajax调用vote.php文件

  1. <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd"> 
  2. <html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en"> 
  3. <head> 
  4.   <meta http-equiv="Content-Type" content="text/html;charset=UTF-8"> 
  5.   <title>Document</title> 
  6. </head> 
  7. <script src="http://lib.sinaapp.com/js/jquery/1.9.1/jquery-1.9.1.min.js"></script> 
  8. <body> 
  9.   <p><span id="uid1">0</span><input type="button" value="用户1" onclick="vote(1);" /></p> 
  10.   <p><span id="uid2">0</span><input type="button" value="用户2" onclick="vote(2);" /></p> 
  11.   <p><span id="uid3">0</span><input type="button" value="用户3" onclick="vote(3);" /></p> 
  12. </body> 
  13. <script> 
  14.   function vote(i){ 
  15.     $.get('vote.php?uid='+i,function(rs){ 
  16.       var span = '#uid'+i; 
  17.       $(span).html(rs); 
  18.     }); 
  19.   } 
  20. </script> 
  21. </html> 

vote.php

这个文件主要实现投票的逻辑。首先连接上Redis服务器,然后保存投票人id,然后将投票人id为key记录每个用户的票数,然后返回给index.html文件,最后使用global_voteid作为key记录总票数,也可以作为MySQL的自增长的键。然后记录uid,ip,time等数据。

注意格式有一定的要求:

假如voteid为3,记录的是ip,那么键为vote:3:ip:127.0.0.1

  1. <?php 
  2. $redis = new Redis(); 
  3. $redis->connect('localhost',6379); 
  4. //计算每个用户的总票数 
  5. $uid = intval($_GET['uid']); 
  6. //$uid = mt_rand(1,3);//随机指定投票人员,方便进行压力测试 
  7. echo $redis->incr($uid); 
  8. $voteid = $redis->incr('global_voteid'); 
  9. $redis->set('vote:'.$voteid.':uid',$uid); 
  10. $ip = $_SERVER['REMOTE_ADDR']; 
  11. $redis->set('vote:'.$voteid.':ip',$ip); 
  12. $redis->set('vote:'.$voteid.':time',time()); 

重点内容

这个文件主要实现冷热数据交换,首先连接MySQL数据库和redis服务器,然后每隔5秒去执行while循环,在while循环里获取自增长的投票主键和最近一次插入mysql的投票主键(位置)。判断插入的位置是否存在,如果不存在就从头插入,如果全部插入完毕,就进行等待,如果没有插入完毕,就进行插入操作。

  1. <?php 
  2. //连接数据库 
  3. $pdo = new PDO('mysql:host=localhost;dbname=test','root','1234'); 
  4. $pdo->query('set names utf8'); 
  5. //连接redis 
  6. $redis = new Redis(); 
  7. $redis->connect('localhost',6379); 
  8. //永真循环 
  9. while(true){ 
  10.   $vid = $redis->get('global_voteid');//自增长的主键 
  11.   $last = $redis->get('last');//最近一次插入mysql的投票主键 
  12.   //如果没有插入数据库,刚开始的肯定为true 
  13.   if(!$last){ 
  14.     $last = 0;//设置为0 
  15.   } 
  16.   //如果所有的数据都被插入到MySQL中 
  17.   if($vid == $last){ 
  18.     echo "wait\n";//输出等待 
  19.   }else
  20.     //进行插入到数据库操作 
  21.     $sql = 'insert into vote(vid,uid,ip,time) values'
  22.     for($i = $vid;$i>$last;$i--){ 
  23.       $k1 = 'vote:'.$i.':uid'
  24.       $k2 = 'vote:'.$i.':ip'
  25.       $k3 = 'vote:'.$i.':time'
  26.       $row = $redis->mget([$k1,$k2,$k3]); 
  27.       $sql.="($i,$row[0],'$row[1]',$row[2]),"
  28.             $redis->delete($k1,$k2,$k3); 
  29.     } 
  30.     $sql = substr($sql,0,-1); 
  31.     $pdo->exec($sql); 
  32.     $redis->set('last',$vid);//设置插入的主键位置 
  33.     echo 'OK'
  34.   } 
  35.   sleep(5);//每隔5秒执行循环 

vote表

Redis+MySQL PHP冷热数据交换

运行步骤:

1、使用php命令行工具调用swap.php

Redis+MySQL PHP冷热数据交换

2、使用Apache的ab工具进行压力测试。

Redis+MySQL PHP冷热数据交换

Tags: Redis+MySQL PHP冷热数据交换

分享到: