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

首頁

後端開發

php教程

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

WBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWB

Jul 12, 2016 am 09:05 AM

php redis

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="/static/imghw/default1.png"  data-src="loading.gif"  class="lazy" alt="PHP+redis实现添加处理投票的方法，phpredis_PHP教程" >Loading...
</body>
</html>

登入後複製

其中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;>

登入後複製

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

本網站聲明

本文內容由網友自願投稿，版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容，請聯絡admin@php.cn

熱AI工具

Undresser.AI Undress

人工智慧驅動的應用程序，用於創建逼真的裸體照片

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

免費脫衣圖片

Clothoff.io

AI脫衣器

Video Face Swap

使用我們完全免費的人工智慧換臉工具，輕鬆在任何影片中換臉！

熱工具

記事本++7.3.1

好用且免費的程式碼編輯器

SublimeText3漢化版

中文版，非常好用

禪工作室 13.0.1

強大的PHP整合開發環境

Dreamweaver CS6

視覺化網頁開發工具

SublimeText3 Mac版

神級程式碼編輯軟體(SublimeText3)

熱門話題

Java教學

1670

CakePHP 教程

1428

Laravel 教程

1329

PHP教程

1274

C# 教程

1256

Related knowledge

如何利用Redis緩存方案高效實現產品排行榜列表的需求？ Apr 19, 2025 pm 11:36 PM

Redis緩存方案如何實現產品排行榜列表的需求？在開發過程中，我們常常需要處理排行榜的需求，例如展示一個�...

Spring Boot中OAuth2Authorization對象Redis緩存失敗怎麼辦？ Apr 19, 2025 pm 08:03 PM

SpringBoot中使用Redis緩存OAuth2Authorization對像在SpringBoot應用中，使用SpringSecurityOAuth2AuthorizationServer...

REDIS的角色：探索數據存儲和管理功能 Apr 22, 2025 am 12:10 AM

Redis在數據存儲和管理中扮演著關鍵角色，通過其多種數據結構和持久化機製成為現代應用的核心。 1）Redis支持字符串、列表、集合、有序集合和哈希表等數據結構，適用於緩存和復雜業務邏輯。 2）通過RDB和AOF兩種持久化方式，Redis確保數據的可靠存儲和快速恢復。

IIS和PHP的兼容性：深度潛水 Apr 22, 2025 am 12:01 AM

IIS和PHP可以兼容，通過FastCGI實現。 1.IIS通過配置文件將.php文件請求轉發給FastCGI模塊。 2.FastCGI模塊啟動PHP進程處理請求，提高性能和穩定性。 3.實際應用中需注意配置細節、錯誤調試和性能優化。

如果session_start（）被多次調用會發生什麼？ Apr 25, 2025 am 12:06 AM

多次調用session_start()會導致警告信息和可能的數據覆蓋。 1)PHP會發出警告，提示session已啟動。 2)可能導致session數據意外覆蓋。 3)使用session_status()檢查session狀態，避免重複調用。

使用RedisTemplate進行批量查詢時，為什麼返回值會為空？ Apr 19, 2025 pm 10:15 PM

使用RedisTemplate進行批量查詢時為何返回值為空？在使用RedisTemplate進行批量查詢操作時，可能會遇到返回的結果�...

REDIS：了解其架構和目的 Apr 26, 2025 am 12:11 AM

Redis是一种内存数据结构存储系统，主要用作数据库、缓存和消息代理。它的核心特点包括单线程模型、I/O多路复用、持久化机制、复制与集群功能。Redis在实际应用中常用于缓存、会话存储和消息队列，通过选择合适的数据结构、使用管道和事务、以及进行监控和调优，可以显著提升其性能。

作曲家：通過AI的幫助開發PHP Apr 29, 2025 am 12:27 AM

AI可以幫助優化Composer的使用，具體方法包括：1.依賴管理優化：AI分析依賴關係，建議最佳版本組合，減少衝突。 2.自動化代碼生成：AI生成符合最佳實踐的composer.json文件。 3.代碼質量提升：AI檢測潛在問題，提供優化建議，提高代碼質量。這些方法通過機器學習和自然語言處理技術實現，幫助開發者提高效率和代碼質量。

See all articles

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

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

熱AI工具

Undresser.AI Undress

AI Clothes Remover

Undress AI Tool

Clothoff.io

Video Face Swap

熱門文章

熱工具

記事本++7.3.1

SublimeText3漢化版

禪工作室 13.0.1

Dreamweaver CS6

SublimeText3 Mac版

熱門話題