[转]非mmcache！Memcached的應用：多網站伺服器 PHP 共享 Session

秒速五厘米 2022-09-18 05:00 111阅读 0赞

转:http://blog.twpug.org/index.php?blogId=30

請注意是 Memcached 不是 mmcache，很多人搞不清楚他們兩個的不同！多半玩過 PHP 的人大概都聽過 mmcache，它是一個預編譯緩衝的 PHP 加速程式，能夠提升 PHP 的執行效能。但很少人聽過 Memcached ，因為大多人乍看之下都以為它是mmcache，使得它沒什麼機會介紹自己。事實上，若您正打算架構一個真正高負載的大型網站系統，你需要了解的並不是 mmcache，而是 memcached。  
  
Memcached 是什麼？顧名思義，他是由記憶體(Memory)和暫存(cache)所組合起來的常駐程式(Daemon)，你也可以稱它為『暫存伺服器』。 Memcached 能提供一個暫存資料的服務，透過網路供其他電腦使用。Memcached 有什麼用途？最常見的應用就是在網站伺服器的叢集，它能讓許多的網站伺服器 Session 互相流通使用。如果你正在傷透腦筋煩惱這一點，恭喜你找到解決方法了！  
  
想要在網站伺服器的叢集中，多網站伺服器 Session 互相流通使用，首先你必須將 Memcached 架起來當 Session 分享伺服器，這邊建議你使用大的記憶體，最好是能多大就有多大，因為 Memcached 並不會以硬碟當資料暫存，而是會完全跑在記憶體上，所以若記憶被用完了，Memcached 就會無法再存放更多資料。  
  
接著，你必須修改 PHP 的 Session Save Handler，讓 PHP 懂得利用 Memcached Server 存放 PHP 的 Session 資料並能從 Memcached Server 取出 Session 的資料。PHP提供了 session\_set\_save\_handler() 函式讓我們能輕易修改 Session Save Handler ，以下是我修改後的 PHP 程式碼，你必須在呼叫 session\_start() 之前使用：

![None.gif][] <?   
![None.gif][] require\_once   " memcached-client.php " ;  
![None.gif][]  
![None.gif][] define ( " SHARED\_SESS\_TIME " ,   3600 );  //  Timeout  
![None.gif][]  
![None.gif][]// Session Class by Fred   
![None.gif][]   
![None.gif][] class  Shared\_Session  
![None.gif][]\{  
![None.gif][]     function  init()  
![None.gif][]    \{  
![None.gif][]         ini\_set ( " session.use\_trans\_sid " ,   0 );  
![None.gif][]         ini\_set ( " session.gc\_maxlifetime " ,  SHARED\_SESS\_TIME);  
![None.gif][]         ini\_set ( " session.use\_cookies " ,   1 );  
![None.gif][]         ini\_set ( " session.cookie\_path " ,   " / " );  
![None.gif][]         ini\_set ( " session.cookie\_domain " ,   " .yourdomain.com.tw " );  
![None.gif][]  
![None.gif][]         session\_module\_name ( " user " );  
![None.gif][]         session\_set\_save\_handler (  
![None.gif][]             array ( " Shared\_Session " ,   " open " ) ,   
![None.gif][]             array ( " Shared\_Session " ,   " close " ) ,   
![None.gif][]             array ( " Shared\_Session " ,   " read " ) ,   
![None.gif][]             array ( " Shared\_Session " ,   " write " ) ,   
![None.gif][]             array ( " Shared\_Session " ,   " destroy " ) ,   
![None.gif][]             array ( " Shared\_Session " ,   " gc " )  
![None.gif][]        );  
![None.gif][]    \}  
![None.gif][]  
![None.gif][]     function  open( $save\_path ,   $session\_name ) \{  
![None.gif][]         return   true ;  
![None.gif][]    \}  
![None.gif][]  
![None.gif][]     function  close() \{  
![None.gif][]         return   true ;  
![None.gif][]    \}  
![None.gif][]  
![None.gif][]     function  read( $sesskey ) \{  
![None.gif][]         global   $memcache ;  
![None.gif][]  
![None.gif][]     return   $memcache \-> get( $sesskey );  
![None.gif][]    \}  
![None.gif][]  
![None.gif][]     function  write( $sesskey ,   $data ) \{  
![None.gif][]         global   $memcache ;  
![None.gif][]  
![None.gif][]         $memcache \-> set( $sesskey ,   $data ,  SHARED\_SESS\_TIME);  
![None.gif][]  
![None.gif][]         return   true ;  
![None.gif][]    \}  
![None.gif][]  
![None.gif][]     function  destroy( $sesskey ) \{  
![None.gif][]         global   $memcache ;  
![None.gif][]  
![None.gif][]         $memcache \-> delete( $sesskey );  
![None.gif][]         $memcache \-> flush\_all();  
![None.gif][]  
![None.gif][]         return   true ;  
![None.gif][]    \}  
![None.gif][]  
![None.gif][]     function  gc( $maxlifetime   =   null ) \{  
![None.gif][]         return   true ;  
![None.gif][]    \}  
![None.gif][]\}  
![None.gif][]  
![None.gif][] $GLOBALS \[ " memcache " \]  =   new  memcached( array (  
![None.gif][]               ' servers '   =>   array ( ' 127.0.0.1:11212 ' ) ,   
![None.gif][]               ' debug '     =>   false ,   
![None.gif][]               ' compress\_threshold '   =>   10240 ,   
![None.gif][]               ' persistant '   =>   true ));  
![None.gif][]  
![None.gif][]Shared\_Session :: init();  
![None.gif][]  
![None.gif][] ?>

其中粗字體的部分，是要特別修改的地方：

*  **3600** 是 Session 的生命周期﹝以秒為單位﹞，這應該不用再做太多解釋。

*  **.yourdomain.com.tw** 是你的網域名稱：想像一個情況若是 Loadbalance 在用戶第一次連線分配用戶到A伺服器，第二次連線分配給同一用戶到B伺服器，會導致 B 伺服器無法透過 cookies 取得 A 伺服器分配給用戶的 session\_id，因為 cookies 無法跨網域存取，解決方法是必須修改 cookies 的網域設定，讓 www1.yourdomain.com.tw、www2.yourdomain.com.tw、www3.yourdomain.com.tw...等等，都可以共同存取同一個 cookies ，以取得同一個 session\_id，故此時你必須設定成為『.yourdomain.com.tw』。

