PHP+redis实现添加处理投票的方法

作者:jackluo 时间:2023-11-22 04:38:19 

本文实例讲述了PHP+redis实现添加处理投票的方法。分享给大家供大家参考,具体如下:


<?php
header("Content-Type:text/html;charset=utf-8");
include 'lib/mysql.class.php';
$mysql_obj = mysql::getConn();
if(class_exists('Redis')){
 //redis
 $redis = new Redis();
 $redis->pconnect('127.0.0.1', 6379);
 if(isset($_SERVER['HTTP_REFERER'])){
  $url_md5 = md5($_SERVER['HTTP_REFERER']);
 }
 $adve_key = 'adve';
 $adve_key_exists = 'adve_exists';
 if(!$redis->exists($adve_key_exists)){
  $list = $mysql_obj->fetch_array("select * from admin_online_adve");
  if($list){
   foreach ($list as $key => $value) {
    $url_hash = md5($value['adve_url']);
    $adve_hash_key = $adve_key.":".$url_hash;
    $id = $value['id'];
    $redis->set($adve_hash_key,$id);
    $redis->set($adve_key_exists,true);
   }
  }
 }
 $adve_new_key = $adve_key.':'.$url_md5;
 if($redis->exists($adve_new_key)){
   $adve_plus = $adve_new_key.":plus" ;
   if(!$redis->exists($adve_plus)){
    $redis->set($adve_plus,1);
   }else{
    $redis->incr($adve_plus);
    $num = $redis->get($adve_plus);
    if($num >100){
     $id = $redis->get($adve_new_key);
     // insert to sql;
     $mysql_obj->query("update admin_online_adve set adve_num=adve_num+$num where id=$id");
     $redis->set($adve_plus,1);
    }
   }
 }
}
?>
<html>
<head>
<meta http-equiv="refresh" content="1;url=https://itunes.apple.com/cn/app/san-guo-zhi15-ba-wangno-da-lu/id694974270?mt=8">
<title>统计</title>
</head>
<body>
<img src="loading.gif">Loading...
</body>
</html>

其中php连接mysql类mysql.class.php如下:


