Redis內(nèi)存數(shù)據(jù)庫(kù)存儲(chǔ)

前言

會(huì)話是臨時(shí)存儲(chǔ)數(shù)據(jù)信息的一種機(jī)制。但是如果項(xiàng)目需要使用一些高復(fù)用的服務(wù)器架構(gòu)(如下圖)，就需要實(shí)現(xiàn)session數(shù)據(jù)同步或者統(tǒng)一存儲(chǔ)，不然就有可能出現(xiàn)會(huì)話狀態(tài)丟失的問題。所以如何共享Session信息就是一個(gè)需要解決的問題。下面本文講述的是，如何使用Thinkphp搭配Redis存儲(chǔ)Session信息(單應(yīng)用服務(wù)器，單redis版本)，以達(dá)到Session共享的目的。

base lbs

環(huán)境

  • 操作系統(tǒng) Linux ubuntu 16.04
  • PHP環(huán)境 PHP 7.0.28-0ubuntu0.16.04.1 ( NTS )
  • redis版本 4.0.8

介紹

Redis是一個(gè)使用ANSI C編寫的開源、支持網(wǎng)絡(luò)、基于內(nèi)存、可選持久性的鍵值對(duì)存儲(chǔ)數(shù)據(jù)庫(kù)。根據(jù)月度排行網(wǎng)站DB-Engines.com的數(shù)據(jù)顯示，Redis是最流行的鍵值對(duì)存儲(chǔ)數(shù)據(jù)庫(kù)

安裝Redis

源碼包安裝

根據(jù)redis官網(wǎng)的教程
1, Download, extract and compile Redis with:

wget http://download.redis.io/releases/redis-4.0.8.tar.gz
tar xzf redis-4.0.8.tar.gz
cd redis-4.0.8
make

2, The binaries that are now compiled are available in the src directory. Run Redis with:

src/redis-server

3, You can interact with Redis using the built-in client:

src/redis-cli
redis> set foo bar
OK
redis> get foo
"bar"

一切順利的話，源碼包Redis就安裝完畢了。另外我們也可以使用Docker安裝Redis。

Docker倉(cāng)庫(kù)安裝

這里是Redis的倉(cāng)庫(kù) ，提供了 Redis 3.x ~ 4.x 各個(gè)版本的鏡像。

1, 查看docker-hub上的遠(yuǎn)程倉(cāng)庫(kù)

docker search redis
image

2, 執(zhí)行下面命令，大意是首先docker會(huì)本地搜索docker images中理出來的鏡像，如果沒有則從docker hub(國(guó)內(nèi)鏡像)拉取redis的docker鏡像，然后啟動(dòng)一個(gè)名為some-redis容器，-p是把本地的9736端口和容器中的6379端口映射起來，-d (daemon)并讓容器運(yùn)行在后臺(tái),--requirepass客戶端鏈接需要認(rèn)證。

docker run --name my-redis -p 9736:6379 -d redis --requirepass "11110000"
##查看docker已經(jīng)啟動(dòng)的容器
docker ps
##安裝redis客戶端
sudo apt install reids-tools
##嘗試從外部主機(jī)范圍docker中的redis
redis-cli -h 127.0.0.1 -p 9736 -a 11110000
test-redis

Docker倉(cāng)庫(kù)安裝的程序，拓展遷徙相對(duì)簡(jiǎn)單，和其他系統(tǒng)的耦合性很小。接下來我們安裝拓展。

安裝php-redis 拓展

拓展我們選擇phpredis，這個(gè)比較通用，更新比較及時(shí)。github地址在這里

git clone https://github.com/phpredis/phpredis.git
##切換到phpredis所在的文件夾
phpize
./configure
make && make install
##重啟php服務(wù)
systemctl restart  php7.0-fpm.service

這時(shí)候就可以去phpinfo頁面看到redis拓展已經(jīng)成功出現(xiàn)了。


phpinfo-redis.png

這時(shí)候，我們就可以在php程序中操作redis數(shù)據(jù)庫(kù)了。新建一個(gè)文件vim phpredis.php，內(nèi)容如下。

<?php
 if( !extension_loaded('redis')){
     echo "not support redis";
     exit();
  }
  $redis = new Redis();
  $redis->connect('127.0.0.1',9736);
  $redis->auth("11110000");
  var_dump($redis->info());

##執(zhí)行上面的測(cè)試文件，如果成功了，就出現(xiàn)類似下面的結(jié)果。
php phpredis.php
redis-out.png

到這，php-redis拓展已經(jīng)安裝成功，我們也可以在php程序總操作redis數(shù)據(jù)庫(kù)了。接下來我們就在項(xiàng)目中使用redis存儲(chǔ)session。

Redis存儲(chǔ)Session

如果是使用原生的php來實(shí)現(xiàn)這個(gè)功能，就需要調(diào)整配置文件php.ini，配置phpredis使用文檔編寫代碼。

session.save_handler = redis
session.save_path = "tcp://host1:6379?weight=1"

如果是使用php框架的話，一般框架已經(jīng)集成了對(duì)應(yīng)的模塊操作驅(qū)動(dòng)。我們可以到thinkphp官網(wǎng)找到Session的Redis存儲(chǔ)驅(qū)動(dòng)類。我們需要在相對(duì)應(yīng)的位置(./ThinkPHP/Library/Think/Session/Driver/
)新建一個(gè)Redis.class.php文件，內(nèi)容如下。

<?php
namespace Think\Session\Driver;

/**
 * Redis Session驅(qū)動(dòng)
 */
class Redis {

    /**
     * Redis句柄
     */
    private $handler;
    private $get_result;

    public function __construct(){
        if ( !extension_loaded('redis') ) {
            E(L('_NOT_SUPPERT_').':redis');
        }
        if(empty($options)) {
            $options = array (
            'host'       => C('REDIS_HOST') ? C('REDIS_HOST') : '127.0.0.1',
            'port'       => C('REDIS_PORT') ? C('REDIS_PORT') : 6379,
            'timeout'    => C('REDIS_TIMEOUT') ? C('REDIS_TIMEOUT') : false,
            'persistent' => C('REDIS_PERSISTENT') ? C('REDIS_PERSISTENT'):false,
            'auth'      => C('REDIS_AUTH') ? C('REDIS_AUTH') : false,
            );
        }
        $options['host'] = explode(',', $options['host']);
        $options['port'] = explode(',', $options['port']);
        $options['auth'] = explode(',', $options['auth']);
        foreach ($options['host'] as $key=>$value) {
            if (!isset($options['port'][$key])) {
                $options['port'][$key] = $options['port'][0];
            }
            if (!isset($options['auth'][$key])) {
                $options['auth'][$key] = $options['auth'][0];
            }
        }
        $this->options =  $options;
        $expire = C('SESSION_EXPIRE');
        $this->options['expire'] =  
        isset($expire) ? (int)$expire : (int)ini_get('session.gc_maxlifetime');
        $this->options['prefix'] =  
        isset($options['prefix']) ?  $options['prefix']  :  C('SESSION_PREFIX');
        $this->handler  = new \Redis;
    }

    /**
     * 連接Redis服務(wù)端
     * @access public
     * @param bool $is_master : 是否連接主服務(wù)器
     */
    public function connect($is_master = true) {
        if ($is_master) {
            $i = 0;
        } else {
            $count = count($this->options['host']);
            if ($count == 1) {
                $i = 0;
            } else {
                $i = rand(1, $count - 1);   //多個(gè)從服務(wù)器隨機(jī)選擇
            }
        }
        $func = $this->options['persistent'] ? 'pconnect' : 'connect';
        try {
            if ($this->options['timeout'] === false) {
                $result = $this
                ->handler
                ->$func($this->options['host'][$i], $this->options['port'][$i]);
                if (!$result)
                    throw new \Think\Exception('Redis Error', 100);
            } else {
                $result = $this
                ->handler
                ->$func($this->options['host'][$i], $this->options['port'][$i],
                $this->options['timeout']);
                if (!$result)
                    throw new \Think\Exception('Redis Error', 101);
            }
            if ($this->options['auth'][$i]) {

                $result = $this->handler->auth($this->options['auth'][$i]);
                if (!$result) {
                    throw new \Think\Exception('Redis Error', 102);
                }
            }
        } catch ( \Exception $e ) {
          exit('Error:'.$e->getMessage().'<br>Error Code:'.$e->getCode().'');
        }
    }

    /**
      +----------------------------------------------------------
     * 打開Session
      +----------------------------------------------------------
     * @access public
      +----------------------------------------------------------
     * @param string $savePath
     * @param mixed $sessName
      +----------------------------------------------------------
     */
    public function open($savePath, $sessName) {
        return true;
    }

    /**
      +----------------------------------------------------------
     * 關(guān)閉Session
      +----------------------------------------------------------
     * @access public
      +----------------------------------------------------------
     */
    public function close() {
        if ($this->options['persistent'] == 'pconnect') {
            $this->handler->close();
        }
        return true;
    }

    /**
      +----------------------------------------------------------
     * 讀取Session
      +----------------------------------------------------------
     * @access public
      +----------------------------------------------------------
     * @param string $sessID
      +----------------------------------------------------------
     */
    public function read($sessID) {
      $this->connect(0);
      $this->get_result = $this->handler->get($this->options['prefix'].$sessID);
      //延長(zhǎng)有效期
      $this->handler->expire($this->options['prefix']
      .$sessID,C('SESSION_EXPIRE'));
      return $this->get_result;
    }

    /**
      +----------------------------------------------------------
     * 寫入Session
      +----------------------------------------------------------
     * @access public
      +----------------------------------------------------------
     * @param string $sessID
     * @param String $sessData
      +----------------------------------------------------------
     */
    public function write($sessID, $sessData) {
        if (!$sessData || $sessData == $this->get_result) {
            return true;
        }
        $this->connect(1);
        $expire  =  $this->options['expire'];
        $sessID   =   $this->options['prefix'].$sessID;
        if(is_int($expire) && $expire > 0) {
            $result = $this->handler->setex($sessID, $expire, $sessData);
            $re = $result ? 'true' : 'false';
        }else{
            $result = $this->handler->set($sessID, $sessData);
            $re = $result ? 'true' : 'false';
        }
        return $result;
    }

