From e9455baeeeda899a801d879224da2a729330fc71 Mon Sep 17 00:00:00 2001
From: aborn <loveaborn@foxmail.com>
Date: Sat, 15 Mar 2014 17:55:31 +0800
Subject: [PATCH] add dredis.php for distributed system.

---
 phpd/dredis.php | 98 +++++++++++++++++++++++++++++++++++++++++++++++++
 phpd/hello.php  |  8 +++-
 phpd/index2.php | 61 +++++++++++++++++++-----------
 3 files changed, 144 insertions(+), 23 deletions(-)
 create mode 100644 phpd/dredis.php

diff --git a/phpd/dredis.php b/phpd/dredis.php
new file mode 100644
index 0000000..12f346b
--- /dev/null
+++ b/phpd/dredis.php
@@ -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;
+}
+
+
+ ?>
diff --git a/phpd/hello.php b/phpd/hello.php
index 7450102..d6dfc97 100644
--- a/phpd/hello.php
+++ b/phpd/hello.php
@@ -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");
+
+
+
 ?>
\ No newline at end of file
diff --git a/phpd/index2.php b/phpd/index2.php
index 6b00da4..312c3f9 100644
--- a/phpd/index2.php
+++ b/phpd/index2.php
@@ -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";
 }