search

Home >Backend Development >PHP Tutorial >redis/分布式文件存储系统/数据库 存储session，解决负载均衡集群中session不一致问题，redissession_PHP教程

redis/分布式文件存储系统/数据库 存储session，解决负载均衡集群中session不一致问题，redissession_PHP教程

WBOY
WBOYOriginal
2016-07-12 08:59:03944browse

redis/分布式文件存储系统/数据库 存储session，解决负载均衡集群中session不一致问题，redissession

先来说下session和cookie的异同

 

session和cookie不仅仅是一个存放在服务器端，一个存放在客户端那么笼统

session虽然存放在服务器端，但是也需要和客户端相互匹配，试想一个浏览器为啥session总是一样的（过期或者关闭不算），主要得益于在浏览器端有个cook，名字叫"PHPSESSID"这个cookie里面就是一串字符串。这个字符串就是用于标示session的，在使用session时当服务器端发现这个cookie后就会到服务器端session文件存放目录查找名称为"sess_PHPSESSID值" 的文件(没有就创建之), 这个文件里面就是存放的session的一些数据（序列化后的数据）

所以，即使你把这个文件删掉了，下次再使用session它又会重新创建一个同样名称的文件，当然要是把那个cookie给删掉了，那就得重新命名了

session 默认情况下是存放在每台服务器本地目录的，在'php.ini'有相应配置

 

服务器端配置：

session.save_handler = files    (默认为file，定义session在服务端的保存方式，file意为把sesion保存到一个临时文件里，如果我们想自定义别的方式保存，比如数据库之类需设置为'user')

 

session.save_path = "D:/wamp/php/sessiondata/"   (定义服务端存储session的临时文件的位置)

 

session.auto_start = 0  (如置1，则不用在每个文件里写session_start(); session自动start ：)

 

session.gc_probability = 1

session.gc_divisor    = 100

session.gc_maxlifetime = 1440(以上三个构成session的垃圾自动回收机制，session.gc_probability与session.gc_divisor构成执行session清理的概率，理论上的解释为服务端定期有一定的概率调用gc函数来对session进行清理，清理的概率为：gc_probability/gc_divisor 比如：1/100  表示每一个新会话初始化时，有1%的概率会被垃圾回收机制回收，清理的标准为 session.gc_maxlifetime 定义的时间)

 

还有些客户端相关的配置

