SESSION管理类库-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 = &＃39;file&＃39;;

	/**
	 * 当存储方式为file或dir时SESSION文件所存储的路径
	 *
	 * @var string 会话文件存储路径
	 */
	private $_path = &＃39;/tmp&＃39;;

	/**
	 * 连接数据的模块对象
	 *
	 * @var wcore_mysql
	 */
	private $_db = null;

	/**
	 * 当SESSION存储在数据库中时要操作的数据表
	 *
	 * @var string 数据库表名称 (分普通表[session_wcore]与内存表[session_mem])
	 */
	private $_opt = &＃39;session_wcore&＃39;;

	/**
	 * 连接MEM的模块对象
	 *
	 * @var wcore_mem
	 */
	private $_mem = null;

	/**
	 * SESSION的寿命，默认为30分钟以秒为单位
	 *
	 * @var integer
	 */
	private $_life_time = 1800;

	/**
	 * SESSION 前缀
	 *
	 * @var string
	 */
	private $_prefix = &＃39;ws&＃39;;

	/**
	 * IP地址
	 *
	 * @var integer
	 */
	private $_ip = &＃39;&＃39;;

	/**
	 * 初始化SESSION
	 *
	 * @param string  $type   会话的存储方式
	 * @param integer $ltime  会话寿命时间以分钟为单位
	 * @param string  $path   会话文件存储的路径
	 * @param string  $prefix 会话文件前缀
	 * @param boolean $start  是否马上启用SESSION处理
	 */
	public function __construct($type = &＃39;file&＃39;, $ltime = 30, $path = &＃39;&＃39;, $prefix = &＃39;ws&＃39;, $start = true)
	{
		$this->_prefix = $prefix;
		$this->_type   = strtolower($type);
		if ($this->_type == &＃39;file&＃39; || $this->_type == &＃39;dir&＃39;)
		{
			$this->_path = ($path && file_exists($path)) ? $path : get_cfg_var(&＃39;session.save_path&＃39;);
			wcore_fso::make_dir($this->_path); //处理SESSION存储的路径
		}

		$this->_life_time = ($ltime && is_numeric($ltime)) ? $ltime * 60 : get_cfg_var(&＃39;session.gc_maxlifetime&＃39;);
		$this->_ip        = wcore_utils::get_ip();
		session_set_save_handler(array(&$this, &＃39;open&＃39;), array(&$this, &＃39;close&＃39;),		array(&$this, &＃39;read&＃39;),
								 array(&$this, &＃39;write&＃39;),array(&$this, &＃39;destroy&＃39;),	array(&$this, &＃39;gc&＃39;));
		register_shutdown_function(&＃39;session_write_close&＃39;);

		/**
		 * 是否马上启用SESSION处理
		 */
		if ($start)
		{
			ini_set(&＃39;session.use_COOKIEs&＃39;, &＃39;On&＃39;);
			ini_set(&＃39;session.use_trans_sid&＃39;, &＃39;Off&＃39;);
			session_set_COOKIE_params(0, &＃39;/&＃39;);
			session_start();
		}
		$this->data = & $_SESSION;
	}

	/**
	 * 打开 SESSION
	 *
	 * @param string $path 会话存储路径
	 * @param string $name 会话名称
	 * @return boolean
	 */
	public function open($path, $name)
	{
		if ($this->_type == &＃39;db&＃39; || $this->_type == &＃39;mdb&＃39;) //以数据库方式来处理SESSION
		{
			$this->_db = wcore_object::mdb();
			if ($this->_type == &＃39;mdb&＃39;)
			{
				$this->_opt = &＃39;session_mem&＃39;;
			}
		}
		else if ($this->_type == &＃39;mem&＃39;) //以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 == &＃39;db&＃39; || $this->_type == &＃39;mdb&＃39;)
		{
			$res = $this->_db->fetch_row("SELECT sData FROM {$this->_opt} WHERE sId = &＃39;{$sid}&＃39;;");

			return ($res) ? $res[&＃39;sData&＃39;] : &＃39;&＃39;;
		}

		/**
		 * 以Memcache缓冲方式来处理SESSION
		 */
		if ($this->_type == &＃39;mem&＃39;)
		{
			return $this->_mem->get(&＃39;session&＃39;, $sid);
		}

		/**
		 * 以文件系统的方式来处理SESSION
		 */
		if ($this->_type == &＃39;dir&＃39;)
		{
			$sfile = "{$this->_path}/{$sid[0]}/{$this->_prefix}-{$sid}";
		}
		else
		{
			$sfile = "{$this->_path}/{$this->_prefix}-{$sid}";
		}

		if (!file_exists($sfile))
		{
			return &＃39;&＃39;;
		}

		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 == &＃39;db&＃39; || $this->_type == &＃39;mdb&＃39;)
		{
			$expires = time() + $this->_life_time; //SESSION的有效期
			$sql     = "REPLACE INTO {$this->_opt} (sId, sData, sIp, sExpires) VALUES (&＃39;{$sid}&＃39;, &＃39;{$sdata}&＃39;, &＃39;{$this->_ip}&＃39;, {$expires})";
			$this->_db->query($sql);

			return ($this->_db->affected_rows() > 0) ? true : false;
		}

		/**
		 * 以Memcache缓冲方式来处理SESSION
		 */
		if ($this->_type == &＃39;mem&＃39;)
		{
			$expires = $this->_life_time / 60; //SESSION的有效期
			return $this->_mem->set(&＃39;session&＃39;, $sid, $sdata, $expires);
		}

		/**
		 * 以文件系统的方式来处理SESSION
		 */
		if ($this->_type == &＃39;dir&＃39;)
		{
			$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 = &＃39;&＃39;)
	{
		if (empty($sid))
		{
			$sid = $this->get_id();
		}

		/**
		 * 以数据库方式来处理SESSION
		 */
		if ($this->_type == &＃39;db&＃39; || $this->_type == &＃39;mdb&＃39;)
		{
			$this->_db->query("DELETE FROM {$this->_opt} WHERE sId = &＃39;{$sid}&＃39;");

			return ($this->_db->affected_rows() > 0) ? true : false;
		}

		/**
		 * 以Memcache缓冲方式来处理SESSION
		 */
		if ($this->_type == &＃39;mem&＃39;)
		{
			return $this->_mem->del(&＃39;session&＃39;, $sid);
		}

		/**
		 * 以文件系统的方式来处理SESSION
		 */
		if ($this->_type == &＃39;dir&＃39;)
		{
			$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 == &＃39;db&＃39; || $this->_type == &＃39;mdb&＃39;) //以数据库方式来处理SESSION
		{
			$this->_db->query("DELETE FROM {$this->_opt} WHERE sExpires <" . time());
		}
		else if ($this->_type == &＃39;file&＃39;) //以文件系统的方式来处理SESSION
		{
			self::kill_sfile($this->_path);
		}
		else if ($this->_type == &＃39;dir&＃39;) //以目录分层文件的方式来处理SESSION
		{
			$dir = &＃39;abcdefghijklmnopqrstuvwxyz&＃39;;
			$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 _type)
		{
			case &＃39;mem&＃39;:
				return $this->_mem->flush();
			case &＃39;db&＃39;:
			case &＃39;mdb&＃39;:
				return $this->_db->truncate($this->_opt);
			case &＃39;file&＃39;:
				return self::kill_sfile($this->_path, true);
			case &＃39;dir&＃39;:
				$dir = &＃39;abcdefghijklmnopqrstuvwxyz&＃39;;
				$len = strlen($dir);
				for ($i = 0; $i <$len; ++$i)
				{
					wcore_fso::rm_dir($dir[$i]);
				}
			default:
				return true;
		}
	}
}
?>