php+redis實(shí)現(xiàn)對(duì)200w用戶即時(shí)推送服務(wù)的案例

這篇文章將為大家詳細(xì)講解有關(guān)php+redis實(shí)現(xiàn)對(duì)200w用戶即時(shí)推送服務(wù)的案例，小編覺得挺實(shí)用的，因此分享給大家做個(gè)參考，希望大家閱讀完這篇文章后可以有所收獲。

當(dāng)時(shí)先寫了一個(gè)demo 直接讀取DB然后單個(gè)推送，結(jié)果。。。。可想而知

于是設(shè)計(jì)一套基于redis＋php多進(jìn)程的方案，用著還不錯(cuò)而去擴(kuò)展性蠻高的，故分享之。

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

具體的邏輯如下：（無視我的字體）

其實(shí)這里還可以優(yōu)化的，我的設(shè)想是如果用戶數(shù)據(jù)再多一些的話，可以在redis里對(duì)數(shù)據(jù)進(jìn)行分割采取多List，每一個(gè)List對(duì)應(yīng)多個(gè)php進(jìn)程這樣會(huì)更快。

下面是我實(shí)現(xiàn)的具體代碼：

主管理腳本：應(yīng)用時(shí)啟動(dòng)這個(gè)即可。

<?php          //push推送配置  注:使用前請(qǐng)確認(rèn)log文件為空       2016-04-12
include_once(dirname (__FILE__)."/../../config.inc.php");
//if(exec('ps aux | grep redis_push.php | grep -v grep | wc -l') != 0) goto check;
import('push.class.php');
import('Redis.class.php');

$time  =time();
$data  = array("apikey"=>'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;//如果有推送任務(wù) 直接執(zhí)行監(jiān)控代碼

/*PUSH配置項(xiàng)*/
$config = array(
  "file"=>"test.txt",
  "Title"=>"sssss",
  "Content"=>"ssssssssssssssss",
  "OpenType"=>"0",    //1是  0否    是否跳轉(zhuǎn)鏈接
  "Url"=>"",         //鏈接地址
  "num"=>"500",      //每次推送條數(shù)
  "s"=>"1"           //睡眠時(shí)間 （單位：秒）
);
$num = 15;            //啟動(dòng)進(jìn)程數(shù)量
$a = $config['OpenType']==1 ? "是" : "否";
$c = json_encode($config);
$info = <<<monkey
   ************ 請(qǐng)確認(rèn)信息是否有誤*10秒后啟動(dòng)push任務(wù)! *************
   * 文件名稱   : {$config['file']};
   * 推送標(biāo)題   : {$config['Title']};
   * 推送內(nèi)容   : {$config['Content']};
   * 是否跳轉(zhuǎn)   : {$config['OpenType']};
   * 進(jìn)程數(shù)量   : $num;(如果為單進(jìn)程無視此項(xiàng))
   * 睡眠時(shí)間   : {$config['s']};
   * 日志目錄   : /log;
   ***************************************************************\n
monkey;
echo $info;
sleep(3);
$n = 1;
while($n<=10){
  echo (10-$n++),"秒\n";
  sleep(1);
}
echo "------------------------- 任務(wù)已啟動(dòng) -------------------------\n";
if($redis->Scount('push_getchannel_success')){
  echo "隊(duì)列有未完成任務(wù)\n";
}else{
  $res = exec("php redis_getchannel.php {$config['file']}");//寫入redis腳本
  echo $res;
}
smtp_mail('xxxx@qq.com','推送任務(wù)已開啟','請(qǐng)實(shí)時(shí)監(jiān)測(cè),5秒后您的手機(jī)將接收到測(cè)試推送!');//推送監(jiān)控 實(shí)現(xiàn)定時(shí)全自動(dòng)推送 
echo "\n---------------- 5秒后 test 將收到測(cè)試推送消息 ----------------\n";
sleep(5);
$re = $push->BaiduPush('xxxx','xxxxx',$config['Content'],$config['Title'],'1',$config['OpenType'],$config['Url'],'xxxxx',$push);
sleep(1);
echo "\n---------------- 測(cè)試推送已發(fā)出!如未收到,請(qǐng)及時(shí)終止程序! 10秒后正式推送!!! ----------------\n";
$m = 1;
while($m<=10){
  echo (10-$m++),"秒\n";
  sleep(1);
}
echo "\n---------------- 推送任務(wù)已經(jīng)開始!請(qǐng)耐心等待! ----------------\n";
//下面設(shè)置是否多進(jì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 發(fā)送完成 用時(shí)",time()-$time,"秒";
    die();
  }
  echo "當(dāng)前進(jìn)程數(shù)：",exec('ps aux | grep redis_push.php | grep -v grep | wc -l'),"個(gè)","\n";
  echo "當(dāng)前剩余推送數(shù)量：".$redis->Scount('push_getchannel_success')."\n";
  sleep(10);
}

至于寫入redis和具體的推送腳本這個(gè)靠自己的想象里就好了 我就不發(fā)了 嘿嘿

我的做法是具體的推送腳本在推送一定數(shù)量后會(huì)自動(dòng)終止并調(diào)用自己本身。

因?yàn)樵趯?shí)際應(yīng)用中發(fā)現(xiàn)php腳本在長時(shí)間運(yùn)行之后會(huì)發(fā)生假死（可能是因?yàn)樯舷挛那袚Q的問題），

所以我都是避免讓php腳本長時(shí)間運(yùn)行。

還有就是用戶肯定不是固定的200w用戶 每天都會(huì)有一個(gè)增量，我的方案是通過定時(shí)腳本每天把增量的用戶整理進(jìn)我自己設(shè)計(jì)的一個(gè)用戶表自己管理。

ps：我把所有的腳本弄到了一個(gè)我自己整理的小的php原生框架統(tǒng)一管理，過段時(shí)間我發(fā)出來。

關(guān)于php+redis實(shí)現(xiàn)對(duì)200w用戶即時(shí)推送服務(wù)的案例就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果覺得文章不錯(cuò)，可以把它分享出去讓更多的人看到。