session.use_cookies = 1  (sessionid在客户端采用的存储方式，置1代表使用cookie记录客户端的sessionid，同时，$_COOKIE变量里才会有$_COOKIE['PHPSESSIONID']这个cookie存在

 

session.use_only_cookies = 1  (也是定义sessionid在客户端采用的存储方式，置1代表仅仅使用 cookie 来存放会话 ID)

 

session.use_trans_sid = 0   (对应于上面那个设置，这里如果置1，则代表允许sessionid通过url参数传递，同理，建议设置成0, 所以这里纠正下一些面试题什么的 禁用cookie是否能够使用session, 答案是当然能够只要把该值设置为1)

 

session.referer_check =   (这个设置在session.use_trans_sid = 1的时候才会生效，目的是检查HTTP头中的"Referer"以判断包含于URL中的会话id是否有效，HTTP_REFERER必须包含这个参数指定的字符串，否则URL中的会话id将被视为无效。所以一般默认为空，即不检查)

 

session.name = PHPSESSID   (定义sessionid的名称，即变量名，所以通过浏览器http工具看到的http头文件里的PHPSESSID=##############)

 

session.cookie_lifetime = 0   (保存sessionid的cookie文件的生命周期，如置0，代表会话结束，则sessionid就自动消失，常见的强行关闭浏览器，就会丢失上一次的sessionid)

 

所以，通过上面我们可以知道，默认情况下session是存放在每台服务器本地的，因此在集群环境下如果要使用session ，如果使用默认配置的话会出问题的,就是刚刚客户访问A服务器session文件存在A上面，但过一会可能会分配给该客户B服务器，这时B服务器上这个文件不存在，数据也就丢失了。

 

即如此，那么解决问题的办法就是把session存放到单独的服务器上，要么数据库，要么redis, 要么文件服务器

笔者这里一一说明设置方法

 

一、使用redis存放session

这个笔者只说最简单的，不采用很多人用的还要写个PHP类规定怎样存放(当然也可以这么做，如果在某些特殊需求情况下)

先修改php.ini 配置

session.save_handler =<span> redis
session.save_path </span>= <span>"</span><span>tcp://127.0.0.1:6379</span><span>"</span>

当然了，也可以在php程序中设置

<span>ini_set</span>('session.save_handler','redis'<span>);
</span><span>ini_set</span>('session.save_path','tcp://127.0.0.1:6379');

如果你的redis里面配置了密码，可以这样设置

session.save_handler = redis
session.save_path = "tcp://127.0.0.1:6379?auth=authpwd"

 

二、使用文件服务器存放session

这个笔者觉得比较简单，笔者公司里面直接把分布式文件服务器挂载到指定目录下，然后访问分布式文件服务器就像访问本地文件夹一样，这里只需要设置下 保存路径即可

session.save_path = <span>"</span><span>xxxx</span><span>"</span>

 

三、使用数据库存放session

这个略显复杂，要写个PHP类，指定如何打开、读取、写入、销毁、GC垃圾回收、关闭，不过笔者不懒还是手动写一个意思意思

<?<span>php 
</span><span>class</span><span> sessionHandler{
    </span><span>/*</span><span>*
    * session 存放的库
    </span><span>*/</span>
    <span>const</span> SESSION_DB = 'mytest'<span>;

    </span><span>/*</span><span>*
    * session 存放的表
    </span><span>*/</span>
    <span>const</span> SESSION_TABLE = 'session'<span>;

    </span><span>/*</span><span>*
    * @var string $_dbHandler 数据库链接句柄
    </span><span>*/</span>
    <span>private</span> <span>$_dbHandler</span><span>;

    </span><span>/*</span><span>*
    * @var string $_dbHost 数据库主机
    </span><span>*/</span>
    <span>private</span> <span>$_dbHost</span><span>;

    </span><span>/*</span><span>*
    * @var string $_dbUser 数据库用户名
    </span><span>*/</span>
    <span>private</span> <span>$_dbUser</span><span>;

    </span><span>/*</span><span>*
    * @var string $_dbUser 数据库密码
    </span><span>*/</span>
    <span>private</span> <span>$_dbPasswd</span><span>;

    </span><span>/*</span><span>*
    * @var string $_name session 名称
    </span><span>*/</span>
    <span>private</span> <span>$_name</span><span>;

    </span><span>/*</span><span>*
    * 构造函数
    * @param string $dbHost 数据库主机
    * @param string $dbUser 数据库用户名
    * @param string $dbPasswd 数据库密码
    * @return void
    </span><span>*/</span>
    <span>public</span> <span>function</span> __construct(<span>$dbHost</span>, <span>$dbUser</span>, <span>$dbPasswd</span><span>)
    {
        </span><span>$this</span>->_dbHost = <span>$dbHost</span><span>;
        </span><span>$this</span>->_dbUser = <span>$dbUser</span><span>;
        </span><span>$this</span>->_dbPasswd = <span>$dbPasswd</span><span>;
    }

    </span><span>/*</span><span>*
    * 链接数据库
    * @param string $savePath 存储路径
    * @param string $name 名称
    * @return boolean
    </span><span>*/</span>
    <span>public</span> <span>function</span> open(<span>$savePath</span>, <span>$name</span><span>)
    {
        </span><span>$this</span>->_dbHandler = <span>mysql_connect</span>(<span>$this</span>->_dbHost, <span>$this</span>->_dbUser, <span>$this</span>-><span>_dbPasswd);
        </span><span>if</span>(!<span>$this</span>-><span>_dbHandler)
        {
            </span><span>return</span> <span>false</span><span>;
        }
        </span><span>$this</span>->_name = <span>$name</span><span>;
        </span><span>mysql_select_db</span>(self::SESSION_DB, <span>$this</span>-><span>_dbHandler);
        </span><span>return</span> <span>true</span><span>;
    }

    </span><span>/*</span><span>*
    * 读session
    * @param string $sessionId session id
    * @return mixd 存在返回数组  否则返回空
    </span><span>*/</span>
    <span>public</span> <span>function</span> read(<span>$sessionId</span><span>)
    {
        </span><span>$data</span> = ''<span>;
        </span><span>$sql</span> = <span>sprintf</span>('SELECT `data` FROM ' . self::SESSION_TABLE . ' WHERE `id`="%s"', <span>$sessionId</span><span>);
        </span><span>$result</span> = <span>mysql_query</span>(<span>$sql</span>, <span>$this</span>-><span>_dbHandler);
        </span><span>if</span>(<span>mysql_num_rows</span>(<span>$result</span>) == 1<span>)
        {
            </span><span>list</span>(<span>$data</span>) = <span>mysql_fetch_array</span>(<span>$result</span>,<span> MYSQL_NUM);
        }
        </span><span>return</span> <span>$data</span><span>;
    }

    </span><span>/*</span><span>*
    * 链接数据库
    * @param string $sessionId session id
    * @param string $data 数据
    * @return boolean
    </span><span>*/</span>
    <span>public</span> <span>function</span> write(<span>$sessionId</span>, <span>$data</span><span>)
    {
        </span><span>$sql</span> = <span>sprintf</span><span>(
                </span>'<span>REPLACE INTO 
                </span>' . self::SESSION_TABLE . '<span> (`id`, `data`, `last_time`) 
                VALUES 
                ("%s", "%s", %d)</span>', 
                <span>$sessionId</span>,     
                <span>mysql_escape_string</span>(<span>$data</span>),  
                <span>time</span><span>()
                );
        </span><span>mysql_query</span>(<span>$sql</span>, <span>$this</span>-><span>_dbHandler);
        </span><span>return</span> <span>mysql_affected_rows</span>(<span>$this</span>->_dbHandler) > 0<span>;
    }

    </span><span>/*</span><span>*
    * 链接数据库
    * @param int $expire 生存周期
    * @return boolean
    </span><span>*/</span>
    <span>public</span> <span>function</span> gc(<span>$expire</span><span>)
    {
        </span><span>$sql</span> = <span>sprintf</span><span>(
                        </span>'DELETE FROM `' . self::SESSION_TABLE . '<span>`
                        WHERE 
                        `last_time` < NOW() - %d</span>',
                        <span>$expire</span><span>
                    );
        </span><span>mysql_query</span>(<span>$sql</span>, <span>$this</span>-><span>_dbHandler);
        </span><span>return</span> <span>mysql_affected_rows</span>(<span>$this</span>->_dbHandler) > 0<span>;
    }

    </span><span>/*</span><span>*
    * 关闭数据库链接
    * @param void
    * @return boolean
    </span><span>*/</span>
    <span>public</span> <span>function</span><span> close()
    {
        </span><span>return</span> <span>mysql_close</span>(<span>$this</span>-><span>_dbHandler);
    }

    </span><span>/*</span><span>*
    * 销毁session
    * @param string $sessionId
    * @return boolean
    </span><span>*/</span>
    <span>public</span> <span>function</span> destroy(<span>$sessionId</span><span>)
    {
        </span><span>$sql</span> = <span>sprintf</span>('DELETE FROM `' . self::SESSION_TABLE . '` WHERE `id`="%s"', <span>$sessionId</span><span>);
        </span><span>mysql_query</span>(<span>$sql</span>, <span>$this</span>-><span>_dbHandler);
        </span><span>$_SESSION</span> = <span>array</span><span>();
        </span><span>return</span> <span>mysql_affected_rows</span>(<span>$this</span>->_dbHandler) > 0<span>;
    }
}


</span><span>$sessionHandler</span> = <span>new</span> sessionHandler('localhost', 'root', '123abc+'<span>);
</span><span>session_set_save_handler</span><span>(
                            </span><span>array</span>(<span>$sessionHandler</span>, 'open'),
                            <span>array</span>(<span>$sessionHandler</span>, 'close'),
                            <span>array</span>(<span>$sessionHandler</span>, 'read'),
                            <span>array</span>(<span>$sessionHandler</span>, 'write'),
                            <span>array</span>(<span>$sessionHandler</span>, 'destroy'),
                            <span>array</span>(<span>$sessionHandler</span>, 'gc'<span>)
                        );


</span><span>/*</span><span>
    在 PHP 5.0.5 中，在对象销毁之后才会调用 write 和 close 回调函数， 所以，在这两个回调函数中不可以使用对象，也不可以抛出异常。 
    如果在函数中抛出异常，PHP 既不会捕获它，也不会跟踪它， 这样会导致程序异常终止。 
    但是对象析构函数可以使用会话。
    可以在析构函数中调用 session_write_close() 函数来解决这个问题。 
    但是注册 shutdown 回调函数才是更加可靠的做法
</span><span>*/</span>
<span>register_shutdown_function</span>('session_write_close'<span>);

</span><span>session_start</span><span>();
</span><span>$_SESSION</span>['test'] = 'aa';

然后了建立一个表 叫 session  ，记住先建立数据库'mytest'奥  session表中有三个字段

id   vchar(100)  primary  sessionid的主键

data vchar(1000) 数据内容(序列化后的)

last_time int(10)  最后修改的时间戳

 

整完了运行下发现表里面的内容

大家可以看得出，通过代码自定义session的这种方式不仅可以应用到数据库上，也可以使用其他的，如文件、redis之类

 

 

至此，session的原理，如何自定义存放session，在集群中如何使用session，就已经完了

www.bkjia.comtruehttp://www.bkjia.com/PHPjc/1100144.htmlTechArticleredis/分布式文件存储系统/数据库 存储session，解决负载均衡集群中session不一致问题，redissession 先来说下session和cookie的异同 session和cookie不...
Statement：
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn
Previous article：ThinkPHP设置禁止百度等搜索引擎转码(简单实用)，thinkphp简单实用_PHP教程Next article：关于Apache默认编码错误，导致网站乱码的解决方案，apache编码_PHP教程

Related articles

See more