您好,登錄后才能下訂單哦!
這篇文章將為大家詳細(xì)講解有關(guān)怎么在php中利用redis高并發(fā)實現(xiàn)發(fā)帖,文章內(nèi)容質(zhì)量較高,因此小編分享給大家做個參考,希望大家閱讀完這篇文章后對相關(guān)知識有一定的了解。
weibo_redis.php
<?php //此處需要安裝phpredis擴(kuò)展 $redis = new Redis(); $redis->connect('127.0.0.1', 6379); $redis->auth("php001"); //連接redis $web_info= array( 'uid' => $_REQUEST[uid], //發(fā)布者id 'username' => $_REQUEST[username],//發(fā)布者用戶名 'content' =>$_REQUEST[content],//微博內(nèi)容 ); //將數(shù)組轉(zhuǎn)成json來存儲 $list = json_encode($web_info); //lpush向KEY對應(yīng)的頭部添加一個字符串元素 $redis->lpush('weibo_lists',$list); $redis->close(); var_dump($list); ?>
模擬后臺進(jìn)程從redis隊列獲取微博
Pdodb.class.php
<?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(); } } }
weibo_mysql.php
<?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頭部刪除并返回刪除數(shù)據(jù) $info = $redis->rpop('weibo_lists'); $info = json_decode($info); $pdo->post($info->uid,$info->username,$info->content); } $redis->close(); sleep(10);//延時10秒 }
后臺執(zhí)行weibo_mysql.php
nohup php /var/www/html/big/weibo_mysql.php &
關(guān)于怎么在php中利用redis高并發(fā)實現(xiàn)發(fā)帖就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,可以學(xué)到更多知識。如果覺得文章不錯,可以把它分享出去讓更多的人看到。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。