You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
52 lines
1.4 KiB
52 lines
1.4 KiB
<?php
|
|
class LtCacheConnectionManager
|
|
{
|
|
public $configHandle;
|
|
protected $connectionAdapter;
|
|
|
|
public function getConnection($group, $node, $role)
|
|
{
|
|
if ($connection = $this->getNewConnection($group, $node, $role))
|
|
{
|
|
return array(
|
|
"connectionAdapter" => $this->connectionAdapter,
|
|
"connectionResource" => $connection
|
|
);
|
|
}
|
|
else
|
|
{
|
|
trigger_error("no cache server can be connected");
|
|
return false;
|
|
}
|
|
}
|
|
|
|
protected function getNewConnection($group, $node, $role)
|
|
{
|
|
$servers = $this->configHandle->get("cache.servers");
|
|
$hostTotal = count($servers[$group][$node][$role]);
|
|
$hostIndexArray = array_keys($servers[$group][$node][$role]);
|
|
while ($hostTotal)
|
|
{
|
|
$hashNumber = substr(microtime(),7,1) % $hostTotal;
|
|
$hostConfig = $servers[$group][$node][$role][$hostIndexArray[$hashNumber]];
|
|
$cacheFactory = new LtCacheAdapterFactory;
|
|
$this->connectionAdapter = $cacheFactory->getConnectionAdapter($hostConfig["adapter"]);
|
|
if ($connection = $this->connectionAdapter->connect($hostConfig))
|
|
{
|
|
return $connection;
|
|
}
|
|
else
|
|
{
|
|
//trigger_error('connection fail', E_USER_WARNING);
|
|
//delete the unavailable server
|
|
for ($i = $hashNumber; $i < $hostTotal - 1; $i ++)
|
|
{
|
|
$hostIndexArray[$i] = $hostIndexArray[$i+1];
|
|
}
|
|
unset($hostIndexArray[$hostTotal-1]);
|
|
$hostTotal --;
|
|
}//end else
|
|
}//end while
|
|
return false;
|
|
}
|
|
} |