西部数码主机 | 阿里云主机| 虚拟主机 | 服务器 | 返回乐道官网
当前位置: 主页 > php教程 > ecshop教程 >

ecshop利用全局变量$_SESSION和register_shutdown_function自定义会话

时间:2016-04-06 08:05来源:未知 作者:好模板 点击:次
在做ecshop的二次开发过程中,虽然代码 太老太乱太冗余，但ec的会话处理的设计感觉还是不错的,就使用了$_SESSION这个全局变量而已,这个设计是最好改善原来的会话处理方式的存数据库表
在做ecshop的二次开发过程中,虽然代码 太老太乱太冗余，但ec的会话处理的设计感觉还是不错的,就使用了$_SESSION这个全局变量而已,这个设计是最好改善原来的会话处理方式的存数据库表的话,有2张表,sessions 表使用内存存储引擎，会话属于临时数据，这样存取速度很快,当然当临时数据很多时,会占用内存空间,对于较多的数据 还是需要存在磁盘上,这是就需要sessions_data 做一个sessions表的关联来存储较多的额外数据.register_shutdown_function 可以注册一个自定义的函数，在程序运行结束之前 执行。
 
表结构
 
 
 
CREATE TABLE `sessions` (
  `sesskey` char(32) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '',
  `expiry` int(10) unsigned NOT NULL DEFAULT '0',
  `userid` mediumint(8) unsigned NOT NULL DEFAULT '0',
  `adminid` mediumint(8) unsigned NOT NULL DEFAULT '0',
  `ip` char(15) NOT NULL DEFAULT '',
  `user_name` varchar(60) NOT NULL,
  `user_rank` tinyint(3) NOT NULL,
  `discount` decimal(3,2) NOT NULL,
  `email` varchar(60) NOT NULL,
  `data` char(255) NOT NULL DEFAULT '',
  PRIMARY KEY (`sesskey`),
  KEY `expiry` (`expiry`)
) ENGINE=MEMORY DEFAULT CHARSET=utf8;
 
