Gemeinschaft Lernen Tools-Bibliothek Freizeit
suchen
Deutsch
Heim > Backend-Entwicklung > PHP-Tutorial > PHP+redis实现添加处理投票的方法，phpredis_PHP教程

PHP+redis实现添加处理投票的方法，phpredis_PHP教程

WBOY
Freigeben： 2016-07-12 09:05:00
Original
677 Leute haben es durchsucht

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

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

<&#63;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);
     }
    }
  }
 }
&#63;>
<html>
<head>
<meta http-equiv="refresh" content="1;url=https://itunes.apple.com/cn/app/san-guo-zhi15-ba-wangno-da-lu/id694974270&#63;mt=8">
<title>统计</title>
</head>
<body>
 <img  src="loading.gif" alt="PHP+redis实现添加处理投票的方法，phpredis_PHP教程" >Loading...
</body>
</html>
Nach dem Login kopieren

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

<&#63;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) &#63; @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&#63;$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&#63;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.");
    }
  }
}
&#63;>
Nach dem Login kopieren

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

www.bkjia.comtruehttp://www.bkjia.com/PHPjc/1071397.htmlTechArticlePHP+redis实现添加处理投票的方法，phpredis 本文实例讲述了PHP+redis实现添加处理投票的方法。分享给大家供大家参考，具体如下： php header(...
Verwandte Etiketten：
php redis
Quelle：php.cn
Vorheriger Artikel：有评论就是我最大的动力~MySQL基础篇完结（存储引擎和图形化管理工具），mysql基础篇_PHP教程 Nächster Artikel：两款万能的php分页类，两款php分页_PHP教程
Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn
Neueste Artikel des Autors
Aktuelle Ausgaben
Aus URL-Parametern erhaltene PHP-Arrays verhalten sich nicht wie erwartet Ich habe einen URL-Parameter, der die Kategorie-ID enthält, und ich möchte ihn als Array w...
Aus 2024-04-06 22:09:02
0
1
1428
Wo soll ich die CustomLog-Direktive in Apache platzieren? Ich verwende php:7.2-apachedocker. Ich muss das URL-Anmeldezugriffsprotokoll zur Gesundhei...
Aus 2024-04-06 22:03:59
0
1
990
Welches Format haben die Variablen im Rückgabewert? Ich bin ein PHP-Neuling. Ich habe einen Code gefunden: if($x<time()){return[false,'erro...
Aus 2024-04-06 21:55:20
0
1
778
Bei der Verwendung von opentbs zum Generieren von ODT-Dateien sind Probleme aufgetreten: Werte desselben Schlüssels werden in derselben Zeile statt in separaten Spalten angezeigt. Ich verwende eine Bibliothek namens OpenTbs, um ODT mit PHP zu erstellen. Ich verwende sie...
Aus 2024-04-06 20:18:18
0
1
483
Gruppieren Sie MySQL-Ergebnisse nach ID für die Schleife Ich habe eine Tabelle mit Flugdaten in MySQL. Ich schreibe einen PHP-Code, der Daten mithi...
Aus 2024-04-06 17:27:56
0
1
406
verwandte Themen
Mehr>
Beliebte Empfehlungen
Beliebte Tutorials
Mehr>
Verwandte Tutorials
Beliebte Empfehlungen
Aktuelle Kurse
Neueste Downloads
Mehr>
Web-Effekte
Quellcode der Website
Website-Materialien
Frontend-Vorlage