SESSION管理类库代码,PHP代码库,德仔网

代码语言
代码分类
【PHP】 SESSION管理类库
作者:步山 / 发布于2014/11/10/ 890
SESSION管理类库可交SESSION存储到数据库，memcached，文件，按目录存储文件

	<?php
	/**
	*
	* 模块: wcore/session.php
	* 简述: 专门处理SESSION的库
	*
	*/
	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;
	 }
	 }
	}
	?>
试试其它关键字
　SESSION　
同语言下
可能有用的
步山贡献的其它代码(75)