当前位置：Gxlcms > PHP教程 > 一个用mysql内存表来代替phpsession的类

一个用mysql内存表来代替phpsession的类

时间：2021-07-01 10:21:17 帮助过：27人阅读

  2. /**
  3. * session mysql内存表
  4. @Usage: use some other storage method(mysql or memcache) instead of php sessoin
  5. @author:lein
  6. @Version:1.2
  7. */
  8. session_start();
  9. if(!isset($_SESSION['test'])){
  10. $_SESSION['test']="123_lein_".date("Y-m-d H:i:s");
  11. }
  13. class session{
  14. //session data
  15. private $data;
  16. //engine,mysql or memcache
  17. private $engine;
  18. //php session expire time
  19. private $sessionexpiredTime;
  20. //current user's session cookie value
  21. private $sessionID;
  22. //session coolie name
  23. private $sessionCookieName;
  24. public function session($engineBase=NULL,$engineName='mysql',$storage_name='php_session'){
  25. try{
  26. $this->sessionexpiredTime = intval(ini_get("session.cache_expire"))*10;//默认是180分钟，太长了，改为了30分钟
  27. }catch(Exception $Exception){
  28. $this->sessionexpiredTime = 1200;
  29. }
  30. try{
  31. $this->sessionCookieName = ini_get("session.name");
  32. }catch(Exception $Exception){
  33. $this->sessionCookieName = 'PHPSESSID';
  34. }
  36. if(!isset($_COOKIE[$this->sessionCookieName])){
  37. @session_start();
  38. $this->sessionID=session_id();
  39. }else{
  40. $this->sessionID=$_COOKIE[$this->sessionCookieName];
  41. }
  42. $className = $engineName."SessionEngine";
  43. $this->engine = new $className(
  44. array(
  45. 'storage_name'=>$storage_name,//mysql table name or memcahce key which stores data;
  46. 'expire_time'=>$this->sessionexpiredTime,
  47. 'data_too_long_instead_value' => '{__DATA IS *$* TO LONG__}'
  48. ),
  49. $this->sessionID,
  50. &$engineBase
  51. );
  52. $this->init();
  53. $this->loadFromSession();
  54. $this->engine->refresh();
  55. $this->engine->cleanup();
  56. }
  57. private function init()
  58. {
  59. $this->data = $this->engine->get();
  60. if(empty($this->data)){
  61. @session_start();
  62. if(!empty($_SESSION)){
  63. $this->data = $_SESSION;
  64. $this->engine->create(false, $this->data);
  65. }
  66. else
  67. {
  68. $this->engine->create(false, "");
  69. }
  70. }
  71. }
  72. public function loadFromSession($flagStartSession = false){
  73. $flag=false;
  74. if($flagStartSession){
  75. @session_start();
  76. }
  77. if($_SESSION&&is_array($_SESSION)){
  78. foreach($_SESSION as $k=>$v){
  79. if(!isset($this->data[$k])){
  80. $this->data[$k] = $v;
  81. $flag=true;
  82. }
  83. }
  84. }
  85. if($flag){
  86. $this->engine->set(false, $this->data);
  87. }
  88. }
  89. private function __get($nm)
  90. {
  91. if (isset($this->data[$nm])) {
  92. $r = $this->data[$nm];
  93. return $r;
  94. }
  95. else
  96. {
  97. return NULL;
  98. }
  99. }
  100. private function __set($nm, $val)
  101. {
  102. $this->data[$nm] = $val;
  103. $this->engine->set(false, $this->data);
  104. }
  106. private function __isset($nm)
  107. {
  108. return isset($this->data[$nm]);
  109. }
  111. private function __unset($nm)
  112. {
  113. unset($this->data[$nm]);
  114. $this->engine->set(false, $this->data);
  115. }
  117. function __destruct(){
  118. $this->data = NULL;
  119. $this->engine->close();
  120. $this->engine = NULL;
  121. }
  122. }
  124. interface SessionEngine
  125. {
  126. /*
  127. * set varibles
  128. * @param $arr array,array(varible name=>varible value,...)
  129. */
  130. public function setVariable($arr);
  131. /*
  132. * get session value
  133. * @param $key string
  134. */
  135. public function get($key="");
  136. /*
  137. * set session value
  138. * @param $key string
  139. * @param $value string
  140. */
  141. public function set($key="",$value="");
  142. /*
  143. * set session value
  144. * @param $key string
  145. * @param $value string
  146. */
  147. public function create($key="",$value="");
  148. /*
  149. * update the session's invalid time
  150. * @param $key string
  151. */
  152. public function refresh($key="");
  153. /*
  154. * close mysql or memcache connection
  155. */
  156. public function close();
  157. /*
  158. * delete expired sessions
  159. */
  160. public function cleanup();
  161. }
  163. final class mysqlSessionEngine implements SessionEngine{
  164. private $id="";
  165. private $storage_name='php_session';
  166. private $storage_name_slow='php_session_slow';
  167. private $data_too_long_instead_value = '{__DATA IS ~ TO LONG__}';//if data is longer than $max_session_data_length and you are using mysql 4 or below,insert this value into memery table instead.
  168. private $expire_time=1200;
  169. private $max_session_data_length = 2048;
  170. private $conn;
  171. private $mysql_version;
  172. public function mysqlSessionEngine($arr=array(),$key="",&$_conn){
  173. $this->setVariable($arr);
  174. $this->id = $key;
  175. if(empty($this->id)||strlen($this->id)!=32){
  176. throw new Exception(__FILE__."->".__LINE__.": Session's cookie name can't be empty and it must have just 32 charactors!");
  177. }
  178. $this->conn = $_conn;
  179. if(!$this->conn||!is_resource($this->conn)){
  180. throw new Exception(__FILE__."->".__LINE__.": Need a mysql connection!");
  181. }
  182. $this->mysql_version = $this->getOne("select floor(version())");
  183. if($this->mysql_version<5){
  184. $this->max_session_data_length = 255;
  185. }
  186. }
  187. public function setVariable($arr){
  188. if(!empty($arr)&&is_array($arr)){
  189. foreach($arr as $k=>$v){
  190. $this->$k = $v;
  191. if($k=='storage_name'){
  192. $this->storage_name_slow = $v.'_slow';
  193. }
  194. }
  195. }
  196. }
  197. public function get($key=""){
  198. if($key=="") $key = $this->id;
  199. $return = $this->getOne('select value from '.$this->storage_name.' where id="'.$key.'"');
  200. if($return==$this->data_too_long_instead_value)
  201. {
  202. $return = $this->getOne('select value from '.$this->storage_name_slow.' where id="'.$key.'"');
  203. }
  204. if(!$return)
  205. {
  206. $mysqlError = mysql_error($this->conn);
  207. if(strpos($mysqlError,"doesn't exist")!==false)
  208. {
  209. $this->initTable();
  210. }
  211. $return = array();
  212. }
  213. else
  214. {
  215. $return = unserialize($return);
  216. }
  217. return $return;
  218. }
  219. public function close(){
  220. @mysql_close($this->conn);
  221. }
  222. public function cleanup(){
  223. if($this->mysql_version>4){
  224. $sql = 'delete from '.$this->storage_name.' where date_add(`time`,INTERVAL '.$this->expire_time.' SECOND) }else{
  225. $sql = 'delete from '.$this->storage_name_slow.' where `time`+'.$this->expire_time.' if($_SESSION['username']=="leinchu"){
  226. echo $sql;
  227. }
  228. $this->execute($sql);
  229. $sql = 'delete from '.$this->storage_name.' where `time`+'.$this->expire_time.' if($_SESSION['username']=="leinchu"){
  230. echo $sql;
  231. }
  232. }
  233. $this->execute($sql);
  234. }
  235. public function refresh($key=""){
  236. if($this->mysql_version>4){
  237. $sql = 'update '.$this->storage_name.' set `time`=CURRENT_TIMESTAMP() where id="'.$key.'"';
  238. }else{
  239. $sql = 'update '.$this->storage_name.' set `time`=unix_timestamp() where id="'.$key.'"';
  240. }
  241. $return = $this->execute($sql);
  242. if(!$return){
  243. $this->initTable();
  244. $return = $this->execute($sql,true);
  245. }
  246. return $return;
  247. }
  248. public function create($key="",$value=""){
  249. if($key=="") $key = $this->id;
  250. if($value != "") $value = mysql_real_escape_string(serialize($value),$this->conn);
  251. if(strlen($value)>$this->max_session_data_length)
  252. {
  253. if($this->mysql_version>4){
  254. throw new Exception(__FILE__."->".__LINE__.": Session data is long than max allow length(".$this->max_session_data_length.")!");
  255. }
  256. }
  257. if($this->mysql_version>4){
  258. $sql = 'replace into '.$this->storage_name.' set value=/''.$value.'/',id="'.$key.'",`time`=CURRENT_TIMESTAMP()';
  259. }else{
  260. $sql = 'replace into '.$this->storage_name.' set value=/''.$value.'/',id="'.$key.'",`time`=unix_timestamp()';
  261. }
  262. $return = $this->execute($sql);
  263. if(!$return){
  264. $this->initTable();
  265. $return = $this->execute($sql,true);
  266. }
  267. return $return;
  268. }
  269. public function set($key="",$value=""){
  270. if($key=="") $key = $this->id;
  271. if($value != "") $value = mysql_real_escape_string(serialize($value),$this->conn);
  272. $sql = 'update '.$this->storage_name.' set value=/''.$value.'/' where id="'.$key.'"';
  273. if(strlen($value)>$this->max_session_data_length)
  274. {
  275. if($this->mysql_version>4){
  276. throw new Exception(__FILE__."->".__LINE__.": Session data is long than max allow length(".$this->max_session_data_length.")!");
  277. }
  278. $sql = 'replace into '.$this->storage_name_slow.' set value=/''.$value.'/',id="'.$key.'",`time`=unix_timestamp()';
  279. $this->execute($sql,true);
  280. $sql = 'update '.$this->storage_name.' set value=/''.$this->data_too_long_instead_value.'/' where id="'.$key.'"';
  281. }
  282. $return = $this->execute($sql);
  283. if(!$return){
  284. $this->initTable();
  285. $return = $this->execute($sql,true);
  286. }
  287. return $return;
  288. }
  289. private function initTable(){
  290. if($this->mysql_version>4){
  291. $sql = "
  292. CREATE TABLE if not exists `".$this->storage_name."` (
  293. `id` char(32) NOT NULL default 'ERR',
  294. `value` VARBINARY(".$this->max_session_data_length.") NULL,
  295. `time` timestamp NOT NULL default CURRENT_TIMESTAMP on update CURRENT_TIMESTAMP,
  296. PRIMARY KEY (`id`),
  297. KEY `time` (`time`)
  298. ) ENGINE=MEMORY;
  299. ";
  300. }else{
  301. $sqlSlow = "
  302. CREATE TABLE if not exists `".$this->storage_name."_slow` (
  303. `id` char(32) NOT NULL default 'ERR',
  304. `value` text NULL,
  305. `time` int(10) not null default '0',
  306. PRIMARY KEY (`id`),
  307. KEY `time` (`time`)
  308. ) ENGINE=MyISAM;
  309. ";
  310. $this->execute($sqlSlow,true);
  312. $sql = "
  313. CREATE TABLE if not exists `".$this->storage_name."` (
  314. `id` char(32) NOT NULL default 'ERR',
  315. `value` VARCHAR(255) NULL,
  316. `time` int(10) not null default '0',
  317. PRIMARY KEY (`id`),
  318. KEY `time` (`time`)
  319. ) ENGINE=MEMORY;
  320. ";
  321. }
  322. return $this->execute($sql,true);
  323. }
  324. private function execute($sql,$die=false)
  325. {
  326. if($die)
  327. {
  328. mysql_query($sql,$this->conn) or die("exe Sql error:
    ".mysql_error()."
    ".$sql."
    ");
  329. }
  330. else
  331. {
  332. mysql_query($sql,$this->conn);
  333. if(mysql_error()){
  334. return false;
  335. }else{
  336. return true;
  337. }
  338. }
  339. }
  340. private function getOne($sql,$die=false){
  341. $rs = $this->query($sql,$die);
  342. if($rs && ($one = mysql_fetch_row($rs)) ){
  343. return $one[0];
  344. }else{
  345. return false;
  346. }
  347. }
  348. private function query($sql,$die=false){
  349. if($die)
  350. $rs = mysql_query($sql,$this->conn) or die("query Sql error:
    ".mysql_error()."
    ".$sql."
    ");
  351. else
  352. $rs = mysql_query($sql,$this->conn);
  353. return $rs;
  354. }
  355. }
  356. $lnk = mysql_connect('localhost', 'root', '123456')
  357. or die ('Not connected : ' . mysql_error());
  359. // make foo the current db
  360. mysql_select_db('test', $lnk) or die ('Can/'t use foo : ' . mysql_error());
  361. $S = new session($lnk);
  362. if(!$S->last){
  363. $S->last = time();
  364. }
  365. echo "First visit at ".$S->last."
    ";
  366. if(!$S->lastv){
  367. $S->lastv = 0;
  368. }
  369. $S->lastv++;
  370. echo "lastv=".$S->lastv."
    ";
  371. echo "test=".$S->test."
    ";
  372. if(isset($_GET['max'])){
  373. $S->boom = str_repeat("OK",255);
  374. }
  375. if(isset($_GET['boom'])){
  376. $S->boom = $_GET['boom'];
  377. }
  378. echo "boom=".$S->boom."
    ";
  379. ?>

人气教程排行

本站所有资源全部来源于网络，若本站发布的内容侵害到您的隐私或者利益，请联系我们删除！