将Session存储到MySQL中
title = ""
date=
tags=["PHP"]
+++
我们知道，Session是一种会话技术，用来实现跨脚本共享数据。Session是存放在服务器端的文件里的，因此Session有可能因为文件数量过多，会在查询 Session 文件以及读取的时候产生压力。一般我们有三种解决方案
- 使用文件分层（缺点：I/O操作是系统的一个瓶颈，即使分层也不能避免此问题）
- 将session放入数据库
- 将session放在内存中（非关系性数据库）（缺点：对服务器内存要求教高）
将Session存入MySQL数据库，也就是我们要讲的重点（其实并不建议这么做，因为在高并发和大流量的情况下，无疑会增加MySQL的压力，建议放到缓存服务中，如Memcache、Redis），
要实现session入库，首先我们要了解session 机制：
在PHP中，Session 可以理解为一套单独的小系统，在该系统中有很多关于 Session 的处理方法，用来解决各种问题，用户只需要在 Session 之外，调用session_start函数（session系统的一个接口）
其他操作都是session系统帮忙去处理
由图可知我们应该修改session机制中的session的读取和最终的写入。要修改session机制要借助一个系统函数session_set_save_handler():用来使用外部用户定义的函数，来取代session系统本身的函数。
bool session_set_save_handler ( callable $open , callable $close , callable $read , callable $write , callable $destroy , callable $gc [, callable $create_sid [, callable $validate_sid [, callable $update_timestamp ]]] )open(string $savePath, string $sessionName)
open 回调函数类似于类的构造函数， 在会话打开的时候会被调用。 这是自动开始会话或者通过调用 session_start() 手动开始会话 之后第一个被调用的回调函数。 此回调函数操作成功返回 TRUE，反之返回 FALSE。
close()
close 回调函数类似于类的析构函数。 在 write 回调函数调用之后调用。 当调用 session_write_close() 函数之后，也会调用 close 回调函数。 此回调函数操作成功返回 TRUE，反之返回 FALSE。
read(string $sessionId)
如果会话中有数据，read 回调函数必须返回将会话数据编码（序列化）后的字符串。 如果会话中没有数据，read 回调函数返回空字符串。
在自动开始会话或者通过调用 session_start() 函数手动开始会话之后，PHP 内部调用 read 回调函数来获取会话数据。 在调用 read 之前，PHP 会调用 open 回调函数。
read 回调返回的序列化之后的字符串格式必须与 write 回调函数保存数据时的格式完全一致。 PHP 会自动反序列化返回的字符串并填充$_SESSION 超级全局变量。 虽然数据看起来和 serialize() 函数很相似， 但是需要提醒的是，它们是不同的。 请参考：session.serialize_handler。
write(string $sessionId, string $data)
在会话保存数据时会调用 write 回调函数。 此回调函数接收当前会话 ID 以及 $_SESSION 中数据序列化之后的字符串作为参数。 序列化会话数据的过程由 PHP 根据 session.serialize_handler 设定值来完成。
序列化后的数据将和会话 ID 关联在一起进行保存。 当调用 read 回调函数获取数据时，所返回的数据必须要和 传入 write 回调函数的数据完全保持一致。
PHP 会在脚本执行完毕或调用 session_write_close() 函数之后调用此回调函数。 注意，在调用完此回调函数之后，PHP 内部会调用 close回调函数。
Note:
PHP 会在输出流写入完毕并且关闭之后 才调用 write 回调函数， 所以在 write 回调函数中的调试信息不会输出到浏览器中。 如果需要在 write 回调函数中使用调试输出， 建议将调试输出写入到文件。
destroy($sessionId)
当调用 session_destroy() 函数， 或者调用 session_regenerate_id() 函数并且设置 destroy 参数为 TRUE 时， 会调用此回调函数。此回调函数操作成功返回 TRUE，反之返回 FALSE。
gc($lifetime)
为了清理会话中的旧数据，PHP 会不时的调用垃圾收集回调函数。 调用周期由 session.gc_probability 和 session.gc_divisor 参数控制。 传入到此回调函数的 lifetime 参数由 session.gc_maxlifetime 设置。 此回调函数操作成功返回 TRUE，反之返回 FALSE。
create_sid()
当需要新的会话 ID 时被调用的回调函数。 回调函数被调用时无传入参数， 其返回值应该是一个字符串格式的、有效的会话 ID。
因此我们要准备六个函数。
代码实现：
<?php
//session入库
//以为修改session机制必须借助session_set_save_handler()函数，该函数需要6个可以调用的回调函数，因此需要创建6个人对应的函数
//1.开启session机制
function sess_open() {
//开启资源
//连接数据库
mysql_connect('localhost','root','');
mysql_query('set names utf8');
mysql_query('use session');
echo FUNCTION,'<br/>';
}
//2.关闭session
function sess_close() {
//关闭资源
mysql_close();
echo FUNCTION,'<br/>';
}
//3.读取session
function sess_read($sess_id) {
//从数据库读取数据
//根据sess_id（由系统提供）获取数据
//读数据时要过滤掉过期的数据
$expire=time()-ini_get('session.gc_maxlifetime');
$sql="selsct * from session where sess_id='{$sess_id}' and sess_expire>='{$expire}'";
res=mysql_query(sql);
//得到的是一个数组
if(sess=@mysql_fetch_assoc(res)) {
//得到一个序列化后的字符串
//要进行反序列化，read只负责读取数据，不负责加工数据
return $sess['sess_info'];
}
echo FUNCTION,'<br/>';
}
//4.写入session
function sess_write(sess_id,sess_info) {
//向数据库中写入数据
$time=time();
$sql="replace into session values('{$sess_id}','{$sess_info}','{$time}')";
mysql_query($sql);
echo FUNCTION,'<br/>';
}
//5.销毁session
function sess_destroy($sess_id) {
$sql="delete from session where sess_id='{$sess_id}'";
return mysql_query($sql);
}
//6.回收session
function sess_gc() {
//从数据库删除过期的session数据
//判断session是否过期，过期的删除
$expire=ini_get('session.gc_maxlifetime');
//得到最迟的时间，在$expire之前的都是过期的
expire=time()-expire;
$sql="delete from session where sess_expire < '{expire}'";
return mysql_query($sql);
}
//使用session_set_save_handler()修改session机制
session_set_save_handler('sess_open','sess_close','sess_read','sess_write','sess_destroy','sess_gc');
//想要使用session，必须要用session_start()来开启
session_start();
$_SESSION['name']='wangqixing';
$_SESSION['age']='23';
//session_destroy();
