發帖、發微博、點贊、評論等這些操作很頻繁的動作如果并發量小，直接入庫是最簡單的
但是并發量一大，數據庫肯定扛不住，這時可采取延遲發布：先將發布動作保存在隊列里，后臺進程循環獲取再入庫
模擬發布微博先進入redis隊列
weibo_redis.php
<?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);?>
模擬后臺進程從redis隊列獲取微博
Pdodb.class.php
<?phpclass 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(); } }}weibo_mysql.php
<?phprequire_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秒}
后臺執行weibo_mysql.php
nohup php /var/www/html/big/weibo_mysql.php &
以上這篇php結合redis高并發下發帖、發微博的實現方法就是小編分享給大家的全部內容了，希望能給大家一個參考，也希望大家多多支持VeVb武林網。
新聞熱點
疑難解答
圖片精選
