PHP+redis实现添加处理投票的方法，phpredis
PHP+redis实现添加处理投票的方法，phpredis
本文实例讲述了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="/static/imghw/default1.png" data-src="loading.gif" class="lazy" alt="PHP+redis实现添加处理投票的方法，phpredis" >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程序设计有所帮助。
Hot AI Tools
Undresser.AI Undress
AI-powered app for creating realistic nude photos
AI Clothes Remover
Online AI tool for removing clothes from photos.
Undress AI Tool
Undress images for free
Clothoff.io
AI clothes remover
Video Face Swap
Swap faces in any video effortlessly with our completely free AI face swap tool!
Hot Article
Hot Tools
Notepad++7.3.1
Easy-to-use and free code editor
SublimeText3 Chinese version
Chinese version, very easy to use
Zend Studio 13.0.1
Powerful PHP integrated development environment
Dreamweaver CS6
Visual web development tools
SublimeText3 Mac version
God-level code editing software (SublimeText3)
Hot Topics
1386
52
How to build the redis cluster mode
Apr 10, 2025 pm 10:15 PM
Redis cluster mode deploys Redis instances to multiple servers through sharding, improving scalability and availability. The construction steps are as follows: Create odd Redis instances with different ports; Create 3 sentinel instances, monitor Redis instances and failover; configure sentinel configuration files, add monitoring Redis instance information and failover settings; configure Redis instance configuration files, enable cluster mode and specify the cluster information file path; create nodes.conf file, containing information of each Redis instance; start the cluster, execute the create command to create a cluster and specify the number of replicas; log in to the cluster to execute the CLUSTER INFO command to verify the cluster status; make
The Future of PHP: Adaptations and Innovations
Apr 11, 2025 am 12:01 AM
The future of PHP will be achieved by adapting to new technology trends and introducing innovative features: 1) Adapting to cloud computing, containerization and microservice architectures, supporting Docker and Kubernetes; 2) introducing JIT compilers and enumeration types to improve performance and data processing efficiency; 3) Continuously optimize performance and promote best practices.
How to clear redis data
Apr 10, 2025 pm 10:06 PM
How to clear Redis data: Use the FLUSHALL command to clear all key values. Use the FLUSHDB command to clear the key value of the currently selected database. Use SELECT to switch databases, and then use FLUSHDB to clear multiple databases. Use the DEL command to delete a specific key. Use the redis-cli tool to clear the data.
PHP and Python: Comparing Two Popular Programming Languages
Apr 14, 2025 am 12:13 AM
PHP and Python each have their own advantages, and choose according to project requirements. 1.PHP is suitable for web development, especially for rapid development and maintenance of websites. 2. Python is suitable for data science, machine learning and artificial intelligence, with concise syntax and suitable for beginners.
PHP vs. Python: Understanding the Differences
Apr 11, 2025 am 12:15 AM
PHP and Python each have their own advantages, and the choice should be based on project requirements. 1.PHP is suitable for web development, with simple syntax and high execution efficiency. 2. Python is suitable for data science and machine learning, with concise syntax and rich libraries.
PHP's Current Status: A Look at Web Development Trends
Apr 13, 2025 am 12:20 AM
PHP remains important in modern web development, especially in content management and e-commerce platforms. 1) PHP has a rich ecosystem and strong framework support, such as Laravel and Symfony. 2) Performance optimization can be achieved through OPcache and Nginx. 3) PHP8.0 introduces JIT compiler to improve performance. 4) Cloud-native applications are deployed through Docker and Kubernetes to improve flexibility and scalability.
How to read redis queue
Apr 10, 2025 pm 10:12 PM
To read a queue from Redis, you need to get the queue name, read the elements using the LPOP command, and process the empty queue. The specific steps are as follows: Get the queue name: name it with the prefix of "queue:" such as "queue:my-queue". Use the LPOP command: Eject the element from the head of the queue and return its value, such as LPOP queue:my-queue. Processing empty queues: If the queue is empty, LPOP returns nil, and you can check whether the queue exists before reading the element.
PHP: The Foundation of Many Websites
Apr 13, 2025 am 12:07 AM
The reasons why PHP is the preferred technology stack for many websites include its ease of use, strong community support, and widespread use. 1) Easy to learn and use, suitable for beginners. 2) Have a huge developer community and rich resources. 3) Widely used in WordPress, Drupal and other platforms. 4) Integrate tightly with web servers to simplify development deployment.
