本文实例讲述了PHP+redis实现添加处理投票的方法。分享给大家供大家参考,具体如下:
PHP;">
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);
}
}
}
}
?>
<Meta http-equiv="refresh" content="1;url=https://itunes.apple.com/cn/app/san-guo-zhi15-ba-wangno-da-lu/id694974270?mt=8">
统计
其中PHP连接MysqL类MysqL.class.PHP如下:
PHP;">
_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->_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,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("
",$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("MysqL _error: %s (%s)
/n",$this->_errno,$this->_error); } die($msg); }else{ die("Session halted."); } } } ?>
",$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("MysqL _error: %s (%s)
/n",$this->_errno,$this->_error); } die($msg); }else{ die("Session halted."); } } } ?>
希望本文所述对大家PHP程序设计有所帮助。