微博发布接口:
$weibo = new Weibo(); $uid = $weibo->get_uid(); $content =$weibo->get_content; $time = time(); $webi->post($uid,$content,$time);
此方法直接把微博内容写入Mysql。具体过程省略。
把消息写入到redis:
$redis = new Redis(localhost,6379);
$redis->connect();
$webiInfo = array('uid'=>get_uid(),'content'=>get_content(),'time'=>time());
$redis->lpush('weibo_list',json_encode($weiboInfo));
$redis->close();从redis中取出数据:
while(true){
if($redis->lsize('weibo_list') > 0){
$info = $redis->rpop('weibo_list');
$info = json_decode($info);
}else{
sleep(1);
}
}
$weibo->post($info->uid,$info->content,$info->time);
//插入数据的时候可以用一次性插入多条数据的方法,避免循环插入,不停的循环插入可能会导致死锁问题。
上一篇:怎么在php中地址页面缓存时间