Heim >php教程 >php手册 >ssdb的Yii cache扩展

ssdb的Yii cache扩展

WBOY
WBOYOriginal
2016-06-06 20:12:181030Durchsuche

google的leveldb越来越被很多人接受。国内的ideawu基于leveldb还写了一个ssdb的前置扩展用来实现了很多功能,比如标准的getset和hget,hset还有zset,zget,也实现了队列。当然pub/sub就没有办法实现了。毕竟它和redis还是有点区别。 基于标准的ssdb的类,写了

google的leveldb越来越被很多人接受。国内的ideawu基于leveldb还写了一个ssdb的前置扩展用来实现了很多功能,比如标准的getset和hget,hset还有zset,zget,也实现了队列。当然pub/sub就没有办法实现了。毕竟它和redis还是有点区别。

基于标准的ssdb的类,写了个小扩展,扩展了Yii的Cache类:

    class?CSsdbCache?extends?CCache??
    {??
    ????/**?
    ?????*?@var?string?hostname?to?use?for?connecting?to?the?redis?server.?Defaults?to?'127.0.0.1'.?
    ?????*/??
    ????public?$hostname?=?'127.0.0.1';??
    ????/**?
    ?????*?@var?int?the?port?to?use?for?connecting?to?the?ssdb?server.?Default?port?is?8888.?
    ?????*/??
    ????public?$port?=?8888;??
    ????/**?
    ?????*?@var?float?
    ?????*/??
    ????public?$timeout?=?2000;??
    ????public?$serializer?=?false;??
    ????public?$_cache;??
    ????protected?$_cachekeys?=?'ssdb_cachekey';??
    ??????
    ????public?function?init()?{??
    ????????parent::init();??
    ????}??
    ????/**?
    ?????*?@return?SSDB?
    ?????*/??
    ????public?function?getSsdbCache()?{??
    ????????if?($this->_cache?!==?null)??
    ????????????return?$this->_cache;??
    ????????else?{??
    ????????????return?$this->_cache?=?new?SimpleSSDB($this->hostname,?$this->port,?$this->timeout);??
    ????????}??
    ????}??
    ????public?function?getkeys()?{??
    ????????return?$this->getSsdbCache()->hkeys($this->_cachekeys,?"",?"",?$this->getSsdbCache()->hsize($this->_cachekeys));??
    ????}??
    ????/**?
    ?????*?Retrieves?a?value?from?cache?with?a?specified?key.?
    ?????*?This?is?the?implementation?of?the?method?declared?in?the?parent?class.?
    ?????*?@param?string?$key?a?unique?key?identifying?the?cached?value?
    ?????*?@return?string|boolean?the?value?stored?in?cache,?false?if?the?value?is?not?in?the?cache?or?expired.?
    ?????*/??
    ????protected?function?getValue($key)?{??
    ????????return?unserialize($this->getSsdbCache()->get($key));??
    ????}??
    ??
    ????/**?
    ?????*?Stores?a?value?identified?by?a?key?in?cache.?
    ?????*?This?is?the?implementation?of?the?method?declared?in?the?parent?class.?
    ?????*?@param?string??$key????the?key?identifying?the?value?to?be?cached?
    ?????*?@param?string??$value??the?value?to?be?cached?
    ?????*?@param?integer?$expire?the?number?of?seconds?in?which?the?cached?value?will?expire.?0?means?never?expire.?
    ?????*?@return?boolean?true?if?the?value?is?successfully?stored?into?cache,?false?otherwise?
    ?????*/??
    ????protected?function?setValue($key,?$value,?$expire)?{??
    ????????$this->getSsdbCache()->hset($this->_cachekeys,?$key,?1);??
    ????????if?($expire?>?0)?{??
    ????????????//$expire?+=?time();??
    ????????????return?$this->getSsdbCache()->setx($key,?serialize($value),?(int)?$expire);??
    ????????}??
    ????????else?{??
    ????????????return?$this->getSsdbCache()->set($key,?serialize($value));??
    ????????}??
    ????}??
    ????/**?
    ?????*?Stores?a?value?identified?by?a?key?into?cache?if?the?cache?does?not?contain?this?key.?
    ?????*?This?is?the?implementation?of?the?method?declared?in?the?parent?class.?
    ?????*?@param?string??$key????the?key?identifying?the?value?to?be?cached?
    ?????*?@param?string??$value??the?value?to?be?cached?
    ?????*?@param?integer?$expire?the?number?of?seconds?in?which?the?cached?value?will?expire.?0?means?never?expire.?
    ?????*?@return?boolean?true?if?the?value?is?successfully?stored?into?cache,?false?otherwise?
    ?????*/??
    ????protected?function?addValue($key,?$value,?$expire)?{??
    ????????return?$this->setValue($key,?$value,?$expire);??
    ????}??
    ????/**?
    ?????*?Deletes?a?value?with?the?specified?key?from?cache?
    ?????*?This?is?the?implementation?of?the?method?declared?in?the?parent?class.?
    ?????*?@param?string?$key?the?key?of?the?value?to?be?deleted?
    ?????*?@return?boolean?if?no?error?happens?during?deletion?
    ?????*/??
    ????protected?function?deleteValue($key)?{??
    ????????$this->getSsdbCache()->hdel($this->_cachekeys,?$key);??
    ????????return?$this->getSsdbCache()->del($key);??
    ????}??
    ????/**?
    ?????*?@return?boolean?whether?the?flush?operation?was?successful.?
    ?????*/??
    ????protected?function?flushValues()?{??
    ????????$this->getSsdbCache()->multi_del($this->getkeys());??
    ????????return?$this->getSsdbCache()->hclear($this->_cachekeys);??
    ????}??
    }??

其实代码很简单,不过由于ssdb默认没有serialize功能,所以在存储之前,得先主动的serialize,然后get的时候unserialize。不然就没有办法存储数组了。

由于ssdb没有flush功能。所以利用hget/hset将所有的key存储下来。flush的时候把hget获取的key读出来删除。然后再清掉这个hget的key

最后还有expire。ssdb里的setx第三个参数。。。居然不是expire,而是ttl。开始的时候,一直都当成expire。结果浪费了很长时间

Stellungnahme:
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn