##############test.php############
<?php
         $redis = new Redis();
         $redis->connect('172.25.11.5',6379) or die ("could net connect redis server");
   #      $query = "select * from test limit 9";
         $query = "select * from test";
         for ($key = 1; $key < 10; $key++)
         {
                 if (!$redis->get($key))
                 {
                         $connect = mysql_connect('172.25.11.6','redis','westos');
                         mysql_select_db(test);
                         $result = mysql_query($query);
                         //如果没有找到$key,就将该查询sql的结果缓存到redis
                         while ($row = mysql_fetch_assoc($result))
                         {
                                 $redis->set($row['id'],$row['name']);
                         }
                         $myserver = 'mysql';
                         break;
                 }
                 else
                 {
                         $myserver = "redis";
                        $data[$key] = $redis->get($key);
                 }
         }
        echo $myserver;
         echo "<br>";
         for ($key = 1; $key < 10; $key++)
         {
                 echo "number is <b><font color=#FF0000>$key</font></b>";
echo "<br>";
echo "name is <b><font color=#FF0000>$data[$key]</font></b>";
                echo "<br>";
         }
 ?>
###########worker.php#########
<?php
 $worker = new GearmanWorker();
 $worker->addServer();
 $worker->addFunction('syncToRedis', 'syncToRedis');
$redis = new Redis();
 $redis->connect('127.0.0.1', 6379);
while($worker->work());
 function syncToRedis($job)
 {
         global $redis;
         $workString = $job->workload();
         $work = json_decode($workString);
         if(!isset($work->id)){
                 return false;
         }
         $redis->set($work->id, $work->name);
 }
 ?>










