php redis实现对200w用户的即时推送

Redis  /  管理员 发布于 5年前   396

怎么实现对200w用户的即时推送，这个推送可以理解为调用第三方的接口，push，sms之类的东西。

当时先写了一个demo 直接读取DB然后单个推送，结果。。可想而知

于是设计一套基于redis＋php多进程的方案，用着还不错而去扩展性蛮高的，故分享之。

＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝

具体的逻辑如下：（无视我的字体）

其实这里还可以优化的，我的设想是如果用户数据再多一些的话，可以在redis里对数据进行分割采取多List，每一个List对应多个php进程这样会更快。

下面是我实现的具体代码：

主管理脚本：应用时启动这个即可。 

'xxxx',"secret"=>'xxxx'); $push = new Channel($data); $redis = new RedisCache($Credis['host'],$Credis['port']); if(exec('ps aux | grep redis_push.php | grep -v grep | wc -l') != 0) goto check;//如果有推送任务 直接执行监控代码  /*PUSH配置项*/ $config = array(  "file"=>"test.txt",  "Title"=>"sssss",  "Content"=>"ssssssssssssssss",  "OpenType"=>"0",  //1是 0否  是否跳转链接  "Url"=>"",     //链接地址  "num"=>"500",   //每次推送条数  "s"=>"1"      //睡眠时间 （单位：秒） ); $num = 15;      //启动进程数量 $a = $config['OpenType']==1 ? "是" : "否"; $c = json_encode($config); $info = <<Scount('push_getchannel_success')){  echo "队列有未完成任务\n"; }else{  $res = exec("php redis_getchannel.php {$config['file']}");//写入redis脚本  echo $res; } smtp_mail('[email protected]','推送任务已开启','请实时监测,5秒后您的手机将接收到测试推送!');//推送监控 实现定时全自动推送  echo "\n---------------- 5秒后 test 将收到测试推送消息 ----------------\n"; sleep(5); $re = $push->BaiduPush('xxxx','xxxxx',$config['Content'],$config['Title'],'1',$config['OpenType'],$config['Url'],'xxxxx',$push); sleep(1); echo "\n---------------- 测试推送已发出!如未收到,请及时终止程序! 10秒后正式推送!!! ----------------\n"; $m = 1; while($m<=10){  echo (10-$m++),"秒\n";  sleep(1); } echo "\n---------------- 推送任务已经开始!请耐心等待! ----------------\n"; //下面设置是否多进程 for($i=1;$i<=$num;$i++){ exec("php redis_push.php '{$c}' > /dev/null 2>&1 &"); }  check: while(1){  if(exec('ps aux | grep redis_push.php | grep -v grep | wc -l') == 0){   echo "push 发送完成 用时",time()-$time,"秒";   die();  }  echo "当前进程数：",exec('ps aux | grep redis_push.php | grep -v grep | wc -l'),"个","\n";  echo "当前剩余推送数量：".$redis->Scount('push_getchannel_success')."\n";  sleep(10); } 

至于写入redis和具体的推送脚本这个靠自己的想象里就好了 我就不发了 嘿嘿

我的做法是具体的推送脚本在推送一定数量后会自动终止并调用自己本身。

因为在实际应用中发现php脚本在长时间运行之后会发生假死（可能是因为上下文切换的问题），所以我都是避免让php脚本长时间运行。

还有就是用户肯定不是固定的200w用户 每天都会有一个增量，我的方案是通过定时脚本每天把增量的用户整理进我自己设计的一个用户表自己管理。

ps：我把所有的脚本弄到了一个我自己整理的小的php原生框架统一管理，过段时间我发出来。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

您可能感兴趣的文章:

• php实现微信公众号主动推送消息
• 微信小程序 消息推送php服务器验证实例详解
• 解析php做推送服务端实现ios消息推送
• php ios推送(代码)
• php实现微信模板消息推送
• PHP快速推送微信模板消息
• php实现websocket实时消息推送
• php实现socket推送技术的示例
• PHP实现小程序批量通知推送