web / hood · Commits

Go to a project

Authored by 沈海生
Commit 867fba1f8ec5f229a0ba64619ec75a97877a4229 1 parent 1c8e4235

ssdb方法

Inline Side-by-side
Showing 1 changed file with 345 additions and 0 deletions
<?php
/**
* Created by PhpStorm.
* User: shin
* Date: 15/10/19
* Time: 下午3:12
*/
namespace Hood\Cache;
use Hood\Core\Root;
use Hood\Cache\Ssdb;
use Hood\Debug\DebugException;
use Hood\Cache\Ssdb\SSDBException;
class CacheSSDB extends Root implements CacheInterface
{
private $instances = array();
private $section = 'ssdb';
private $node = 'servers';
private $childNodes = 'hosts';
private $port = 8888;
private $timeout = 5000;//毫秒
private $persistentID = 'hood.ssdb';
public function __construct($prefix = '', $persistentID = 'hood.ssdb')
{
parent::__construct();
$this->persistentID = $persistentID;
}
/**
* 设置子节点
* @param $childNode
* @return $this
*/
public function setChildNodes($childNode)
{
$this->childNodes = $childNode;
return $this;
}
/**
* 设置配置的块
* @param $section
* @return $this
*/
public function setSection($section)
{
$this->section = $section;
return $this;
}
/**
* 设置配置的块节点
* @param $node
* @return $this
*/
public function setNode($node = null)
{
if ($node != null) $this->node = $node;
return $this;
}
/**
* 设置共享连接ID
* @param $persistentID
* @return $this
*/
public function setPersistentID($persistentID)
{
$this->persistentID = $persistentID;
return $this;
}
/**
* 指定连接id删除
* @param $persistentID
* @return $this
*/
public function delInstances($persistentID)
{
if (isset($this->instances[$persistentID])) {
unset($this->instances[$persistentID]);
}
return $this;
}
public function init()
{
if (isset($this->instances[$this->persistentID])) {
return $this->instances[$this->persistentID];
} else {
$server = $this->getServerHost('cache');
$_serverHosts = $server->getServerConfig($this->section, $this->node);
if (empty($_serverHosts)) {
throw new DebugException('ssdb node :' . $this->node . ' is null');
}
if (!isset($_serverHosts[$this->childNodes]) || empty($_serverHosts[$this->childNodes])) {
throw new DebugException('ssdb Host:' . $this->childNodes . ' is Null.');
}
$allServerAndPort = $this->_makeHosts($_serverHosts[$this->childNodes]);
$serverAndPort = $allServerAndPort[rand(0, count($allServerAndPort) - 1)];
$host = $serverAndPort[0];
if (isset($serverAndPort[1]) && !empty($serverAndPort[1])) {
$this->port = $serverAndPort[1];
}
try {
$ssdb = new Ssdb\SimpleSSDB($host, $this->port, $this->timeout);
} catch (SSDBException $e) {
throw new DebugException('ssdb connetc error:' . $host . ':' . $this->port . ' ' . $e->getMessage());
}
$this->instances[$this->persistentID] = $ssdb;
return $ssdb;
}
}
/**
* 组织host
* @param array $hosts
* @return array
*/
private function _makeHosts($hosts)
{
$servers = explode(',', $hosts);
$_server = array();
foreach ($servers as $val) {
$_server[] = explode(':', $val);
}
return $_server;
}
/**
* @param $key
* @return mixed
*/
public function get($key)
{
return $this->init()->get($key);
}
/**
*
* @param $key
* @param $value
* @param $second
* @return bool
* @throws DebugException
*/
public function add($key, $value, $second)
{
$result = $this->init()->setnx($key, $value);
if ($result == 1) {
$this->expire($key, $second);
return true;
} else {
return false;
}
}
/**
* 设置过期时间，秒
* @param $key
* @param $ttl
* @throws DebugException
*/
public function expire($key, $ttl)
{
return $this->init()->expire($key, $ttl);
}
/**
* @param $key
* @param $value
* @param $minutes
* @return mixed
*/
public function set($key, $value, $second)
{
return $this->init()->setx($key, $value, $second);
}
/**
* @param $key
* @param int $value
* @return mixed
*/
public function increment($key, $value = 1)
{
}
/**
* @param $key
* @param int $value
* @return mixed
*/
public function decrement($key, $value = 1)
{
}
/**
* @param $key
* @return mixed
*/
public function delete($key)
{
return $this->init()->del($key);
}
/**
* @param $tagName
* @return $this
*/
public function tag($tagName)
{
}
/**
* zset类型添加
* @param $zname
* @param $zkey
* @param $score
* @return mixed
* @throws DebugException
*/
public function zset($zname, $zkey, $score)
{
return $this->init()->zset($zname, $zkey, $score);
}
/**
* 将zset里的东西列表
* @param $name_start
* @param $name_end
* @param $limit
* @throws DebugException
*/
public function zlist($name_start, $name_end, $limit)
{
$this->init()->zlist($name_start, $name_end, $limit);
}
/**
* 返回 zset 中的元素个数.
* @param $zname
* @return mixed
* @throws DebugException
*/
public function zsize($zname)
{
return $this->init()->zsize($zname);
}
/**
* 删除权重处于区间 [start,end] 的元素.包含边界
* @param $zname
* @param $score_start
* @param $score_end
*/
public function zremrangebyscore($zname, $score_start, $score_end)
{
return $this->init()->zremrangebyscore($zname, $score_start, $score_end);
}
/**
* 从 zset 首部删除并返回 `limit` 个元素.
* @param $zname
* @param $limit
* @return mixed
* @throws DebugException
*/
public function zpop_front($zname, $limit)
{
return $this->init()->zpop_front($zname, $limit);
}
/**
* 从 zset 尾部删除并返回 `limit` 个元素.
* @param $zname
* @param $limit
* @return mixed
* @throws DebugException
*/
public function zpop_back($zname, $limit)
{
return $this->init()->zpop_back($zname, $limit);
}
/**
* 根据下标索引区间 [offset, offset + limit) 获取 key-score 对, 下标从 0 开始
* @param $zname
* @param $offset
* @param $limist
* @return mixed
* @throws DebugException
*/
public function zrange($zname, $offset, $limist)
{
return $this->init()->zrange($zname, $offset, $limist);
}
/**
* 根据下标索引区间 [offset, offset + limit) 获取 key-score 对, 下标从 0 开始 zrrange 是反向顺序获取.
* @param $zname
* @param $offset
* @param $limist
* @return mixed
* @throws DebugException
*/
public function zrrange($zname, $offset, $limist)
{
return $this->init()->zrrange($zname, $offset, $limist);
}
}
... ...