*  **192.168.1.1** 這是你的 Memcached Server 的 IP 位置，這裡值得提的是 add\_server() 方法，你可以有多行設定許多 IP 做 Loadbalance 負載分配，前面也講到 Memcached 是純粹使用記憶體，若其中一台機器記憶體滿了，本方法可以從中找到另一台可用的機器使用。故你可以建立一個 Memcached 的叢集來處理 Session。

因 為我偷懶， Memcached 的安裝方法就沒寫了，去求助 google 大神，它應該會告訴你更多詳細的安裝資料。其實 Memcached 除了可應用在 Session 共享上，也可以應用在資料庫的資料暫存緩充，降低SQL Server負擔以提升速度。Memcached多好用？就看你怎麼用了！  
  
附:memcached-client.php

![None.gif][] <? php  
![None.gif][] //   
![None.gif][]// +---------------------------------------------------------------------------+  
![None.gif][]// | memcached client, PHP                                                     |  
![None.gif][]// +---------------------------------------------------------------------------+  
![None.gif][]// | Copyright (c) 2003 Ryan T. Dean <rtdean@cytherianage.net>                 |  
![None.gif][]// | All rights reserved.                                                      |  
![None.gif][]// |                                                                           |  
![None.gif][]// | Redistribution and use in source and binary forms, with or without        |  
![None.gif][]// | modification, are permitted provided that the following conditions        |  
![None.gif][]// | are met:                                                                  |  
![None.gif][]// |                                                                           |  
![None.gif][]// | 1. Redistributions of source code must retain the above copyright         |  
![None.gif][]// |    notice, this list of conditions and the following disclaimer.          |  
![None.gif][]// | 2. Redistributions in binary form must reproduce the above copyright      |  
![None.gif][]// |    notice, this list of conditions and the following disclaimer in the    |  
![None.gif][]// |    documentation and/or other materials provided with the distribution.   |  
![None.gif][]// |                                                                           |  
![None.gif][]// | THIS SOFTWARE IS PROVIDED BY THE AUTHOR \`\`AS IS'' AND ANY EXPRESS OR      |  
![None.gif][]// | IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES |  
![None.gif][]// | OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.   |  
![None.gif][]// | IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,          |  
![None.gif][]// | INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT  |  
![None.gif][]// | NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |  
![None.gif][]// | DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY     |  
![None.gif][]// | THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT       |  
![None.gif][]// | (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF  |  
![None.gif][]// | THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.         |  
![None.gif][]// +---------------------------------------------------------------------------+  
![None.gif][]// | Author: Ryan T. Dean <rtdean@cytherianage.net>                            |  
![None.gif][]// | Heavily influenced by the Perl memcached client by Brad Fitzpatrick.      |  
![None.gif][]// |   Permission granted by Brad Fitzpatrick for relicense of ported Perl     |  
![None.gif][]// |   client logic under 2-clause BSD license.                                |  
![None.gif][]// +---------------------------------------------------------------------------+  
![None.gif][]//  
![None.gif][]// $TCAnet$  
![None.gif][]//   
![None.gif][]   
![None.gif][] /\* \*  
![None.gif][] \* This is the PHP client for memcached - a distributed memory cache daemon.  
![None.gif][] \* More information is available at http://www.danga.com/memcached/  
![None.gif][] \*  
![None.gif][] \* Usage example:  
![None.gif][] \*  
![None.gif][] \* require\_once 'memcached.php';  
![None.gif][] \*   
![None.gif][] \* $mc = new memcached(array(  
![None.gif][] \*              'servers' => array('127.0.0.1:10000',   
![None.gif][] \*                                 array('192.0.0.1:10010', 2),  
![None.gif][] \*                                 '127.0.0.1:10020'),  
![None.gif][] \*              'debug'   => false,  
![None.gif][] \*              'compress\_threshold' => 10240,  
![None.gif][] \*              'persistant' => true));  
![None.gif][] \*  
![None.gif][] \* $mc->add('key', array('some', 'array'));  
![None.gif][] \* $mc->replace('key', 'some random string');  
![None.gif][] \* $val = $mc->get('key');  
![None.gif][] \*  
![None.gif][] \* @author  Ryan T. Dean <rtdean@cytherianage.net>  
![None.gif][] \* @package memcached-client  
![None.gif][] \* @version 0.1.2  
![None.gif][]  \*/   
![None.gif][]  
![None.gif][] //  \{ \{ \{ requirements  
![None.gif][]// \}\}\}  
![None.gif][]  
![None.gif][]// \{ \{ \{ constants  
![None.gif][]// \{ \{ \{ flags   
![None.gif][]   
![None.gif][] /\* \*  
![None.gif][] \* Flag: indicates data is serialized  
![None.gif][]  \*/   
![None.gif][] define ( " MEMCACHE\_SERIALIZED " ,   1 << 0 );  
![None.gif][]  
![None.gif][] /\* \*  
![None.gif][] \* Flag: indicates data is compressed  
![None.gif][]  \*/   
![None.gif][] define ( " MEMCACHE\_COMPRESSED " ,   1 << 1 );  
![None.gif][]  
![None.gif][] //  \}\}\}   
![None.gif][]   
![None.gif][] /\* \*  
![None.gif][] \* Minimum savings to store data compressed  
![None.gif][]  \*/   
![None.gif][] define ( " COMPRESSION\_SAVINGS " ,   0.20 );  
![None.gif][]  
![None.gif][] //  \}\}\}  
![None.gif][]  
![None.gif][]// \{ \{ \{ class memcached   
![None.gif][]/\* \*  
![None.gif][] \* memcached client class implemented using (p)fsockopen()  
![None.gif][] \*  
![None.gif][] \* @author  Ryan T. Dean <rtdean@cytherianage.net>  
![None.gif][] \* @package memcached-client  
![None.gif][]  \*/   
![None.gif][] class  memcached  
![None.gif][]\{  
![None.gif][]    //  \{ \{ \{ properties  
![None.gif][]   // \{ \{ \{ public   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Command statistics  
![None.gif][]    \*  
![None.gif][]    \* @var     array  
![None.gif][]    \* @access  public  
![None.gif][]     \*/   
![None.gif][]    var   $stats ;  
![None.gif][]     
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ private   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Cached Sockets that are connected  
![None.gif][]    \*  
![None.gif][]    \* @var     array  
![None.gif][]    \* @access  private  
![None.gif][]     \*/   
![None.gif][]    var   $\_cache\_sock ;  
![None.gif][]     
![None.gif][]    /\* \*  
![None.gif][]    \* Current debug status; 0 - none to 9 - profiling  
![None.gif][]    \*  
![None.gif][]    \* @var     boolean  
![None.gif][]    \* @access  private  
![None.gif][]     \*/   
![None.gif][]    var   $\_debug ;  
![None.gif][]     
![None.gif][]    /\* \*  
![None.gif][]    \* Dead hosts, assoc array, 'host'=>'unixtime when ok to check again'  
![None.gif][]    \*  
![None.gif][]    \* @var     array  
![None.gif][]    \* @access  private  
![None.gif][]     \*/   
![None.gif][]    var   $\_host\_dead ;  
![None.gif][]     
![None.gif][]    /\* \*  
![None.gif][]    \* Is compression available?  
![None.gif][]    \*  
![None.gif][]    \* @var     boolean  
![None.gif][]    \* @access  private  
![None.gif][]     \*/   
![None.gif][]    var   $\_have\_zlib ;  
![None.gif][]     
![None.gif][]    /\* \*  
![None.gif][]    \* Do we want to use compression?  
![None.gif][]    \*  
![None.gif][]    \* @var     boolean  
![None.gif][]    \* @access  private  
![None.gif][]     \*/   
![None.gif][]    var   $\_compress\_enable ;  
![None.gif][]     
![None.gif][]    /\* \*  
![None.gif][]    \* At how many bytes should we compress?  
![None.gif][]    \*  
![None.gif][]    \* @var     interger  
![None.gif][]    \* @access  private  
![None.gif][]     \*/   
![None.gif][]    var   $\_compress\_threshold ;  
![None.gif][]     
![None.gif][]    /\* \*  
![None.gif][]    \* Are we using persistant links?  
![None.gif][]    \*  
![None.gif][]    \* @var     boolean  
![None.gif][]    \* @access  private  
![None.gif][]     \*/   
![None.gif][]    var   $\_persistant ;  
![None.gif][]     
![None.gif][]    /\* \*  
![None.gif][]    \* If only using one server; contains ip:port to connect to  
![None.gif][]    \*  
![None.gif][]    \* @var     string  
![None.gif][]    \* @access  private  
![None.gif][]     \*/   
![None.gif][]    var   $\_single\_sock ;  
![None.gif][]     
![None.gif][]    /\* \*  
![None.gif][]    \* Array containing ip:port or array(ip:port, weight)  
![None.gif][]    \*  
![None.gif][]    \* @var     array  
![None.gif][]    \* @access  private  
![None.gif][]     \*/   
![None.gif][]    var   $\_servers ;  
![None.gif][]     
![None.gif][]    /\* \*  
![None.gif][]    \* Our bit buckets  
![None.gif][]    \*  
![None.gif][]    \* @var     array  
![None.gif][]    \* @access  private  
![None.gif][]     \*/   
![None.gif][]    var   $\_buckets ;  
![None.gif][]     
![None.gif][]    /\* \*  
![None.gif][]    \* Total \# of bit buckets we have  
![None.gif][]    \*  
![None.gif][]    \* @var     interger  
![None.gif][]    \* @access  private  
![None.gif][]     \*/   
![None.gif][]    var   $\_bucketcount ;  
![None.gif][]     
![None.gif][]    /\* \*  
![None.gif][]    \* \# of total servers we have  
![None.gif][]    \*  
![None.gif][]    \* @var     interger  
![None.gif][]    \* @access  private  
![None.gif][]     \*/   
![None.gif][]    var   $\_active ;  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \}\}\}  
![None.gif][]   // \{ \{ \{ methods  
![None.gif][]   // \{ \{ \{ public functions  
![None.gif][]   // \{ \{ \{ memcached()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Memcache initializer  
![None.gif][]    \*  
![None.gif][]    \* @param   array    $args    Associative array of settings  
![None.gif][]    \*  
![None.gif][]    \* @return  mixed  
![None.gif][]    \* @access  public  
![None.gif][]     \*/   
![None.gif][]    function  memcached ( $args )  
![None.gif][]   \{  
![None.gif][]       $this \-> set\_servers( $args \[ ' servers ' \]);  
![None.gif][]       $this \-> \_debug  =   $args \[ ' debug ' \];  
![None.gif][]       $this \-> stats  =   array ();  
![None.gif][]       $this \-> \_compress\_threshold  =   $args \[ ' compress\_threshold ' \];  
![None.gif][]       $this \-> \_persistant  =   isset ( $args \[ ' persistant ' \])  ?   $args \[ ' persistant ' \]  :   false ;  
![None.gif][]       $this \-> \_compress\_enable  =   true ;  
![None.gif][]       $this \-> \_have\_zlib  =   function\_exists ( " gzcompress " );  
![None.gif][]        
![None.gif][]       $this \-> \_cache\_sock  =   array ();  
![None.gif][]       $this \-> \_host\_dead  =   array ();  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ add()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Adds a key/value to the memcache server if one isn't already set with   
![None.gif][]    \* that key  
![None.gif][]    \*  
![None.gif][]    \* @param   string   $key     Key to set with data  
![None.gif][]    \* @param   mixed    $val     Value to store  
![None.gif][]    \* @param   interger $exp     (optional) Time to expire data at  
![None.gif][]    \*  
![None.gif][]    \* @return  boolean  
![None.gif][]    \* @access  public  
![None.gif][]     \*/   
![None.gif][]    function  add ( $key ,   $val ,   $exp   =   0 )  
![None.gif][]   \{  
![None.gif][]       return   $this \-> \_set( ' add ' ,   $key ,   $val ,   $exp );  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ decr()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Decriment a value stored on the memcache server  
![None.gif][]    \*  
![None.gif][]    \* @param   string   $key     Key to decriment  
![None.gif][]    \* @param   interger $amt     (optional) Amount to decriment  
![None.gif][]    \*  
![None.gif][]    \* @return  mixed    FALSE on failure, value on success  
![None.gif][]    \* @access  public  
![None.gif][]     \*/   
![None.gif][]    function  decr ( $key ,   $amt = 1 )  
![None.gif][]   \{  
![None.gif][]       return   $this \-> \_incrdecr( ' decr ' ,   $key ,   $amt );  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ delete()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Deletes a key from the server, optionally after $time  
![None.gif][]    \*  
![None.gif][]    \* @param   string   $key     Key to delete  
![None.gif][]    \* @param   interger $time    (optional) How long to wait before deleting  
![None.gif][]    \*  
![None.gif][]    \* @return  boolean  TRUE on success, FALSE on failure  
![None.gif][]    \* @access  public  
![None.gif][]     \*/   
![None.gif][]    function  delete ( $key ,   $time   =   0 )  
![None.gif][]   \{  
![None.gif][]       if  ( ! $this \-> \_active)  
![None.gif][]          return   false ;  
![None.gif][]           
![None.gif][]       $sock   =   $this \-> get\_sock( $key );  
![None.gif][]       if  ( ! is\_resource ( $sock ))  
![None.gif][]          return   false ;  
![None.gif][]        
![None.gif][]       $key   =   is\_array ( $key )  ?   $key \[ 1 \]  :   $key ;  
![None.gif][]        
![None.gif][]       $this \-> stats\[ ' delete ' \] \++ ;  
![None.gif][]       $cmd   =   " delete $key $time  " ;  
![None.gif][]       if ( ! fwrite ( $sock ,   $cmd ,   strlen ( $cmd )))  
![None.gif][]      \{  
![None.gif][]          $this \-> \_dead\_sock( $sock );  
![None.gif][]          return   false ;  
![None.gif][]      \}  
![None.gif][]       $res   =   trim ( fgets ( $sock ));  
![None.gif][]        
![None.gif][]       if  ( $this \-> \_debug)  
![None.gif][]          printf ( " MemCache: delete %s (%s)  " ,   $key ,   $res );  
![None.gif][]        
![None.gif][]       if  ( $res   ==   " DELETED " )  
![None.gif][]          return   true ;  
![None.gif][]       return   false ;  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ disconnect\_all()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Disconnects all connected sockets  
![None.gif][]    \*  
![None.gif][]    \* @access  public  
![None.gif][]     \*/   
![None.gif][]    function  disconnect\_all ()  
![None.gif][]   \{  
![None.gif][]       foreach  ( $this \-> \_cache\_sock  as   $sock )  
![None.gif][]          fclose ( $sock );  
![None.gif][]  
![None.gif][]       $this \-> \_cache\_sock  =   array ();  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ enable\_compress()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Enable / Disable compression  
![None.gif][]    \*  
![None.gif][]    \* @param   boolean  $enable  TRUE to enable, FALSE to disable  
![None.gif][]    \*  
![None.gif][]    \* @access  public  
![None.gif][]     \*/   
![None.gif][]    function  enable\_compress ( $enable )  
![None.gif][]   \{  
![None.gif][]       $this \-> \_compress\_enable  =   $enable ;  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ forget\_dead\_hosts()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Forget about all of the dead hosts  
![None.gif][]    \*  
![None.gif][]    \* @access  public  
![None.gif][]     \*/   
![None.gif][]    function  forget\_dead\_hosts ()  
![None.gif][]   \{  
![None.gif][]       $this \-> \_host\_dead  =   array ();  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ get()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Retrieves the value associated with the key from the memcache server  
![None.gif][]    \*  
![None.gif][]    \* @param  string   $key     Key to retrieve  
![None.gif][]    \*  
![None.gif][]    \* @return  mixed  
![None.gif][]    \* @access  public  
![None.gif][]     \*/   
![None.gif][]    function  get ( $key )  
![None.gif][]   \{  
![None.gif][]       if  ( ! $this \-> \_active)  
![None.gif][]          return   false ;  
![None.gif][]           
![None.gif][]       $sock   =   $this \-> get\_sock( $key );  
![None.gif][]        
![None.gif][]       if  ( ! is\_resource ( $sock ))  
![None.gif][]          return   false ;  
![None.gif][]           
![None.gif][]       $this \-> stats\[ ' get ' \] \++ ;  
![None.gif][]        
![None.gif][]       $cmd   =   " get $key  " ;  
![None.gif][]       if  ( ! fwrite ( $sock ,   $cmd ,   strlen ( $cmd )))  
![None.gif][]      \{  
![None.gif][]          $this \-> \_dead\_sock( $sock );  
![None.gif][]          return   false ;  
![None.gif][]      \}  
![None.gif][]        
![None.gif][]       $val   =   array ();  
![None.gif][]       $this \-> \_load\_items( $sock ,   $val );  
![None.gif][]        
![None.gif][]       if  ( $this \-> \_debug)  
![None.gif][]          foreach  ( $val   as   $k   =>   $v )  
![None.gif][]             printf ( " MemCache: sock %s got %s => %s  " ,   $sock ,   $k ,   $v );  
![None.gif][]        
![None.gif][]       return   $val \[ $key \];  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ get\_multi()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Get multiple keys from the server(s)  
![None.gif][]    \*  
![None.gif][]    \* @param   array    $keys    Keys to retrieve  
![None.gif][]    \*  
![None.gif][]    \* @return  array  
![None.gif][]    \* @access  public  
![None.gif][]     \*/   
![None.gif][]    function  get\_multi ( $keys )  
![None.gif][]   \{  
![None.gif][]       if  ( ! $this \-> \_active)  
![None.gif][]          return   false ;  
![None.gif][]           
![None.gif][]       $this \-> stats\[ ' get\_multi ' \] \++ ;  
![None.gif][]        
![None.gif][]       foreach  ( $keys   as   $key )  
![None.gif][]      \{  
![None.gif][]          $sock   =   $this \-> get\_sock( $key );  
![None.gif][]          if  ( ! is\_resource ( $sock ))  continue ;  
![None.gif][]          $key   =   is\_array ( $key )  ?   $key \[ 1 \]  :   $key ;  
![None.gif][]          if  ( ! isset ( $sock\_keys \[ $sock \]))  
![None.gif][]         \{  
![None.gif][]             $sock\_keys \[ $sock \]  =   array ();  
![None.gif][]             $socks \[\]  =   $sock ;  
![None.gif][]         \}  
![None.gif][]          $sock\_keys \[ $sock \]\[\]  =   $key ;  
![None.gif][]      \}  
![None.gif][]        
![None.gif][]       //  Send out the requests   
![None.gif][]        foreach  ( $socks   as   $sock )  
![None.gif][]      \{  
![None.gif][]          $cmd   =   " get " ;  
![None.gif][]          foreach  ( $sock\_keys \[ $sock \]  as   $key )  
![None.gif][]         \{  
![None.gif][]             $cmd   .=   "   " .   $key ;  
![None.gif][]         \}  
![None.gif][]          $cmd   .=   "  " ;  
![None.gif][]           
![None.gif][]          if  ( fwrite ( $sock ,   $cmd ,   strlen ( $cmd )))  
![None.gif][]         \{  
![None.gif][]             $gather \[\]  =   $sock ;  
![None.gif][]         \}  else   
![None.gif][]         \{  
![None.gif][]             $this \-> \_dead\_sock( $sock );  
![None.gif][]         \}  
![None.gif][]      \}  
![None.gif][]        
![None.gif][]       //  Parse responses   
![None.gif][]        $val   =   array ();  
![None.gif][]       foreach  ( $gather   as   $sock )  
![None.gif][]      \{  
![None.gif][]          $this \-> \_load\_items( $sock ,   $val );  
![None.gif][]      \}  
![None.gif][]        
![None.gif][]       if  ( $this \-> \_debug)  
![None.gif][]          foreach  ( $val   as   $k   =>   $v )  
![None.gif][]             printf ( " MemCache: got %s => %s  " ,   $k ,   $v );  
![None.gif][]              
![None.gif][]       return   $val ;  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ incr()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Increments $key (optionally) by $amt  
![None.gif][]    \*  
![None.gif][]    \* @param   string   $key     Key to increment  
![None.gif][]    \* @param   interger $amt     (optional) amount to increment  
![None.gif][]    \*  
![None.gif][]    \* @return  interger New key value?  
![None.gif][]    \* @access  public  
![None.gif][]     \*/   
![None.gif][]    function  incr ( $key ,   $amt = 1 )  
![None.gif][]   \{  
![None.gif][]       return   $this \-> \_incrdecr( ' incr ' ,   $key ,   $amt );  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ replace()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Overwrites an existing value for key; only works if key is already set  
![None.gif][]    \*  
![None.gif][]    \* @param   string   $key     Key to set value as  
![None.gif][]    \* @param   mixed    $value   Value to store  
![None.gif][]    \* @param   interger $exp     (optional) Experiation time  
![None.gif][]    \*  
![None.gif][]    \* @return  boolean  
![None.gif][]    \* @access  public  
![None.gif][]     \*/   
![None.gif][]    function  replace ( $key ,   $value ,   $exp = 0 )  
![None.gif][]   \{  
![None.gif][]       return   $this \-> \_set( ' replace ' ,   $key ,   $value ,   $exp );  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ run\_command()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Passes through $cmd to the memcache server connected by $sock; returns   
![None.gif][]    \* output as an array (null array if no output)  
![None.gif][]    \*  
![None.gif][]    \* NOTE: due to a possible bug in how PHP reads while using fgets(), each  
![None.gif][]    \*       line may not be terminated by a  .  More specifically, my testing  
![None.gif][]    \*       has shown that, on FreeBSD at least, each line is terminated only  
![None.gif][]    \*       with a  .  This is with the PHP flag auto\_detect\_line\_endings set  
![None.gif][]    \*       to falase (the default).  
![None.gif][]    \*  
![None.gif][]    \* @param   resource $sock    Socket to send command on  
![None.gif][]    \* @param   string   $cmd     Command to run  
![None.gif][]    \*  
![None.gif][]    \* @return  array    Output array  
![None.gif][]    \* @access  public  
![None.gif][]     \*/   
![None.gif][]    function  run\_command ( $sock ,   $cmd )  
![None.gif][]   \{  
![None.gif][]       if  ( ! is\_resource ( $sock ))  
![None.gif][]          return   array ();  
![None.gif][]        
![None.gif][]       if  ( ! fwrite ( $sock ,   $cmd ,   strlen ( $cmd )))  
![None.gif][]          return   array ();  
![None.gif][]           
![None.gif][]       while  ( true )  
![None.gif][]      \{  
![None.gif][]          $res   =   fgets ( $sock );  
![None.gif][]          $ret \[\]  =   $res ;  
![None.gif][]          if  ( preg\_match ( ' /^END/ ' ,   $res ))  
![None.gif][]             break ;  
![None.gif][]          if  ( strlen ( $res )  ==   0 )  
![None.gif][]             break ;  
![None.gif][]      \}  
![None.gif][]       return   $ret ;  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ set()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Unconditionally sets a key to a given value in the memcache.  Returns true  
![None.gif][]    \* if set successfully.  
![None.gif][]    \*  
![None.gif][]    \* @param   string   $key     Key to set value as  
![None.gif][]    \* @param   mixed    $value   Value to set  
![None.gif][]    \* @param   interger $exp     (optional) Experiation time  
![None.gif][]    \*  
![None.gif][]    \* @return  boolean  TRUE on success  
![None.gif][]    \* @access  public  
![None.gif][]     \*/   
![None.gif][]    function  set ( $key ,   $value ,   $exp = 0 )  
![None.gif][]   \{  
![None.gif][]       return   $this \-> \_set( ' set ' ,   $key ,   $value ,   $exp );  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ set\_compress\_threshold()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Sets the compression threshold  
![None.gif][]    \*  
![None.gif][]    \* @param   interger $thresh  Threshold to compress if larger than  
![None.gif][]    \*  
![None.gif][]    \* @access  public  
![None.gif][]     \*/   
![None.gif][]    function  set\_compress\_threshold ( $thresh )  
![None.gif][]   \{  
![None.gif][]       $this \-> \_compress\_threshold  =   $thresh ;  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ set\_debug()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Sets the debug flag  
![None.gif][]    \*  
![None.gif][]    \* @param   boolean  $dbg     TRUE for debugging, FALSE otherwise  
![None.gif][]    \*  
![None.gif][]    \* @access  public  
![None.gif][]    \*  
![None.gif][]    \* @see     memcahced::memcached  
![None.gif][]     \*/   
![None.gif][]    function  set\_debug ( $dbg )  
![None.gif][]   \{  
![None.gif][]       $this \-> \_debug  =   $dbg ;  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ set\_servers()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Sets the server list to distribute key gets and puts between  
![None.gif][]    \*  
![None.gif][]    \* @param   array    $list    Array of servers to connect to  
![None.gif][]    \*  
![None.gif][]    \* @access  public  
![None.gif][]    \*  
![None.gif][]    \* @see     memcached::memcached()  
![None.gif][]     \*/   
![None.gif][]    function  set\_servers ( $list )  
![None.gif][]   \{  
![None.gif][]       $this \-> \_servers  =   $list ;  
![None.gif][]       $this \-> \_active  =   count ( $list );  
![None.gif][]       $this \-> \_buckets  =   null ;  
![None.gif][]       $this \-> \_bucketcount  =   0 ;  
![None.gif][]        
![None.gif][]       $this \-> \_single\_sock  =   null ;  
![None.gif][]       if  ( $this \-> \_active  ==   1 )  
![None.gif][]          $this \-> \_single\_sock  =   $this \-> \_servers\[ 0 \];  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \}\}\}  
![None.gif][]   // \{ \{ \{ private methods  
![None.gif][]   // \{ \{ \{ \_close\_sock()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Close the specified socket  
![None.gif][]    \*  
![None.gif][]    \* @param   string   $sock    Socket to close  
![None.gif][]    \*  
![None.gif][]    \* @access  private  
![None.gif][]     \*/   
![None.gif][]    function  \_close\_sock ( $sock )  
![None.gif][]   \{  
![None.gif][]       $host   =   array\_search ( $sock ,   $this \-> \_cache\_sock);  
![None.gif][]       fclose ( $this \-> \_cache\_sock\[ $host \]);  
![None.gif][]       unset ( $this \-> \_cache\_sock\[ $host \]);  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ \_connect\_sock()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Connects $sock to $host, timing out after $timeout  
![None.gif][]    \*  
![None.gif][]    \* @param   interger $sock    Socket to connect  
![None.gif][]    \* @param   string   $host    Host:IP to connect to  
![None.gif][]    \* @param   float    $timeout (optional) Timeout value, defaults to 0.25s  
![None.gif][]    \*  
![None.gif][]    \* @return  boolean  
![None.gif][]    \* @access  private  
![None.gif][]     \*/   
![None.gif][]    function  \_connect\_sock ( & $sock ,   $host ,   $timeout   =   0.25 )  
![None.gif][]   \{  
![None.gif][]       list  ( $ip ,   $port )  =   explode ( " : " ,   $host );  
![None.gif][]       if  ( $this \-> \_persistant  ==   1 )  
![None.gif][]      \{  
![None.gif][]          $sock   =  @ pfsockopen ( $ip ,   $port ,   $errno ,   $errstr ,   $timeout );  
![None.gif][]      \}  else   
![None.gif][]      \{  
![None.gif][]          $sock   =  @ fsockopen ( $ip ,   $port ,   $errno ,   $errstr ,   $timeout );  
![None.gif][]      \}  
![None.gif][]        
![None.gif][]       if  ( ! $sock )  
![None.gif][]          return   false ;  
![None.gif][]       return   true ;  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ \_dead\_sock()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Marks a host as dead until 30-40 seconds in the future  
![None.gif][]    \*  
![None.gif][]    \* @param   string   $sock    Socket to mark as dead  
![None.gif][]    \*  
![None.gif][]    \* @access  private  
![None.gif][]     \*/   
![None.gif][]    function  \_dead\_sock ( $sock )  
![None.gif][]   \{  
![None.gif][]       $host   =   array\_search ( $sock ,   $this \-> \_cache\_sock);  
![None.gif][]       list  ( $ip ,   $port )  =   explode ( " : " ,   $host );  
![None.gif][]       $this \-> \_host\_dead\[ $ip \]  =   time ()  \+   30   \+   intval ( rand ( 0 ,   10 ));  
![None.gif][]       $this \-> \_host\_dead\[ $host \]  =   $this \-> \_host\_dead\[ $ip \];  
![None.gif][]       unset ( $this \-> \_cache\_sock\[ $host \]);  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ get\_sock()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* get\_sock  
![None.gif][]    \*  
![None.gif][]    \* @param   string   $key     Key to retrieve value for;  
![None.gif][]    \*  
![None.gif][]    \* @return  mixed    resource on success, false on failure  
![None.gif][]    \* @access  private  
![None.gif][]     \*/   
![None.gif][]    function  get\_sock ( $key )  
![None.gif][]   \{  
![None.gif][]       if  ( ! $this \-> \_active)  
![None.gif][]          return   false ;  
![None.gif][]  
![None.gif][]       if  ( $this \-> \_single\_sock  !==   null )  
![None.gif][]          return   $this \-> sock\_to\_host( $this \-> \_single\_sock);  
![None.gif][]        
![None.gif][]       $hv   =   is\_array ( $key )  ?   intval ( $key \[ 0 \])  :   $this \-> \_hashfunc( $key );  
![None.gif][]        
![None.gif][]       if  ( $this \-> \_buckets  ===   null )  
![None.gif][]      \{  
![None.gif][]          foreach  ( $this \-> \_servers  as   $v )  
![None.gif][]         \{  
![None.gif][]             if  ( is\_array ( $v ))  
![None.gif][]            \{  
![None.gif][]                for  ( $i = 0 ;  $i < $v \[ 1 \];  $i \++ )  
![None.gif][]                   $bu \[\]  =   $v \[ 0 \];  
![None.gif][]            \}  else   
![None.gif][]            \{  
![None.gif][]                $bu \[\]  =   $v ;  
![None.gif][]            \}  
![None.gif][]         \}  
![None.gif][]          $this \-> \_buckets  =   $bu ;  
![None.gif][]          $this \-> \_bucketcount  =   count ( $bu );  
![None.gif][]      \}  
![None.gif][]        
![None.gif][]       $realkey   =   is\_array ( $key )  ?   $key \[ 1 \]  :   $key ;  
![None.gif][]       for  ( $tries   =   0 ;  $tries < 20 ;  $tries \++ )  
![None.gif][]      \{  
![None.gif][]          $host   =   $this \-> \_buckets\[ $hv   %   $this \-> \_bucketcount\];  
![None.gif][]          $sock   =   $this \-> sock\_to\_host( $host );  
![None.gif][]          if  ( is\_resource ( $sock ))  
![None.gif][]             return   $sock ;  
![None.gif][]          $hv   \+=   $this \-> \_hashfunc( $tries   .   $realkey );  
![None.gif][]      \}  
![None.gif][]        
![None.gif][]       return   false ;  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ \_hashfunc()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Creates a hash interger based on the $key  
![None.gif][]    \*  
![None.gif][]    \* @param   string   $key     Key to hash  
![None.gif][]    \*  
![None.gif][]    \* @return  interger Hash value  
![None.gif][]    \* @access  private  
![None.gif][]     \*/   
![None.gif][]    function  \_hashfunc ( $key )  
![None.gif][]   \{  
![None.gif][]       $hash   =   0 ;  
![None.gif][]       for  ( $i = 0 ;  $i < strlen ( $key );  $i \++ )  
![None.gif][]      \{  
![None.gif][]          $hash   =   $hash \* 33   \+   ord ( $key \[ $i \]);  
![None.gif][]      \}  
![None.gif][]        
![None.gif][]       return   $hash ;  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ \_incrdecr()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Perform increment/decriment on $key  
![None.gif][]    \*  
![None.gif][]    \* @param   string   $cmd     Command to perform  
![None.gif][]    \* @param   string   $key     Key to perform it on  
![None.gif][]    \* @param   interger $amt     Amount to adjust  
![None.gif][]    \*  
![None.gif][]    \* @return  interger    New value of $key  
![None.gif][]    \* @access  private  
![None.gif][]     \*/   
![None.gif][]    function  \_incrdecr ( $cmd ,   $key ,   $amt = 1 )  
![None.gif][]   \{  
![None.gif][]       if  ( ! $this \-> \_active)  
![None.gif][]          return   null ;  
![None.gif][]           
![None.gif][]       $sock   =   $this \-> get\_sock( $key );  
![None.gif][]       if  ( ! is\_resource ( $sock ))  
![None.gif][]          return   null ;  
![None.gif][]           
![None.gif][]       $key   =   is\_array ( $key )  ?   $key \[ 1 \]  :   $key ;  
![None.gif][]       $this \-> stats\[ $cmd \] \++ ;  
![None.gif][]       if  ( ! fwrite ( $sock ,   " $cmd $key $amt  " ))  
![None.gif][]          return   $this \-> \_dead\_sock( $sock );  
![None.gif][]           
![None.gif][]       stream\_set\_timeout ( $sock ,   1 ,   0 );  
![None.gif][]       $line   =   fgets ( $sock );  
![None.gif][]       if  ( ! preg\_match ( ' /^(d+)/ ' ,   $line ,   $match ))  
![None.gif][]          return   null ;  
![None.gif][]       return   $match \[ 1 \];  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ \_load\_items()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Load items into $ret from $sock  
![None.gif][]    \*  
![None.gif][]    \* @param   resource $sock    Socket to read from  
![None.gif][]    \* @param   array    $ret     Returned values  
![None.gif][]    \*  
![None.gif][]    \* @access  private  
![None.gif][]     \*/   
![None.gif][]    function  \_load\_items ( $sock ,   & $ret )  
![None.gif][]   \{  
![None.gif][]       while  ( 1 )  
![None.gif][]      \{  
![None.gif][]          $decl   =   fgets ( $sock );  
![None.gif][]          if  ( $decl   ==   " END  " )  
![None.gif][]         \{  
![None.gif][]             return   true ;  
![None.gif][]         \}  elseif  ( preg\_match ( ' /^VALUE (S+) (d+) (d+) $/ ' ,   $decl ,   $match ))  
![None.gif][]         \{  
![None.gif][]             list ( $rkey ,   $flags ,   $len )  =   array ( $match \[ 1 \] ,   $match \[ 2 \] ,   $match \[ 3 \]);  
![None.gif][]             $bneed   =   $len \+ 2 ;  
![None.gif][]             $offset   =   0 ;  
![None.gif][]              
![None.gif][]             while  ( $bneed   >   0 )  
![None.gif][]            \{  
![None.gif][]                $data   =   fread ( $sock ,   $bneed );  
![None.gif][]                $n   =   strlen ( $data );  
![None.gif][]                if  ( $n   ==   0 )  
![None.gif][]                   break ;  
![None.gif][]                $offset   \+=   $n ;  
![None.gif][]                $bneed   \-=   $n ;  
![None.gif][]                $ret \[ $rkey \]  .=   $data ;  
![None.gif][]            \}  
![None.gif][]              
![None.gif][]             if  ( $offset   !=   $len \+ 2 )  
![None.gif][]            \{  
![None.gif][]                //  Something is borked!   
![None.gif][]                 if  ( $this \-> \_debug)  
![None.gif][]                   printf ( " Something is borked!  key %s expecting %d got %d length  " ,   $rkey ,   $len \+ 2 ,   $offset );  
![None.gif][]  
![None.gif][]                unset ( $ret \[ $rkey \]);  
![None.gif][]                $this \-> \_close\_sock( $sock );  
![None.gif][]                return   false ;  
![None.gif][]            \}  
![None.gif][]              
![None.gif][]             $ret \[ $rkey \]  =   rtrim ( $ret \[ $rkey \]);  
![None.gif][]  
![None.gif][]             if  ( $this \-> \_have\_zlib  &&   $flags   &  MEMCACHE\_COMPRESSED)  
![None.gif][]                $ret \[ $rkey \]  =   gzuncompress ( $ret \[ $rkey \]);  
![None.gif][]  
![None.gif][]             if  ( $flags   &  MEMCACHE\_SERIALIZED)  
![None.gif][]                $ret \[ $rkey \]  =   unserialize ( $ret \[ $rkey \]);  
![None.gif][]  
![None.gif][]         \}  else    
![None.gif][]         \{  
![None.gif][]             print ( " Error parsing memcached response  " );  
![None.gif][]             return   0 ;  
![None.gif][]         \}  
![None.gif][]      \}  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ \_set()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Performs the requested storage operation to the memcache server  
![None.gif][]    \*  
![None.gif][]    \* @param   string   $cmd     Command to perform  
![None.gif][]    \* @param   string   $key     Key to act on  
![None.gif][]    \* @param   mixed    $val     What we need to store  
![None.gif][]    \* @param   interger $exp     When it should expire  
![None.gif][]    \*  
![None.gif][]    \* @return  boolean  
![None.gif][]    \* @access  private  
![None.gif][]     \*/   
![None.gif][]    function  \_set ( $cmd ,   $key ,   $val ,   $exp )  
![None.gif][]   \{  
![None.gif][]       if  ( ! $this \-> \_active)  
![None.gif][]          return   false ;  
![None.gif][]           
![None.gif][]       $sock   =   $this \-> get\_sock( $key );  
![None.gif][]       if  ( ! is\_resource ( $sock ))  
![None.gif][]          return   false ;  
![None.gif][]           
![None.gif][]       $this \-> stats\[ $cmd \] \++ ;  
![None.gif][]        
![None.gif][]       $flags   =   0 ;  
![None.gif][]        
![None.gif][]       if  ( ! is\_scalar ( $val ))  
![None.gif][]      \{  
![None.gif][]          $val   =   serialize ( $val );  
![None.gif][]          $flags   |=  MEMCACHE\_SERIALIZED;  
![None.gif][]          if  ( $this \-> \_debug)  
![None.gif][]             printf ( " client: serializing data as it is not scalar  " );  
![None.gif][]      \}  
![None.gif][]        
![None.gif][]       $len   =   strlen ( $val );  
![None.gif][]        
![None.gif][]       if  ( $this \-> \_have\_zlib  &&   $this \-> \_compress\_enable  &&    
![None.gif][]           $this \-> \_compress\_threshold  &&   $len   >=   $this \-> \_compress\_threshold)  
![None.gif][]      \{  
![None.gif][]          $c\_val   =   gzcompress ( $val ,   9 );  
![None.gif][]          $c\_len   =   strlen ( $c\_val );  
![None.gif][]           
![None.gif][]          if  ( $c\_len   <   $len \* ( 1   \-  COMPRESS\_SAVINGS))  
![None.gif][]         \{  
![None.gif][]             if  ( $this \-> \_debug)  
![None.gif][]                printf ( " client: compressing data; was %d bytes is now %d bytes  " ,   $len ,   $c\_len );  
![None.gif][]             $val   =   $c\_val ;  
![None.gif][]             $len   =   $c\_len ;  
![None.gif][]             $flags   |=  MEMCACHE\_COMPRESSED;  
![None.gif][]         \}  
![None.gif][]      \}  
![None.gif][]       if  ( ! fwrite ( $sock ,   " $cmd $key $flags $exp $len $val  " ))  
![None.gif][]          return   $this \-> \_dead\_sock( $sock );  
![None.gif][]           
![None.gif][]       $line   =   trim ( fgets ( $sock ));  
![None.gif][]        
![None.gif][]       if  ( $this \-> \_debug)  
![None.gif][]      \{  
![None.gif][]          if  ( $flags   &  MEMCACHE\_COMPRESSED)  
![None.gif][]             $val   =   ' compressed data ' ;  
![None.gif][]          printf ( " MemCache: %s %s => %s (%s)  " ,   $cmd ,   $key ,   $val ,   $line );  
![None.gif][]      \}  
![None.gif][]       if  ( $line   ==   " STORED " )  
![None.gif][]          return   true ;  
![None.gif][]       return   false ;  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \{ \{ \{ sock\_to\_host()   
![None.gif][]   
![None.gif][]    /\* \*  
![None.gif][]    \* Returns the socket for the host  
![None.gif][]    \*  
![None.gif][]    \* @param   string   $host    Host:IP to get socket for  
![None.gif][]    \*  
![None.gif][]    \* @return  mixed    IO Stream or false  
![None.gif][]    \* @access  private  
![None.gif][]     \*/   
![None.gif][]    function  sock\_to\_host ( $host )  
![None.gif][]   \{  
![None.gif][]       if  ( isset ( $this \-> \_cache\_sock\[ $host \]))  
![None.gif][]          return   $this \-> \_cache\_sock\[ $host \];  
![None.gif][]        
![None.gif][]       $now   =   time ();  
![None.gif][]       list  ( $ip ,   $port )  =   explode  ( " : " ,   $host );  
![None.gif][]       if  ( isset ( $this \-> \_host\_dead\[ $host \])  &&   $this \-> \_host\_dead\[ $host \]  >   $now   ||   
![None.gif][]           isset ( $this \-> \_host\_dead\[ $ip \])  &&   $this \-> \_host\_dead\[ $ip \]  >   $now )  
![None.gif][]          return   null ;  
![None.gif][]           
![None.gif][]       if  ( ! $this \-> \_connect\_sock( $sock ,   $host ))  
![None.gif][]          return   $this \-> \_dead\_sock( $host );  
![None.gif][]           
![None.gif][]       //  Do not buffer writes   
![None.gif][]        stream\_set\_write\_buffer ( $sock ,   0 );  
![None.gif][]        
![None.gif][]       $this \-> \_cache\_sock\[ $host \]  =   $sock ;  
![None.gif][]        
![None.gif][]       return   $this \-> \_cache\_sock\[ $host \];  
![None.gif][]   \}  
![None.gif][]  
![None.gif][]    //  \}\}\}  
![None.gif][]   // \}\}\}  
![None.gif][]   // \}\}\}   
![None.gif][] \}  
![None.gif][]  
![None.gif][] //  \}\}\}   
![None.gif][] ?>   
![None.gif][]

[None.gif]: /images/20220828/3f602d82c8c843a9a7babd73a7f1c50f.png