当前位置:首页 > PHP教程 > php高级应用 > 列表

php基于Redis消息队列实现的消息推送的方法

发布:smiling 来源: PHP粉丝网  添加日期:2021-11-02 09:25:54 浏览: 评论:0 

这篇文章主要介绍了php基于Redis消息队列实现的消息推送的方法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧

基本知识点

重点用到了以下命令实现我们的消息推送

brpop 阻塞模式 从队列右边获取值之后删除

brpoplpush 从队列A的右边取值之后删除,从左侧放置到队列B中

逻辑分析

在普通的任务脚本中写入push_queue队列要发送消息的目标,并为目标设置一个要推送的内容,永不过期

RedisPushQueue中brpoplpush处理,处理后的值放到temp_queue,主要防止程序崩溃造成推送失败

RedisAutoDeleteTempqueueItems处理temp_queue,这里用到了brpop

代码实现

普通任务脚本

  1. <?php 
  2. foreach ($user_list as $item) { 
  3.   //命名规则 业务类型_操作_ID_随机6位 值 自定义 我自定义的是"推送内容" 
  4.   $k_name = 'rabbit_push_' . $item['uid'].'_'.rand(100000,999999); 
  5.   $redis->lPush('push_queue',$k_name);//左进队列 
  6.   $redis->set($k_name'推送内容'); 

RedisPushQueue

  1. <?php 
  2. //消息队列处理推送~ 
  3. // 
  4.  // 守护进程运行 
  5.  // nohup php YOURPATH/RedisPushQueue.php & 开启守护进程运行,修改文件之后需要从新启动 
  6. // blpop 有值则回去 没值则阻塞 主要就是这个函数在起作用 不过并不安全,程序在执行过程中崩溃就会导致队列中的内容 
  7.  // 永久丢失~ 
  8.  // BRPOPLPUSH 阻塞模式 右边出 左边进 在填写队列内容的时候要求从左进入 
  9.  // 
  10. ini_set('default_socket_timeout', -1); //不超时 
  11. require_once 'YOURPARH/Rongcloud.php'
  12.  
  13. $redis = new \Redis(); 
  14. $redis->connect('127.0.0.1', 6379); 
  15. $redis->select(2);//切换到db2 
  16. $redis->setOption(\Redis::OPT_READ_TIMEOUT, -1); 
  17.  
  18. // temp_queue临时队列防止程序崩溃导致队列中内容丢失 0代表永不超时! 
  19. While ($key = $redis->brpoplpush('push_queue''temp_queue', 0)) { 
  20.   if ($val = $redis->get($key)) { 
  21.     //rabbit_push_20_175990 
  22.     $arr = explode('_'$key); 
  23.     if (count($arr) != 4) { 
  24.       continue
  25.     } 
  26.     $id = $arr[2]; 
  27.     push($id$val); 
  28.     //删除key内容 
  29.     $redis->del($key); 
  30.   }  
  31. function push($id$v
  32.  //推送操作~ 

RedisAutoDeleteTempqueueItems

  1. <?php 
  2. /* 自动处理temp_queue中的元素,这个操作是防止RedisPushQueue崩溃的时候做处理 
  3.  处理思路是 使用brpop 命令阻塞处理temp_queue这个队列中的值,如果能获取到"值"对应的"值",说明RedisPushQueue执行失败了 
  4.  将值还lpush到push_queue中,以备从新处理 
  5.  至于为什么使用brpop命令,是因为在RedisPushQueue中我们使用的是brpoplpush 
  6.  nohup php YOURPATH/RedisAutoDeleteTempqueueItems.php & 开启守护进程运行,修改文件之后需要从新启动 
  7. */ 
  8. ini_set('default_socket_timeout', -1); //不超时 
  9. $redis = new \Redis(); 
  10. $redis->connect('127.0.0.1', 6379); 
  11. $redis->select(2);//切换到db2 
  12. $redis->setOption(\Redis::OPT_READ_TIMEOUT, -1); 
  13.   while($key_arr = $redis->brPop('temp_queue',0)){ 
  14.   if(count($key_arr) != 2){ 
  15.     continue
  16.   } 
  17.   $key =$key_arr[1]; 
  18.   if($redis->get($key)){//能获取到值 说明RedisPushQueue执行失败 
  19.     $redis->lPush('push_queue',$key); 
  20.   } 
  21. }

Tags: Redis消息队列 php消息推送

分享到:

相关文章