php基于Redis消息队列实现的消息推送的方法
基本知识点
重点用到了以下命令实现我们的消息推送
- brpop阻塞模式从队列右边获取值之后删除
- brpoplpush从队列A的右边取值之后删除，从左侧放置到队列B中
逻辑分析
- 在普通的任务脚本中写入push_queue队列要发送消息的目标，并为目标设置一个要推送的内容，永不过期
- RedisPushQueue中brpoplpush处理，处理后的值放到temp_queue，主要防止程序崩溃造成推送失败
- RedisAutoDeleteTempqueueItems处理temp_queue,这里用到了brpop
代码实现
普通任务脚本
lPush('push_queue',$k_name);//左进队列
$redis->set($k_name,'推送内容');
}
RedisPushQueue
connect('127.0.0.1',6379);
$redis->select(2);//切换到db2
$redis->setOption(\Redis::OPT_READ_TIMEOUT,-1);
//temp_queue临时队列防止程序崩溃导致队列中内容丢失0代表永不超时！
While($key=$redis->brpoplpush('push_queue','temp_queue',0)){
if($val=$redis->get($key)){
//rabbit_push_20_175990
$arr=explode('_',$key);
if(count($arr)!=4){
continue;
}
$id=$arr[2];
push($id,$val);
//删除key内容
$redis->del($key);
}
}
functionpush($id,$v)
{
//推送操作~
}
RedisAutoDeleteTempqueueItems
connect('127.0.0.1',6379);
$redis->select(2);//切换到db2
$redis->setOption(\Redis::OPT_READ_TIMEOUT,-1);
while($key_arr=$redis->brPop('temp_queue',0)){
if(count($key_arr)!=2){
continue;
}
$key=$key_arr[1];
if($redis->get($key)){//能获取到值说明RedisPushQueue执行失败
$redis->lPush('push_queue',$key);
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。