redis/分散式文件存儲系統/資料庫 存儲session,解決負載均衡集群中session不一致問題

来源:http://www.cnblogs.com/painsOnline/archive/2016/02/17/5194851.html
-Advertisement-
Play Games

session原理,session如何存儲,如何使用redis/分散式文件系統/資料庫存儲session,負載均衡中如何解決session不一致問題


先來說下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 = redis
session.save_path = "tcp://127.0.0.1:6379"

當然了,也可以在php程式中設置

ini_set('session.save_handler','redis');
ini_set('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 = "xxxx"

 

三、使用資料庫存放session

這個略顯複雜,要寫個PHP類,指定如何打開、讀取、寫入、銷毀、GC垃圾回收、關閉,不過筆者不懶還是手動寫一個意思意思

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

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

    /**
    * @var string $_dbHandler 資料庫鏈接句柄
    */
    private $_dbHandler;

    /**
    * @var string $_dbHost 資料庫主機
    */
    private $_dbHost;

    /**
    * @var string $_dbUser 資料庫用戶名
    */
    private $_dbUser;

    /**
    * @var string $_dbUser 資料庫密碼
    */
    private $_dbPasswd;

    /**
    * @var string $_name session 名稱
    */
    private $_name;

    /**
    * 構造函數
    * @param string $dbHost 資料庫主機
    * @param string $dbUser 資料庫用戶名
    * @param string $dbPasswd 資料庫密碼
    * @return void
    */
    public function __construct($dbHost, $dbUser, $dbPasswd)
    {
        $this->_dbHost = $dbHost;
        $this->_dbUser = $dbUser;
        $this->_dbPasswd = $dbPasswd;
    }

    /**
    * 鏈接資料庫
    * @param string $savePath 存儲路徑
    * @param string $name 名稱
    * @return boolean
    */
    public function open($savePath, $name)
    {
        $this->_dbHandler = mysql_connect($this->_dbHost, $this->_dbUser, $this->_dbPasswd);
        if(!$this->_dbHandler)
        {
            return false;
        }
        $this->_name = $name;
        mysql_select_db(self::SESSION_DB, $this->_dbHandler);
        return true;
    }

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

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

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

    /**
    * 關閉資料庫鏈接
    * @param void
    * @return boolean
    */
    public function close()
    {
        return mysql_close($this->_dbHandler);
    }

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


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


/*
    在 PHP 5.0.5 中,在對象銷毀之後才會調用 write 和 close 回調函數, 所以,在這兩個回調函數中不可以使用對象,也不可以拋出異常。 
    如果在函數中拋出異常,PHP 既不會捕獲它,也不會跟蹤它, 這樣會導致程式異常終止。 
    但是對象析構函數可以使用會話。
    可以在析構函數中調用 session_write_close() 函數來解決這個問題。 
    但是註冊 shutdown 回調函數才是更加可靠的做法
*/
register_shutdown_function('session_write_close');

session_start();
$_SESSION['test'] = 'aa';

然後了建立一個表 叫 session  ,記住先建立資料庫'mytest'奧  session表中有三個欄位

id   vchar(100)  primary  sessionid的主鍵

data vchar(1000) 數據內容(序列化後的)

last_time int(10)  最後修改的時間戳

 

整完了運行下發現表裡面的內容

大家可以看得出,通過代碼自定義session的這種方式不僅可以應用到資料庫上,也可以使用其他的,如文件、redis之類

 

 

至此,session的原理,如何自定義存放session,在集群中如何使用session,就已經完了


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 1、基本概念 一次http請求 輸入(Request):header信息、get信息、post數據等 輸出(Response):symfony經過處理返回的信息,包括頁面、json字元串、URL跳轉等 2、Request $this->getRequest() httpie工具 HTTPie (讀a
  • 環境 Badboy version 2.1.1 JDK: 1.7.0_67 Apache JMeter-2.11 ---------------------------------------------------------------------------------------------
  • 給出一個整數n(n<=2000)(代碼可適用n<=10^31)和k個變換規則(k<=15)。 規則:1、1個數字可以變換成另1個數字; 2、規則中右邊的數字不能為零。 BFS 1 #include <stdio.h> 2 #include <string.h> 3 #define maxn 1000
  • 思路: 用迴圈提取最裡面的括弧,再進行運算 運算時利用正則表達式尋找相應的運算符 先進行乘除,再進行加減 (參考武sir和金角大王的代碼) 流程圖: 代碼: 1 #!/usr/bin/env python 2 # -*- coding:utf-8 -*- 3 import re 4 def chen
  • C語言數據結構之棧:中綴表達式的計算
  • 安裝環境: CentOS release 6.3 (Final) about 64bit cpu 1, http://www.oracle.com下載最新版的javase的jdk環境 比如我下載的是:jdk-8u73-linux-x64.tar.gz 2,上傳到 /usr/java下 3,tar -
  • public static void main(String[] args) { Integer i1 = new Integer(1); Integer i2 = new Integer(1); // i1,i2分別位於堆中不同的記憶體空間 System.out.println("i1 == i2:
  • 引用計數 Python預設的垃圾收集機制是“引用計數”,每個對象維護了一個ob_ref欄位。它的優點是機制簡單,當新的引用指向該對象時,引用計數加1,當一個對象的引用被銷毀時減1,一旦對象的引用計數為0,該對象立即被回收,所占用的記憶體將被釋放。它的缺點是需要額外的空間維護引用計數,不過最主要的問題是
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...