<?php
//此处需要安装phpredis扩展
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
$redis->auth("php001");
//连接redis
$web_info= array(
 'uid' => $_REQUEST[uid], //发布者id
 'username' => $_REQUEST[username],//发布者用户名
 'content' =>$_REQUEST[content],//微博内容
);


//将数组转成json来存储
$list = json_encode($web_info);
//lpush向KEY对应的头部添加一个字符串元素
$redis->lpush('weibo_lists',$list);
$redis->close();
var_dump($list);
?>

<?php
class Pdodb{
 public function post($uid='',$username='',$content=''){
  try{
   $dsn = "mysql:localhost;dbname=localhost;dbname=big";
   $db = new PDO($dsn,'big','123456'); 
   $db->exec("SET NAMES UTF8");
   $sql ="insert into ih_weibo(uid,username,content)values('$uid','$username','$content')";
   //echo $sql;
   $db->exec($sql);
  }catch(PDOException $e){
   echo $e->getMessage();
  }
 }
}

<?php
require_once 'Pdodb.class.php';
set_time_limit(0); // 取消脚本运行时间的超时上限


$pdo = new Pdodb();
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);


while (true) {
 //返回的列表的大小。如果列表不存在或为空，该命令返回0。如果该键不是列表，该命令返回false
 if($redis -> lsize('weibo_lists')){
  //从LIST头部删除并返回删除数据
  $info = $redis->rpop('weibo_lists');
  $info = json_decode($info);
  $pdo->post($info->uid,$info->username,$info->content);
 }
 $redis->close();
 sleep(10);//延时10秒
}