首页 > IT职业 > IT图书 > PHP用redis做站内消息盒子
最近在工作中遇到一个需求,要面向所有用户发送公告,用户可以删除或者设为已读。这个用数据没办法去实现,我用redis模拟结合数据的方式去实现这个功能。说了这么多废话,还是来点干货吧。
直接贴代码
connect(config('redis.host'), config('redis.port'));
$this->auth(config('redis.password'));
}
//添加一条已读信息
public function read($uid,$mid){
$this->uid = $uid;
$this->mid = $mid;
$this->buildKey();
$res = $this->hGet($this->readListKey,$this->mid);
if(isset($res) && in_array($this->uid,explode(',',$res))) return;
if(empty($res)) $res='';
$this->hSet($this->readListKey,$this->mid,$res.','.$this->uid);
}
public function getIndexKey(){
return ceil( $this->uid / $this->listSize );
}
//删除一条已读信息
public function del($uid,$mid){
$this->uid = $uid;
$this->mid = $mid;
$this->buildKey();
$res = $this->hGet($this->delListKey,$this->uid);
if(isset($res) && in_array($this->mid,explode(',',$res))) return;
if(empty($res)) $res='';
$this->hSet($this->delListKey,$this->uid,$res.','.$this->mid);
}
//拼接已读列表键值
public function buildKey(){
if($this->init) return; //防止多次循环的时候,改变键值
$this->readListKey = $this->readListKey.$this->getIndexKey() ;
$this->init = true;
}
//获取用户已读列表
public function getReadList($uid){
$this->uid = $uid;
$this->buildKey();
$res = $this->hGetAll($this->readListKey);
foreach ( $res as $k=>$v ) {
if(in_array($uid,explode(',',$v))){
$lists[] = $k;
}
}
return $lists;
}
//获取用户已删除的列表
public function getDelList($uid){
$this->uid = $uid;
$this->buildKey();
// var_dump($this->hGet($this->delListKey,$this->uid));die;
return trim($this->hGet($this->delListKey,$this->uid),',');
}
}
来自 “ ITPUB博客 ” ,链接:https://blog.itpub.net/2233/viewspace-2798857/ ,如需转载,请注明出处,否则将追究法律责任。