<?php
define("MYSQL_SQL_GETDATA", 1);
define("MYSQL_SQL_EXECUTE", 2);
class mysql_db{
 var $_server;        //数据库服务器地址
 var $_user;         //数据库连接帐号
 var $_password;       //数据库连接密码
 var $_dbname;        //数据库名称
 var $_persistency=false;  //是否使用持久连接
 var $_isConnect = false;  //是否已经建立数据库连接
 var $_charset="utf8";    //数据库连接字符集
 var $_isDebug = false;   //是否Debug模式
 var $_sql=array();     //执行sql语句数组
 var $_db_connect_id;    //数据库连接对象标识
 var $_result;        //执行查询返回的值
 var $_record;
 var $_rowset;
 var $_errno = 0;
 var $_error = "connection error";
 var $_checkDB = false;
 function mysql_db($dbserver, $dbuser, $dbpassword,$database,$persistency = false,$autoConnect=false,$checkdb = false)
 {
   $this->_server = $dbserver;
   $this->_user = $dbuser;
   $this->_password = $dbpassword;
   $this->_dbname = $database;
   $this->_persistency = $persistency;
   $this->_autoConnect = $autoConnect;
   $this->_checkDB = $checkdb;
   if($autoConnect){
     $this->connection();
   }
 }
 function connection($newLink = false)
 {
   if (!$newLink){
     if($this->_isConnect && isset($this->_db_connect_id)){
       @mysql_close($this->_db_connect_id);
     }
   }
   $this->_db_connect_id = ($this->persistency) ? @mysql_pconnect($this->_server, $this->_user, $this->_password):@mysql_connect($this->_server, $this->_user, $this->_password,$newLink);
   if ($this->_db_connect_id)
   {
     if ($this->version() > '4.1')
     {
       if ($this->_charset != "")
       {
         @mysql_query("SET NAMES '".str_replace('-', '', $this->_charset)."'", $this->_db_connect_id);
       }
     }
     if ($this->version() > '5.0')
     {
       @mysql_query("SET sql_mode=''", $this->_db_connect_id);
     }
     //检测指定数据库是否连接成功
     if ($this->_checkDB){
       $dbname = mysql_query('SELECT database()',$this->_db_connect_id);
       $dbname = mysql_fetch_array($dbname,MYSQL_NUM);
       $dbname = trim($dbname[0]);
     }else{
       $dbname = '';
     }
     if ($dbname==$this->_dbname || $dbname==''){
       if (!@mysql_select_db($this->_dbname, $this->_db_connect_id))
       {
         @mysql_close($this->_db_connect_id);
         $this->_halt("cannot use database " . $this->_dbname);
       }
     }else{
       if ($this->_checkDB && !$newLink){
         $this->connection(true);
       }
     }
     return true;
   }
   else
   {
     $this->_halt('connect failed.',false);
   }
 }
 function setCharset($charset){
   //$charset = str_replace('-', '', $charset);
   $this->_charset = $charset;
 }
 function setDebug($isDebug=true){
   $this->_isDebug = $isDebug;
 }
 function query($sql,$type='')
 {
   return $this->_runSQL($sql,MYSQL_SQL_GETDATA,$type);
 }
 function execute($sql)
 {
   return $this->_runSQL($sql,MYSQL_SQL_EXECUTE,"UNBUFFERED");
 }
 function _runSQL($sql,$sqlType=MYSQL_SQL_GETDATA,$type = '')
 {
   if ($type =="UNBUFFERED"){
     $this->_result = @mysql_unbuffered_query($sql,$this->_db_connect_id);
   }else{
     $this->_result = @mysql_query($sql,$this->_db_connect_id);
   }
   //测试模式下保存执行的sql语句
   if($this->_isDebug){
     $this->_sql[]=$sql;
   }
   if ($this->_result)
   {
     return $sqlType==MYSQL_SQL_GETDATA?$this->getNumRows():$this->getAffectedRows();
   }else{
     $this->_halt("Invalid SQL: ".$sql);
     return false;
   }
 }
 function next($result_type=MYSQL_ASSOC) {
   $this->fetchRow($result_type);
   return is_array($this->_record);
 }
 function f($name) {
   if(is_array($this->_record)){
     return $this->_record[$name];
   }else{
     return false;
   }
 }
 function fetchRow($result_type=MYSQL_ASSOC)
 {
   if( $this->_result )
   {
     $this->_record = @mysql_fetch_array($this->_result,$result_type);
     return $this->_record;
   }else{
     return false;
   }
 }
 function getAll($sql,$primaryKey="",$result_type=MYSQL_ASSOC)
 {
   if ($this->_runSQL($sql,MYSQL_SQL_GETDATA)>=0){
     return $this->fetchAll($primaryKey,$result_type);
   }else{
     return false;
   }
 }
 function getOne($sql,$result_type=MYSQL_ASSOC)
 {
   if ($this->_runSQL($sql,MYSQL_SQL_GETDATA)>0){
     $arr = $this->fetchAll("",$result_type);
     if(is_array($arr)){
       return $arr[0];
     }
   }else{
     return false;
   }
 }
 function fetchAll($primaryKey = "",$result_type=MYSQL_ASSOC)
 {
   if ($this->_result)
   {
     $i = 0;
     $this->_rowset = array();
     if ($primaryKey=="")
     {
       while($this->next($result_type))
       {
         $this->_rowset[$i] = $this->_record;
         $i++;
       }
     }else{
       while($this->next($result_type))
       {
         $this->_rowset[$this->f($primaryKey)] = $this->_record;
         $i++;
       }
     }
     return $this->_rowset;
   }else{
     //$this->_halt("Invalid Result");
     return false;
   }
 }
 function checkExist($sql)
 {
   return $this->query($sql)>0?true:false;
 }
 function getValue($sql, $colset = 0)
 {
   if ($this->query($sql)>0){
     $this->next(MYSQL_BOTH);
     return $this->f($colset);
   }else{
     return false;
   }
 }
 function getNumRows()
 {
   return @mysql_num_rows($this->_result);
 }
 function getNumFields()
 {
   return @mysql_num_fields($this->_result);
 }
 function getFiledName($offset)
 {
   return @mysql_field_name($this->_result, $offset);
 }
 function getFiledType($offset)
 {
   return @mysql_field_type($this->_result, $offset);
 }
 function getFiledLen($offset)
 {
   return @mysql_field_len($this->_result, $offset);
 }
 function getInsertId()
 {
   return @mysql_insert_id($this->_db_connect_id);
 }
 function getAffectedRows()
 {
   return @mysql_affected_rows($this->_db_connect_id);
 }
 function free_result()
 {
   $ret = @mysql_free_result($this->_result);
   $this->_result = 0;
   return $ret;
 }
 function version() {
   return @mysql_get_server_info($this->_db_connect_id);
 }
 function close() {
   return @mysql_close($this->_db_connect_id);
 }
 function sqlOutput($isOut = true, $all = true){
   if($all){
     $ret = implode("<br>",$this->_sql);
   }else{
     $ret = $this->_sql[count($this->_sql)-1];
   }
   if ($isOut){
     echo $ret;
   }else{
     return $ret;
   }
 }
 function _halt($msg="Session halted.",$getErr=true) {
   if($this->_isDebug){
     if($getErr){
       $this->_errno = @mysql_errno($this->_db_connect_id);
       $this->_error = @mysql_error($this->_db_connect_id);
       printf("<b>MySQL _error</b>: %s (%s)<br></font>/n",$this->_errno,$this->_error);
     }
     die($msg);
   }else{
     die("Session halted.");
   }
 }
}
?>

希望本文所述对大家PHP程序设计有所帮助。

标签:PHP,redis
0
投稿

猜你喜欢

  • python argparse传入布尔参数false不生效的解决

    2023-07-03 16:12:20
  • php中的登陆login

    2023-10-08 10:49:30
  • python回调函数的使用方法

    2023-05-28 02:50:55
  • 简单学习Python time模块

    2021-04-24 00:18:53
  • python得到windows自启动列表的方法

    2023-12-18 14:49:13
  • Git原理和常用操作

    2023-02-01 23:55:55
  • Vue源码之关于vm.$delete()/Vue.use()内部原理详解

    2023-07-02 16:48:08
  • python特效之字符成像详解

    2021-06-07 02:18:45
  • MSSQL自动重建出现碎片的索引的方法分享

    2024-01-17 13:50:52
  • 详解Python中的正斜杠与反斜杠

    2021-06-28 08:38:10
  • Mysql复制表三种实现方法及grant解析

    2024-01-13 06:03:23
  • DB为何大量出现select @@session.tx_read_only 详解

    2024-01-15 15:26:15
  • python正则表达式中的括号匹配问题

    2023-07-26 01:36:24
  • JavaScript实现五子棋游戏的方法详解

    2024-04-30 10:11:54
  • Django mysqlclient安装和使用详解

    2024-01-13 21:13:08
  • oracle 安装与SQLPLUS简单用法

    2009-06-10 17:49:00
  • python浪漫表白源码

    2023-11-22 05:16:39
  • SQL 分布式查询、插入递增列示例

    2024-01-21 01:49:39
  • Python接口自动化之接口依赖

    2021-09-03 15:53:09
  • 邮箱正则表达式实现代码(针对php)

    2024-05-03 15:48:55
  • asp之家 网络编程 m.aspxhome.com