CREATE TABLE `sessions_data` (
  `sesskey` varchar(32) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '',
  `expiry` int(10) unsigned NOT NULL DEFAULT '0',
  `data` longtext NOT NULL,
  PRIMARY KEY (`sesskey`),
  KEY `expiry` (`expiry`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8;
复制代码
 
 
 
 
程序文件根据ecshop的类有改动
 
cls_session.php
 
db.php 数据库处理
 
fun.php 用到的函数
 
init.php 初始化程序文件
 
--------------
 
两个demo程序
 
set.php
 
get.php
 
程序文件内容
 
cls_session.php
 
 
 
<?php
 
class cls_session
{
    public $db = NULL;
    public $session_table = '';
 
    public $max_life_time = 1800;
 
    public $session_name = '';
    public $session_id = '';
 
    public $session_expiry = '';
    public $session_md5 = '';
 
    public $session_cookie_path = '/';
    public $session_cookie_domain = '';
    public $session_cookie_secure = false;
 
    public $_ip = '';
    public $_time = 0;
 
    public function __construct(&$db, $session_table, $session_data_table, $session_name = 'ECS_ID', $session_id = '')
    {
        $_SESSION = array();
        $this->session_cookie_path = !empty($GLOBALS['cookie_path']) ? $GLOBALS['cookie_path'] : "/";
        $this->session_cookie_domain = !empty($GLOBALS['cookie_domain']) ? $GLOBALS['cookie_domain'] : '';
        $this->session_cookie_secure = !empty($GLOBALS['cookie_secure']) ? $GLOBALS['cookie_secure'] : false;
 
 
        $this->session_name = $session_name;
        $this->session_table = $session_table;
        $this->session_data_table = $session_data_table;
 
        $this->db = &$db;
 
        $this->_ip = real_ip();
        $this->_time = time();
 
        $this->session_id = $session_id == '' && !empty($_COOKIE[$this->session_name]) ? $_COOKIE[$this->session_name] : $session_id;
        if ($this->session_id) {
            $tmp_session_id = substr($this->session_id, 0, 32);
            if ($this->gen_session_key($tmp_session_id) == substr($this->session_id, 32)) {
                $this->session_id = $tmp_session_id;
            } else {
                $this->session_id = '';
            }
        }
 
 
        if ($this->session_id) {
            $this->load_session();
        } else {
            $this->gen_session_id();
            setcookie($this->session_name, $this->session_id . $this->gen_session_key($this->session_id), 0, $this->session_cookie_path, $this->session_cookie_domain, $this->session_cookie_secure);
        }
 
        register_shutdown_function(array(&$this, 'close_session'));
    }
 
    public function gen_session_id()
    {
        $this->session_id = md5(uniqid(mt_rand(), true));
 
        return $this->insert_session();
    }
 
    public function gen_session_key($session_id)
    {
        static $ip = '';
 
        if ($ip == '') {
            $ip = substr($this->_ip, 0, strrpos($this->_ip, '.'));
        }
 
        return sprintf('%08x', crc32(ROOT_PATH . $ip . $session_id));
    }
 
    public function insert_session()
    {
        return $this->db->exec('INSERT INTO ' . $this->session_table . " (sesskey, expiry, ip, data) VALUES ('" . $this->session_id . "', '" . $this->_time . "', '" . $this->_ip . "', 'a:0:{}')");
    }
 
    public function load_session()
    {
        $session = $this->db->getOne('SELECT userid, adminid, user_name, user_rank, discount, email, data, expiry FROM ' . $this->session_table . " WHERE sesskey = '" . $this->session_id . "'");
        if (empty($session)) {
            $this->insert_session();
 
            $this->session_expiry = 0;
            $this->session_md5 = '40cd750bba9870f18aada2478b24840a';
            $_SESSION = array();
        } else {
            if (!empty($session['data']) && $this->_time - $session['expiry'] <= $this->max_life_time) {
                $this->session_expiry = $session['expiry'];
                $this->session_md5 = md5($session['data']);
                $_SESSION = unserialize($session['data']);
                $_SESSION['user_id'] = $session['userid'];
                $_SESSION['admin_id'] = $session['adminid'];
                $_SESSION['user_name'] = $session['user_name'];
                $_SESSION['user_rank'] = $session['user_rank'];
                $_SESSION['discount'] = $session['discount'];
                $_SESSION['email'] = $session['email'];
            } else {
                $session_data = $this->db->getOne('SELECT data, expiry FROM ' . $this->session_data_table . " WHERE sesskey = '" . $this->session_id . "'");
                if (!empty($session_data['data']) && $this->_time - $session_data['expiry'] <= $this->max_life_time) {
                    $this->session_expiry = $session_data['expiry'];
                    $this->session_md5 = md5($session_data['data']);
                    $_SESSION = unserialize($session_data['data']);
                    $_SESSION['user_id'] = $session['userid'];
                    $_SESSION['admin_id'] = $session['adminid'];
                    $_SESSION['user_name'] = $session['user_name'];
                    $_SESSION['user_rank'] = $session['user_rank'];
                    $_SESSION['discount'] = $session['discount'];
                    $_SESSION['email'] = $session['email'];
                } else {
                    $this->session_expiry = 0;
                    $this->session_md5 = '40cd750bba9870f18aada2478b24840a';
                    $_SESSION = array();
                }
            }
        }
    }
 
    public function update_session()
    {
        $adminid = !empty($_SESSION['admin_id']) ? intval($_SESSION['admin_id']) : 0;
        $userid = !empty($_SESSION['user_id']) ? intval($_SESSION['user_id']) : 0;
        $user_name = !empty($_SESSION['user_name']) ? trim($_SESSION['user_name']) : 0;
        $user_rank = !empty($_SESSION['user_rank']) ? intval($_SESSION['user_rank']) : 0;
        $discount = !empty($_SESSION['discount']) ? round($_SESSION['discount'], 2) : 0;
        $email = !empty($_SESSION['email']) ? trim($_SESSION['email']) : 0;
        unset($_SESSION['admin_id']);
        unset($_SESSION['user_id']);
        unset($_SESSION['user_name']);
        unset($_SESSION['user_rank']);
        unset($_SESSION['discount']);
        unset($_SESSION['email']);
 
        $data = serialize($_SESSION);
        $this->_time = time();
 
        if ($this->session_md5 == md5($data) && $this->_time < $this->session_expiry + 10) {
            return true;
        }
 
        $data = addslashes($data);
 
        if (isset($data{255})) {
 
            $this->db->autoReplace($this->session_data_table, array('sesskey' => $this->session_id, 'expiry' => $this->_time, 'data' => $data), array('expiry' => $this->_time, 'data' => $data));
            $data = '';
        }
 
        return $this->db->exec('UPDATE ' . $this->session_table . " SET expiry = '" . $this->_time . "', ip = '" . $this->_ip . "', userid = '" . $userid . "', adminid = '" . $adminid . "', user_name='" . $user_name . "', user_rank='" . $user_rank . "', discount='" . $discount . "', email='" . $email . "', data = '$data' WHERE sesskey = '" . $this->session_id . "' LIMIT 1");
    }
 
    public function close_session()
    {
        $this->update_session();
 
        if (mt_rand(0, 2) == 2) {
            $this->db->query('DELETE FROM ' . $this->session_data_table . ' WHERE expiry < ' . ($this->_time - $this->max_life_time));
        }
 
        if ((time() % 2) == 0) {
            return $this->db->query('DELETE FROM ' . $this->session_table . ' WHERE expiry < ' . ($this->_time - $this->max_life_time));
        }
 
        return true;
    }
 
    public function delete_spec_admin_session($adminid)
    {
        if (!empty($_SESSION['admin_id']) && $adminid) {
            return $this->db->query('DELETE FROM ' . $this->session_table . " WHERE adminid = '$adminid'");
        }
 
        return false;
    }
 
    public function destroy_session()
    {
        $_SESSION = array();
 
        setcookie($this->session_name, $this->session_id, 1, $this->session_cookie_path, $this->session_cookie_domain, $this->session_cookie_secure);
 
 
        $this->db->query('DELETE FROM ' . $this->session_data_table . " WHERE sesskey = '" . $this->session_id . "' LIMIT 1");
 
        return $this->db->query('DELETE FROM ' . $this->session_table . " WHERE sesskey = '" . $this->session_id . "' LIMIT 1");
    }
 
    public function get_session_id()
    {
        return $this->session_id;
    }
 
    public function get_users_count()
    {
        return $this->db->getOne('SELECT count(*) FROM ' . $this->session_table);
    }
 
}
 
 
?>
 
db.php
 
 
 
<?php
class db{
    protected $pdo;
    public function __construct($dsn,$user,$pwd,$opt=''){
        $this->pdo= new PDO($dsn,$user,$pwd,$opt);
    }
    public function getRow($sql, $limited = false){
        $sql=$limited==true?trim($sql . ' LIMIT 1'):$sql;
 
        $pdo_statement = $this->pdo->query($sql);
 
        if($pdo_statement){
            $res=$pdo_statement->fetchAll(PDO::FETCH_ASSOC);
            if($limited) return $res[0];
            return $res;
        }
        return false;
    }
    public function getOne($sql){
        $sql=trim($sql . ' LIMIT 1');
        $pdo_statement = $this->pdo->query($sql);
        if($pdo_statement){
            $res=$pdo_statement->fetch(PDO::FETCH_ASSOC);
            return $res;
        }
        return false;
    }
 
    public function autoReplace($table, $field_values, $update_values, $where = '')
    {
        $field_descs = $this->getAll('DESC ' . $table);
 
        $primary_keys = array();
        foreach ($field_descs AS $value)
        {
            $field_names[] = $value['Field'];
            if ($value['Key'] == 'PRI')
            {
                $primary_keys[] = $value['Field'];
            }
        }
 
        $fields = $values = array();
        foreach ($field_names AS $value)
        {
            if (array_key_exists($value, $field_values) == true)
            {
                $fields[] = $value;
                $values[] = "'" . $field_values[$value] . "'";
            }
        }
 
        $sets = array();
        foreach ($update_values AS $key => $value)
        {
            if (array_key_exists($key, $field_values) == true)
            {
                if (is_int($value) || is_float($value))
                {
                    $sets[] = $key . ' = ' . $key . ' + ' . $value;
                }
                else
                {
                    $sets[] = $key . " = '" . $value . "'";
                }
            }
        }
 
        $sql = '';
        if (empty($primary_keys))
        {
            if (!empty($fields))
            {
                $sql = 'INSERT INTO ' . $table . ' (' . implode(', ', $fields) . ') VALUES (' . implode(', ', $values) . ')';
            }
        }
        else
        {
            if (empty($where))
            {
                $where = array();
                foreach ($primary_keys AS $value)
                {
                    if (is_numeric($value))
                    {
                        $where[] = $value . ' = ' . $field_values[$value];
                    }
                    else
                    {
                        $where[] = $value . " = '" . $field_values[$value] . "'";
                    }
                }
                $where = implode(' AND ', $where);
            }
 
            if ($where && (!empty($sets) || !empty($fields)))
            {
                $count=$this->getOne("SELECT COUNT(*)  as count FROM $table WHERE $where");
                $count=$count['count'];
                if (intval($count) > 0)
                {
                    if (!empty($sets))
                    {
                        $sql = 'UPDATE ' . $table . ' SET ' . implode(', ', $sets) . ' WHERE ' . $where;
                    }
                }
                else
                {
                    if (!empty($fields))
                    {
                        $sql = 'REPLACE INTO ' . $table . ' (' . implode(', ', $fields) . ') VALUES (' . implode(', ', $values) . ')';
                    }
                }
            }
 
        }
 
        return $sql?$this->exec($sql):false;
 
    }
    public function getAll($sql)
    {
        $res = $this->pdo->query($sql);
        if ($res !== false)
        {
            $arr = array();
            while ($row = $res->fetch(PDO::FETCH_ASSOC))
            {
                $arr[] = $row;
            }
 
            return $arr;
        }
        return false;
    }
 
    public function __call($method,$args){
 
        return call_user_func(array($this->pdo,$method),$args[0]);
    }
}
 
fun.php
 
 
 
<?php
 
function real_ip()
{
    static $realip = NULL;
 
    if ($realip !== NULL) {
        return $realip;
    }
 
    if (isset($_SERVER)) {
        if (isset($_SERVER['HTTP_X_FORWARDED_FOR'])) {
            $arr = explode(',', $_SERVER['HTTP_X_FORWARDED_FOR']);
 
            /* 取X-Forwarded-For中第一个非unknown的有效IP字符串 */
            foreach ($arr AS $ip) {
                $ip = trim($ip);
 
                if ($ip != 'unknown') {
                    $realip = $ip;
 
                    break;
                }
            }
        } elseif (isset($_SERVER['HTTP_CLIENT_IP'])) {
            $realip = $_SERVER['HTTP_CLIENT_IP'];
        } else {
            if (isset($_SERVER['REMOTE_ADDR'])) {
                $realip = $_SERVER['REMOTE_ADDR'];
            } else {
                $realip = '0.0.0.0';
            }
        }
    } else {
        if (getenv('HTTP_X_FORWARDED_FOR')) {
            $realip = getenv('HTTP_X_FORWARDED_FOR');
        } elseif (getenv('HTTP_CLIENT_IP')) {
            $realip = getenv('HTTP_CLIENT_IP');
        } else {
            $realip = getenv('REMOTE_ADDR');
        }
    }
 
    preg_match("/[\d\.]{7,15}/", $realip, $onlineip);
    $realip = !empty($onlineip[0]) ? $onlineip[0] : '0.0.0.0';
 
    return $realip;
}
 
init.php
 
 
 
<?php
define("ROOT_PATH",__DIR__);
include "db.php";
include "fun.php";
include "cls_session.php";
$dsn='mysql:dbname=test;host=127.0.0.1';
$user="root";
$passwd="";
$opt=array(
    PDO :: ATTR_PERSISTENT  =>  true
);
$db=new db($dsn,$user,$passwd,$opt);
 
 
$cls=new cls_session($db,'sessions',"sessions_data");
复制代码
下面是2个运行测试程序
 
set.php
 
 
 
<?php
include "init.php";
$_SESSION['a']="aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaajax";
//$_SESSION['b']="aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaajax11212312333333333333333333333333333333333333333333333333333333333333333";
//$_SESSION['c']="aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaajax11212312333333333333333333333333333333333333333333333333333333333333333";
//$_SESSION['d']="aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaajax11212312333333333333333333333333333333333333333333333333333333333333333";
//$_SESSION['e']="aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaajax11212312333333333333333333333333333333333333333333333333333333333333333";
//$_SESSION['f']="aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaajax11212312333333333333333333333333333333333333333333333333333333333333333";
//$_SESSION['g']="aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaajax11212312333333333333333333333333333333333333333333333333333333333333333";
$_SESSION['h']="aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaajax11212312333333333333333333333333333333333333333333333333333333333333333";
$_SESSION['i']="aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaajax11212312333333333333333333333333333333333333333333333333333333333333333";
unset($_SESSION['b']);
unset($_SESSION['c']);
unset($_SESSION['d']);
unset($_SESSION['e']);
unset($_SESSION['f']);
//unset($_SESSION['h']);
//unset($_SESSION['i']);
unset($_SESSION['g']);
var_dump($_SESSION);
复制代码
get.php
 
 
<?php
 
include "init.php";
var_dump($_SESSION);
最重要的是cls_session.php
 
session存库 有利于统计当前网站在线用户
 
因为ecshop至始至终没用session_start,session的存取还是和以前一样直接操作$_SESSION数组，所以，如果原来的session是存在文件里,现在可以不修改代码的使用这种方式
 
 
(责任编辑：好模板)
顶一下
(0)
0%
踩一下
(1)
100%
------分隔线----------------------------
栏目列表
热点内容
随机内容
随机模板
CopyRight © 2010-2023 乐道主机 All Rights Reserved.