SESSION管理类库 可交SESSION存储到数据库,memcached,文件,按目录存储文件
源码
<?php /** * PHP中文网 -> hoojar studio * * 模块: wcore/session.php * 简述: 专门处理SESSION的库 * 作者: liuqi -> * 版本: $Id: session.php 1 2012-11-20 05:55:12Z Administrator $ * 版权:PHP中文网 * */ class wcore_session { /** * SESSION数组 * * @var array */ public $data = array(); /** * 将SESSION存储在哪种物质类型中 * * @var string 存储方式如下 * db max:65535 会话内容存储在数据库表中 * mdb max:255 会话内容存储在数据库内存表中 * mem max:unlimit 会话内容存储在Memcache缓存中 * file max:unlimit 会话内容存储在文件中 * dir max:unlimit 会话内容存储在分目录的文件中 */ private $_type = 'file'; /** * 当存储方式为file或dir时SESSION文件所存储的路径 * * @var string 会话文件存储路径 */ private $_path = '/tmp'; /** * 连接数据的模块对象 * * @var wcore_mysql */ private $_db = null; /** * 当SESSION存储在数据库中时要操作的数据表 * * @var string 数据库表名称 (分普通表[session_wcore]与内存表[session_mem]) */ private $_opt = 'session_wcore'; /** * 连接MEM的模块对象 * * @var wcore_mem */ private $_mem = null; /** * SESSION的寿命,默认为30分钟以秒为单位 * * @var integer */ private $_life_time = 1800; /** * SESSION 前缀 * * @var string */ private $_prefix = 'ws'; /** * IP地址 * * @var integer */ private $_ip = ''; /** * 初始化SESSION * * @param string $type 会话的存储方式 * @param integer $ltime 会话寿命时间以分钟为单位 * @param string $path 会话文件存储的路径 * @param string $prefix 会话文件前缀 * @param boolean $start 是否马上启用SESSION处理 */ public function __construct($type = 'file', $ltime = 30, $path = '', $prefix = 'ws', $start = true) { $this->_prefix = $prefix; $this->_type = strtolower($type); if ($this->_type == 'file' || $this->_type == 'dir') { $this->_path = ($path && file_exists($path)) ? $path : get_cfg_var('session.save_path'); wcore_fso::make_dir($this->_path); //处理SESSION存储的路径 } $this->_life_time = ($ltime && is_numeric($ltime)) ? $ltime * 60 : get_cfg_var('session.gc_maxlifetime'); $this->_ip = wcore_utils::get_ip(); session_set_save_handler(array(&$this, 'open'), array(&$this, 'close'), array(&$this, 'read'), array(&$this, 'write'),array(&$this, 'destroy'), array(&$this, 'gc')); register_shutdown_function('session_write_close'); /** * 是否马上启用SESSION处理 */ if ($start) { ini_set('session.use_cookies', 'On'); ini_set('session.use_trans_sid', 'Off'); session_set_cookie_params(0, '/'); session_start(); } $this->data = & $_SESSION; } /** * 打开 SESSION * * @param string $path 会话存储路径 * @param string $name 会话名称 * @return boolean */ public function open($path, $name) { if ($this->_type == 'db' || $this->_type == 'mdb') //以数据库方式来处理SESSION { $this->_db = wcore_object::mdb(); if ($this->_type == 'mdb') { $this->_opt = 'session_mem'; } } else if ($this->_type == 'mem') //以Memcache缓冲方式来处理SESSION { $this->_mem = wcore_object::mem(); $this->_mem->expire = $this->_life_time / 60; } $this->gc(0); //删除失效的SESSION return true; } /** * 关闭SESSION * * @return boolean */ public function close() { return true; } /** * 获取SESSION编号 * * @return string */ public function get_id() { return session_id(); } /** * 读取SESSION内容 * * @param string $sid 会话唯一标识 * @return string 会话值 */ public function read($sid) { /** * 以数据库方式来处理SESSION */ if ($this->_type == 'db' || $this->_type == 'mdb') { $res = $this->_db->fetch_row("SELECT sData FROM {$this->_opt} WHERE sId = '{$sid}';"); return ($res) ? $res['sData'] : ''; } /** * 以Memcache缓冲方式来处理SESSION */ if ($this->_type == 'mem') { return $this->_mem->get('session', $sid); } /** * 以文件系统的方式来处理SESSION */ if ($this->_type == 'dir') { $sfile = "{$this->_path}/{$sid[0]}/{$this->_prefix}-{$sid}"; } else { $sfile = "{$this->_path}/{$this->_prefix}-{$sid}"; } if (!file_exists($sfile)) { return ''; } return (string)file_get_contents($sfile); } /** * 写入SESSION内容 * * @param string $sid 会话唯一标识 * @param string $sdata 会话内容 * @return boolean */ public function write($sid, $sdata) { /** * SESSION数据为空则清除先前数据 */ if (empty($sdata)) { $this->destroy($sid); return false; } /** * 以数据库方式来处理SESSION */ if ($this->_type == 'db' || $this->_type == 'mdb') { $expires = time() + $this->_life_time; //SESSION的有效期 $sql = "REPLACE INTO {$this->_opt} (sId, sData, sIp, sExpires) VALUES ('{$sid}', '{$sdata}', '{$this->_ip}', {$expires})"; $this->_db->query($sql); return ($this->_db->affected_rows() > 0) ? true : false; } /** * 以Memcache缓冲方式来处理SESSION */ if ($this->_type == 'mem') { $expires = $this->_life_time / 60; //SESSION的有效期 return $this->_mem->set('session', $sid, $sdata, $expires); } /** * 以文件系统的方式来处理SESSION */ if ($this->_type == 'dir') { $sfile = "{$this->_path}/{$sid[0]}"; wcore_fso::make_dir($sfile); //处理SESSION存储的路径 $sfile = "{$sfile}/{$this->_prefix}-{$sid}"; } else { $sfile = "{$this->_path}/{$this->_prefix}-{$sid}"; } return file_put_contents($sfile, $sdata); } /** * 清除SESSION * * @param string $sid 会话唯一标识 * @return boolean 清除成功返回true否则为false */ public function destroy($sid = '') { if (empty($sid)) { $sid = $this->get_id(); } /** * 以数据库方式来处理SESSION */ if ($this->_type == 'db' || $this->_type == 'mdb') { $this->_db->query("DELETE FROM {$this->_opt} WHERE sId = '{$sid}'"); return ($this->_db->affected_rows() > 0) ? true : false; } /** * 以Memcache缓冲方式来处理SESSION */ if ($this->_type == 'mem') { return $this->_mem->del('session', $sid); } /** * 以文件系统的方式来处理SESSION */ if ($this->_type == 'dir') { $sfile = "{$this->_path}/{$sid[0]}/{$this->_prefix}-{$sid}"; } else { $sfile = "{$this->_path}/{$this->_prefix}-{$sid}"; } return !empty($sfile) ? @unlink($sfile) : true; } /** * 定时去清除过期的SESSION * * @param integer $max_life_time * @return boolean */ public function gc($max_life_time) { if ($this->_type == 'db' || $this->_type == 'mdb') //以数据库方式来处理SESSION { $this->_db->query("DELETE FROM {$this->_opt} WHERE sExpires < " . time()); } else if ($this->_type == 'file') //以文件系统的方式来处理SESSION { self::kill_sfile($this->_path); } else if ($this->_type == 'dir') //以目录分层文件的方式来处理SESSION { $dir = 'abcdefghijklmnopqrstuvwxyz'; $len = strlen($dir); for ($i = 0; $i < $len; ++$i) { self::kill_sfile("{$this->_path}/{$dir[$i]}"); } } return true; } /** * 删除session文件 * * @param string $dir 会话文件所在目录 * @param boolean $no_check 是否进行过期判断 * @return boolean */ private function kill_sfile($dir, $no_check = false) { if ($no_check) //直接删除SESSION文件不进行过期判断 { foreach (glob("{$dir}/{$this->_prefix}-*") as $filename) { @unlink($filename); } return true; } foreach (glob("{$dir}/{$this->_prefix}-*") as $filename) { if (filemtime($filename) + $this->_life_time < time()) { @unlink($filename); } } return true; } /** * 清空所有SESSION * * @return boolean */ public function cleanup() { switch ($this->_type) { case 'mem': return $this->_mem->flush(); case 'db': case 'mdb': return $this->_db->truncate($this->_opt); case 'file': return self::kill_sfile($this->_path, true); case 'dir': $dir = 'abcdefghijklmnopqrstuvwxyz'; $len = strlen($dir); for ($i = 0; $i < $len; ++$i) { wcore_fso::rm_dir($dir[$i]); } default: return true; } } } ?>