怎么在PHP中使用Redis消息隊(duì)列實(shí)現(xiàn)發(fā)布微博

怎么在PHP中使用Redis消息隊(duì)列實(shí)現(xiàn)發(fā)布微博？相信很多沒(méi)有經(jīng)驗(yàn)的人對(duì)此束手無(wú)策，為此本文總結(jié)了問(wèn)題出現(xiàn)的原因和解決方法，通過(guò)這篇文章希望你能解決這個(gè)問(wèn)題。

具體如下：

phpRedisAdmin :github地址  圖形化管理界面

git clone [url]https://github.com/ErikDubbelboer/phpRedisAdmin.git[/url]
cd phpRedisAdmin
git clone [url]https://github.com/nrk/predis.git[/url] vendor

首先安裝上述的Redis圖形化管理界面，能夠方便的管理Redis數(shù)據(jù)

為了降低Mysql的并發(fā)數(shù)，先把用戶的微博存在Redis中

假設(shè)用戶發(fā)布的時(shí)候需要三個(gè)字段，uid(用戶ID號(hào)),username(用戶姓名),content('用戶的評(píng)論')

比如用戶傳遞以下信息

//此處需要安裝phpredis
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
// 連接redis
$web_info= array(
'uid' => '123456',
'username' => '123',
'content' =>'123'
);
//將數(shù)組轉(zhuǎn)成json來(lái)存儲(chǔ)
$list = json_encode($web_info);
//lpush向KEY對(duì)應(yīng)的頭部添加一個(gè)字符串元素
$redis->lpush('weibo_lists',$list);
$redis->close();
///var_dump(json_encode($web_info));
var_dump($list);
?>

此處可以看到我們的redis已經(jīng)有數(shù)據(jù)了

//創(chuàng)建一個(gè)PDO數(shù)據(jù)庫(kù)鏈接 data.php
class qq{
 public function post($uid='',$username='',$content=''){
  try{
   $dsn = "mysql:host;dbname=localhost;dbname=test";
   $db = new PDO($dsn,'root','root');
   $db->exec("SET NAMES UTF8");
   $sql ="insert into test(uid,username,content)values('$uid','$username','$content')";
   $db->exec($sql);
  }catch(PDOException $e){
   $e->getMessage();
  }
 }
}

//處理redis數(shù)據(jù)庫(kù)的數(shù)據(jù) 并把數(shù)據(jù)放到MYSQL數(shù)據(jù)庫(kù)中
include "data.php";
$qq = new qq();
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
//返回的列表的大小。如果列表不存在或?yàn)榭眨撁罘祷?。如果該鍵不是列表，該命令返回FALSE
if($redis -> lsize('weibo_lists')){
 //從LIST頭部刪除并返回刪除數(shù)據(jù)
 $info = $redis->rPop('weibo_lists');
 $info = json_decode($info);
 $qq->post($info->uid,$info->username,$info->content);
}
$redis->close();
var_dump($info);
?>

看完上述內(nèi)容，你們掌握怎么在PHP中使用Redis消息隊(duì)列實(shí)現(xiàn)發(fā)布微博的方法了嗎？如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容，歡迎關(guān)注億速云行業(yè)資訊頻道，感謝各位的閱讀！