怎么在PHP中使用redis實現(xiàn)推模型

本篇文章為大家展示了怎么在PHP中使用redis實現(xiàn)推模型，內(nèi)容簡明扼要并且容易理解，絕對能使你眼前一亮，通過這篇文章的詳細(xì)介紹希望你能有所收獲。

推模型

所謂推模型，就是用戶在發(fā)布微博的時候會將微博推送給關(guān)注者和自己，然后其他關(guān)注者登錄之后就可以看到發(fā)布的微博。

微博項目數(shù)據(jù)結(jié)構(gòu)設(shè)計

user表設(shè)計

注冊的時候?qū)ser數(shù)據(jù)寫入redis中，key如下：

user數(shù)據(jù)的key
用戶名=user:uesrid:$uesrid:username
密碼=user:userid:$userid:password

還需要這樣寫一份，因為需要靠用戶名來登錄，這樣就可以根據(jù)用戶名來查詢用戶id。

user:username:userid:$userid

關(guān)注的人和粉絲設(shè)計

每個用戶在產(chǎn)生關(guān)注的動作后，在redis中維護(hù)兩個無序集合set,一個是following，一個是follower，following集合保存的是我關(guān)注的人，follower集合保存的是我的粉絲。注意是每個用戶都要維護(hù)這樣的兩個集合，用userid來區(qū)。

微博表設(shè)計

每條微博的信息用hash結(jié)構(gòu)來存儲，根據(jù)不同的微博id來區(qū)分，每條微博有如下信息：發(fā)布人id，發(fā)布人昵稱，發(fā)布時間，微博內(nèi)容。

推送表設(shè)計

用戶在發(fā)布微博的時候，將微博推送給自己的粉絲，每個粉絲都維護(hù)一個推送微博的鏈表，這個鏈表只保存50條最新微博。推送表中保存的是微博id.

關(guān)注操作

我們在redis中維護(hù)兩個無序集合set,一個是following，一個是follower，following集合保存的是我關(guān)注的人，follower集合保存的是我的粉絲。注意是每個用戶都要維護(hù)這樣的兩個集合，用userid來區(qū)分。

核心代碼：

$conn = connredis();//連接redis
if($f){//如果沒有關(guān)注過
 $conn->sadd('following:'.$user['userid'],$userid);
 $conn->sadd('follower:'.$userid,$user['userid']);
}else{
 $conn->srem('following:'.$user['userid'],$userid);
 $conn->srem('follower:'.$userid,$user['userid']);
}

發(fā)布微博

遍歷自己的粉絲，給每個粉絲都推送一條微博，將推送的微博保存到每個用戶的推送表中

核心代碼：

//1、保存微博
$conn = connredis();//連接redis
$postid = $conn->incr('global:postid');//生成微博id
//保存微博數(shù)據(jù)
$conn->hmset('post:postid:'.$postid,['userid'=>$user['userid'],'username'=>$user['username'],'time'=>time(),'content'=>$content]);
//2、推送微博
$fans = $conn->smembers('follower:'.$user['userid']);//獲取所有粉絲
$fans[] = $user['userid'];//自己也要推送一份
foreach($fans as $u){
 $conn->lpush('receivepost:'.$u,$postid);
 $conn->ltrim('receivepost:'.$u,0,49);//每個人保存最新微博50條
}

展示微博

首先連接redis，然后獲取自己的推送表的信息，遍歷推送表，然后獲取微博內(nèi)容，最后獲取自己的粉絲和關(guān)注數(shù)。進(jìn)行數(shù)據(jù)展示即可。

//獲取推送的微博id
$conn = connredis();
$postids = $conn->sort('receivepost:'.$user['userid'],['sort'=>'desc']);
//獲取微博
$posts = [];
foreach($postids as $postid){
$posts[] = $conn->hmget('post:postid:'.$postid,['userid','username','time','content']);
}
//獲取粉絲和關(guān)注數(shù)
$fansnum = $conn->scard('follower:'.$user['userid']);
$follownum = $conn->scard('following:'.$user['userid']);

上述內(nèi)容就是怎么在PHP中使用redis實現(xiàn)推模型，你們學(xué)到知識或技能了嗎？如果還想學(xué)到更多技能或者豐富自己的知識儲備，歡迎關(guān)注億速云行業(yè)資訊頻道。