    /**
      +----------------------------------------------------------
     * 刪除Session
      +----------------------------------------------------------
     * @access public
      +----------------------------------------------------------
     * @param string $sessID
      +----------------------------------------------------------
     */
    public function destroy($sessID) {
        $this->connect(1);
        return $this->handler->delete($this->options['prefix'].$sessID);
    }

    /**
      +----------------------------------------------------------
     * Session 垃圾回收
      +----------------------------------------------------------
     * @access public
      +----------------------------------------------------------
     * @param string $sessMaxLifeTime
      +----------------------------------------------------------
     */
    public function gc($sessMaxLifeTime) {
        return true;
    }

    /**
      +----------------------------------------------------------
     * 打開Session
      +----------------------------------------------------------
     * @access public
      +----------------------------------------------------------
     * @param string $savePath
     * @param mixed $sessName
      +----------------------------------------------------------
     */
    public function execute() {
        session_set_save_handler(
                array(&$this, "open"),
                array(&$this, "close"),
                array(&$this, "read"),
                array(&$this, "write"),
                array(&$this, "destroy"),
                array(&$this, "gc")
        );
    }

    public function __destruct() {
        if ($this->options['persistent'] == 'pconnect') {
            $this->handler->close();
        }
        session_write_close();
    }

}

接著在配置文件中配置如下配置項(xiàng)，不需要改動(dòng)php.ini配置項(xiàng)了。

//SESSION 配置
'SESSION_AUTO_START'    => true, //是否開啟session
'SESSION_TYPE'          =>  'Redis',    //session 驅(qū)動(dòng)
'SESSION_PREFIX'        =>  '',       //session前綴
'SESSION_EXPIRE'        =>  '7200',        //session有效期(單位:秒) 0表示永久緩存。
//Redis 配置
'REDIS_HOST'        =>'127.0.0.1', //redis服務(wù)器ip，多臺(tái)用逗號(hào)隔開；
'REDIS_PORT'        =>'9736',//端口號(hào)
'REDIS_TIMEOUT'     =>'30',//超時(shí)時(shí)間(秒)
'REDIS_PERSISTENT'  =>false,//是否長(zhǎng)連接 false=短連接
'REDIS_AUTH'        =>'11110000',//AUTH認(rèn)證密碼

其他層面的代碼不需要改動(dòng)，因?yàn)榭蚣芤呀?jīng)將Session類的操作方面封裝起來了。業(yè)務(wù)存儲(chǔ)Session時(shí)候，底層會(huì)根據(jù)配置項(xiàng)來實(shí)例化對(duì)應(yīng)的存儲(chǔ)驅(qū)動(dòng)類。從而就實(shí)現(xiàn)了session存儲(chǔ)在對(duì)應(yīng)的redis數(shù)據(jù)庫(kù)中了。

如無意外，至此，我們就完成了這次的小目標(biāo)了。

結(jié)語

本文簡(jiǎn)單地實(shí)現(xiàn)了單機(jī)版的Redis存儲(chǔ)php程序的Session數(shù)據(jù)。下一步，計(jì)劃利用Docker技術(shù)搭建Redis基礎(chǔ)的高可用分布式集群，就本文的基礎(chǔ)上進(jìn)行項(xiàng)目架構(gòu)拓展。如有興趣，敬請(qǐng)關(guān)注！

最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡(jiǎn)書系信息發(fā)布平臺(tái)，僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

  • Docker — 云時(shí)代的程序分發(fā)方式 要說最近一年云計(jì)算業(yè)界有什么大事件？Google Compute Engi...
    ahohoho閱讀 15,850評(píng)論 15贊 147
  • Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具（例如配置管理，服務(wù)發(fā)現(xiàn)，斷路器，智...
    卡卡羅2017閱讀 136,610評(píng)論 19贊 139
  • 為什么一定要把想不開的事放下。現(xiàn)在多好啊，每一場(chǎng)夢(mèng)里，你都能來。我突然覺得不那么難受了，唯一的小小心愿，是你一定一...
    87的腿兒閱讀 220評(píng)論 0贊 0
  • 在進(jìn)行數(shù)據(jù)連接時(shí)候需要進(jìn)行網(wǎng)絡(luò)狀態(tài)判斷 //判斷網(wǎng)絡(luò)連接 + (BOOL) isConnectionAvailab...
    眼睛不笑的人閱讀 433評(píng)論 0贊 0
  • Weex頁面由<template>, , 三個(gè)部分構(gòu)成。1.<template>: 必須的, 使用類HTML的語法...
    阿凡提說AI閱讀 454評(píng)論 0贊 0

友情鏈接更多精彩內(nèi)容