zhangyuqing
/
configure_backup
mirror of https://github.com/aborn/configure.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

add dredis.php for distributed system.

This commit is contained in:
aborn 2014-03-15 17:55:31 +08:00
parent e0f078aaa8
commit e9455baeee
3 changed files with 144 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

98
phpd/dredis.php Normal file
View File

@ -0,0 +1,98 @@
<?php
/***
* INTRO
* The class provides an universal interface
* for call distributed redis system
*
* DATE
* 2014-03-15
*/
class dredis
{
$options = array(
'namespace' => 'Application_',
'servers' => array(
array('host' => '127.0.0.1', 'port' => 6379, 'alias' => 'mas01'),
array('host' => '127.0.0.1', 'port' => 6380, 'alias' => 'ins01')
array('host' => '127.0.0.1', 'port' => 6380, 'alias' => 'ins02')
array('host' => '10.8.8.10', 'port' => 6380, 'alias' => 'sla01')
array('host' => '10.8.8.10', 'port' => 6380, 'alias' => 'ins03')
array('host' => '10.8.8.10', 'port' => 6380, 'alias' => 'ins04')
)
);
}
require_once '/vagrant_data/data/rediska/library/Rediska.php';
$rediska = new Rediska($options);
var_dump(Rediska_Manager::getAll());
// Initialize key with name 'keyName'
if(Rediska_Manager::has('default')){
echo "<br/>";
echo "exist@@@@@@@@@@@@@@@";
echo "<br/>";
}
if(Rediska_Manager::add($rediska))
{
echo "add success";
} else {
echo "add failed";
}
$rediska->flushdb();
#return;
for ($i=0; $i<10; $i++)
{
$keyName="key$i";
$key = new Rediska_Key($keyName);
$keyValue="value_$i"."_first";
echo "<br/>";
$key->setValue($keyValue);
print "key:$keyName"." value:".$key->getValue(); #=> value
}
# $rediska->addServer('192.168.122.10', 6379);
$rediska->addServer('10.8.8.10', 6379);
$connection=$rediska->getConnectionByAlias ('0');
# $rediska->slaveOf($connection);
$rediska->removeServer($connection);
echo "<br/>";echo "<br/>";
echo "follow add 10.8.8.10 and delete 6380";
echo "<br/>";
for ($i=0; $i<10; $i++)
{
$keyName="key$i";
$key = new Rediska_Key($keyName);
$keyValue="value_$i"."_second";
echo "<br/>";
$oldValue = $key->getValue();
$key->setValue($keyValue);
print "key:$keyName"." value:".$key->getValue()." old value:$oldValue";
}
// Initialize Set with name 'setKeyName' and specified Rediska instance
$set = new Rediska_Key_Set('setKeyName', array('rediska' => $rediska));
// Print all elements
foreach($set as $element) {
print $element;
}
?>

8
phpd/hello.php
View File

@ -10,7 +10,13 @@ $options = array(
$rediska = new Rediska($options);
$rediska = Rediska_Manager::get('cache');
$rediska = Rediska_Manager::get('default');
print $rediska->getName(); #=> cache
$keyName = "key0";
$key = new Rediska_Key($keyName);
$key->setValue("zzzzzzzzzzzzz");
?>

61
phpd/index2.php
View File

@ -9,45 +9,62 @@ $options = array(
require_once '/vagrant_data/data/rediska/library/Rediska.php';
$rediska = new Rediska($options);
print $rediska->getName();
// Initialize key with name 'keyName'
for ($i=0; $i<10; $i++)
{
$keyName="key$i";
$key = new Rediska_Key($keyName);
$keyValue="value444____$i";
var_dump(Rediska_Manager::getAll());
// Initialize key with name 'keyName'
if(Rediska_Manager::has('default')){
echo "<br/>";
echo "old value";
print $key->getValue($keyValue);
$key->setValue($keyValue);
echo "exist@@@@@@@@@@@@@@@";
echo "<br/>";
echo "new value";
print $key; #=> value
}
$rediska->addServer('192.168.122.10', 6379);
if(Rediska_Manager::add($rediska))
{
echo "add success";
} else {
echo "add failed";
}
$rediska->flushdb();
#return;
for ($i=0; $i<10; $i++)
{
$keyName="key$i";
$key = new Rediska_Key($keyName);
$keyValue="value_$i"."_first";
echo "<br/>";
$key->setValue($keyValue);
print "key:$keyName"." value:".$key->getValue(); #=> value
}
# $rediska->addServer('192.168.122.10', 6379);
$rediska->addServer('10.8.8.10', 6379);
$connection=$rediska->getConnectionByAlias ('0');
#$rediska->slaveOf($connection);
# $rediska->slaveOf($connection);
$rediska->removeServer($connection);
echo "<br/>";echo "<br/>";
echo "follow add 10.8.8.10 and delete 6380";
echo "<br/>";
for ($i=0; $i<10; $i++)
{
$keyName="key$i";
$key = new Rediska_Key($keyName);
$keyValue="value444____$i";
$keyValue="value_$i"."_second";
echo "<br/>";
echo "changed value";
print $key->getValue($keyValue);
$oldValue = $key->getValue();
# $key->setValue($keyValue);
# echo "<br/>";
# echo "new value";
# print $key; #=> value
$key->setValue($keyValue);
print "key:$keyName"." value:".$key->getValue()." old value:$oldValue";
}