123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292 |
- <?php
- namespace KIF\Cache;
- use KIF\Exception\ParamsException;
- use Memcache as MemcacheResource;
- use KIF\Debug\Debug;
- use KIF\Verify;
- use KIF\Core\Config;
- class TTServer {
-
- static private $objMemcaches = array();
-
- private $servers;
-
- private $objMemcache;
- public function __construct($cluster_flag = 'default') {
- $ttserverConfig = Config::getInstance()->get('ttserver');
-
- if (!$ttserverConfig || !isset($ttserverConfig[$cluster_flag])) {
- throw new ParamsException("不存在的ttserver集群标志 {$cluster_flag}");
- }
- $this->servers = $ttserverConfig[$cluster_flag];
- if (!isset(self::$objMemcaches[$cluster_flag])) {
- $objMemcache = new MemcacheResource();
- foreach ($this->servers as $server) {
- $tmpHost = isset($server['host']) ? $server['host'] : '127.0.0.1';
- $tmpPort = isset($server['port']) ? $server['port'] : '11211';
- $tmpPersistent = isset($server['persistent']) ? (bool) $server['persistent'] : false;
- $tmpWeight = isset($server['weight']) ? $server['weight'] : 1;
- $tmpTimeout = isset($server['timeout']) ? $server['timeout'] : 2;
- $tmpRetry_interval = isset($server['retry_interval']) ? $server['retry_interval'] : 5;
- $tmpResult = $objMemcache->addServer($tmpHost, $tmpPort, $tmpPersistent
- , $tmpWeight, $tmpTimeout, $tmpRetry_interval
- );
- }
- self::$objMemcaches[$cluster_flag] = $objMemcache;
- }
- $this->objMemcache = self::$objMemcaches[$cluster_flag];
- }
-
- public function set($key, $value) {
- $begin_microtime = Debug::getTime();
- if (!is_scalar($value)) {
- $value = serialize($value);
- }
- $tmpResult = $this->objMemcache->set($key, $value);
- Debug::cache($this->servers, $key, Debug::getTime() - $begin_microtime, $tmpResult, 'set');
- return $tmpResult;
- }
-
- public function get($key) {
- $begin_microtime = Debug::getTime();
- $tmpResult = $this->objMemcache->get($key);
- if ($tmpResult !== false) {
-
- $tmpUnserializeVal = @unserialize($tmpResult);
- if ($tmpUnserializeVal !== false) {
- $tmpResult = $tmpUnserializeVal;
- }
- Debug::cache($this->servers, $key, Debug::getTime() - $begin_microtime, $tmpResult, 'get');
- return $tmpResult;
- }
- Debug::cache($this->servers, $key, Debug::getTime() - $begin_microtime, false, 'get');
- return false;
- }
-
- public function gets(array $keys) {
- if (empty($keys)) {
- return array();
- }
- $begin_microtime = Debug::getTime();
- $tmpResult = $this->objMemcache->get($keys);
- Debug::cache($this->servers, print_r($keys, true), Debug::getTime() - $begin_microtime, false, 'gets');
- if ($tmpResult === false) {
- return false;
- }
- $return = array();
- foreach ($keys as $key) {
- if (isset($tmpResult[$key])) {
-
- $tmpUnserializeVal = @unserialize($tmpResult[$key]);
- if ($tmpUnserializeVal !== false) {
- $return[$key] = $tmpUnserializeVal;
- } else {
- $return[$key] = $tmpResult[$key];
- }
- } else {
- $return[$key] = null;
- }
- }
- return $return;
- }
-
- public function delete($key) {
- $begin_microtime = Debug::getTime();
- $tmpResult = $this->objMemcache->delete($key);
- if ($tmpResult) {
- Debug::cache($this->servers, $key, Debug::getTime() - $begin_microtime, true, 'delete');
- return true;
- }
- Debug::cache($this->servers, $key, Debug::getTime() - $begin_microtime, false, 'delete');
- return false;
- }
-
- public function add($key, $value) {
- $begin_microtime = Debug::getTime();
- if (!is_scalar($value)) {
- $value = serialize($value);
- }
- $tmpResult = $this->objMemcache->add($key, $value);
- if ($tmpResult) {
- Debug::cache($this->servers, "{$key}::{$value}", Debug::getTime() - $begin_microtime, true, 'add');
- return true;
- }
- Debug::cache($this->servers, "{$key}::{$value}", Debug::getTime() - $begin_microtime, false, 'add');
- return false;
- }
-
- public function replace($key, $value) {
- $begin_microtime = Debug::getTime();
- if (!is_scalar($value)) {
- $value = serialize($value);
- }
- $tmpResult = $this->objMemcache->replace($key, $value);
- if ($tmpResult) {
- Debug::cache($this->servers, "{$key}::{$value}", Debug::getTime() - $begin_microtime, true, 'replace');
- return true;
- }
- Debug::cache($this->servers, "{$key}::{$value}", Debug::getTime() - $begin_microtime, false, 'replace');
- return false;
- }
-
- public function increment($key, $offset = 1) {
- $begin_microtime = Debug::getTime();
- $tmpGetResult = $this->get($key);
- if (is_null($tmpGetResult)) {
- Debug::cache($this->servers, "{$key}::{$offset}", Debug::getTime() - $begin_microtime, null, 'increment');
- return false;
- }
- if (!Verify::naturalNumber($tmpGetResult)) {
- Debug::cache($this->servers, "{$key}::{$offset}", Debug::getTime() - $begin_microtime, false, 'increment');
- return false;
- }
- $tmpResult = $this->objMemcache->increment($key, $offset);
- if (Verify::unsignedInt($tmpResult)) {
- Debug::cache($this->servers, "{$key}::{$offset}", Debug::getTime() - $begin_microtime, $tmpResult, 'increment');
- return $tmpResult;
- }
- Debug::cache($this->servers, "{$key}::{$offset}", Debug::getTime() - $begin_microtime, false, 'increment');
- return false;
- }
-
- public function decrement($key, $offset = 1) {
- $begin_microtime = Debug::getTime();
- $tmpGetResult = $this->get($key);
- if (is_null($tmpGetResult)) {
- Debug::cache($this->servers, "{$key}::{$offset}", Debug::getTime() - $begin_microtime, null, 'decrement');
- return false;
- }
- if (!Verify::naturalNumber($tmpGetResult)) {
- Debug::cache($this->servers, "{$key}::{$offset}", Debug::getTime() - $begin_microtime, false, 'decrement');
- return false;
- }
- $tmpResult = $this->objMemcache->decrement($key, $offset);
- if (Verify::naturalNumber($tmpResult)) {
- Debug::cache($this->servers, "{$key}::{$offset}", Debug::getTime() - $begin_microtime, $tmpResult, 'decrement');
- return $tmpResult;
- }
- Debug::cache($this->servers, "{$key}::{$offset}", Debug::getTime() - $begin_microtime, false, 'decrement');
- return false;
- }
- }
|