Explication détaillée de l'exemple de code pour php redis pour implémenter le push instantané auprès de 2 millions d'utilisateurs

Cet article présente principalement en détail la mise en œuvre de php redis pour implémenter le push instantané pour 2 millions d'utilisateurs. Il a une certaine valeur de référence. Les amis intéressés peuvent se référer à

Comment implémenter le push instantané pour 2 millions d'utilisateurs. Push, ce push peut être compris comme appelant une interface tierce, push, SMS, etc.

A cette époque, j'ai d'abord écrit une démo pour lire directement la base de données puis pousser les résultats individuellement. . C'est envisageable

J'ai donc conçu une solution basée sur le multi-processus redis+php Elle fonctionne bien mais a une grande évolutivité, donc je la partage.

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

La logique spécifique est la suivante : (Ignorer ma police)

En fait, cela peut être optimisé si. il y a plus de données utilisateur, vous pouvez diviser les données dans Redis et utiliser plusieurs listes. Chaque liste correspond à plusieurs processus php, ce qui sera plus rapide.

Voici le code spécifique que j'ai implémenté :

Script de gestion principal : démarrez-le simplement lors de votre candidature.

<?php     //push推送配置 注:使用前请确认log文件为空    2016-04-12 
include_once(dirname (__FILE__)."/../../config.inc.php"); 
//if(exec(&#39;ps aux | grep redis_push.php | grep -v grep | wc -l&#39;) != 0) goto check; 
import(&#39;push.class.php&#39;); 
import(&#39;Redis.class.php&#39;); 
 
$time =time(); 
$data = array("apikey"=>&#39;xxxx&#39;,"secret"=>&#39;xxxx&#39;); 
$push = new Channel($data); 
$redis = new RedisCache($Credis[&#39;host&#39;],$Credis[&#39;port&#39;]); 
if(exec(&#39;ps aux | grep redis_push.php | grep -v grep | wc -l&#39;) != 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[&#39;OpenType&#39;]==1 ? "是" : "否"; 
$c = json_encode($config); 
$info = <<<monkey 
  ************ 请确认信息是否有误*10秒后启动push任务! ************* 
  * 文件名称  : {$config[&#39;file&#39;]}; 
  * 推送标题  : {$config[&#39;Title&#39;]}; 
  * 推送内容  : {$config[&#39;Content&#39;]}; 
  * 是否跳转  : {$config[&#39;OpenType&#39;]}; 
  * 进程数量  : $num;(如果为单进程无视此项) 
  * 睡眠时间  : {$config[&#39;s&#39;]}; 
  * 日志目录  : /log; 
  ***************************************************************\n 
monkey; 
echo $info; 
sleep(3); 
$n = 1; 
while($n<=10){ 
 echo (10-$n++),"秒\n"; 
 sleep(1); 
} 
echo "------------------------- 任务已启动 -------------------------\n"; 
if($redis->Scount(&#39;push_getchannel_success&#39;)){ 
 echo "队列有未完成任务\n"; 
}else{ 
 $res = exec("php redis_getchannel.php {$config[&#39;file&#39;]}");//写入redis脚本 
 echo $res; 
} 
smtp_mail(&#39;xxxx@qq.com&#39;,&#39;推送任务已开启&#39;,&#39;请实时监测,5秒后您的手机将接收到测试推送!&#39;);//推送监控 实现定时全自动推送  
echo "\n---------------- 5秒后 test 将收到测试推送消息 ----------------\n"; 
sleep(5); 
$re = $push->BaiduPush(&#39;xxxx&#39;,&#39;xxxxx&#39;,$config[&#39;Content&#39;],$config[&#39;Title&#39;],&#39;1&#39;,$config[&#39;OpenType&#39;],$config[&#39;Url&#39;],&#39;xxxxx&#39;,$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 &#39;{$c}&#39; > /dev/null 2>&1 &"); 
} 
 
check: 
while(1){ 
 if(exec(&#39;ps aux | grep redis_push.php | grep -v grep | wc -l&#39;) == 0){ 
  echo "push 发送完成 用时",time()-$time,"秒"; 
  die(); 
 } 
 echo "当前进程数：",exec(&#39;ps aux | grep redis_push.php | grep -v grep | wc -l&#39;),"个","\n"; 
 echo "当前剩余推送数量：".$redis->Scount(&#39;push_getchannel_success&#39;)."\n"; 
 sleep(10); 
}

Quant à l'écriture de redis et du script push spécifique, vous pouvez simplement compter sur votre propre imagination et je ne le publierai pas hehe

Mon approche est que le script push spécifique se terminera automatiquement et s'appellera après avoir poussé un certain nombre.

Parce que dans les applications réelles, il s'avère que les scripts php se bloquent après une exécution prolongée (peut-être en raison de problèmes de changement de contexte), j'évite donc toujours de laisser les scripts php s'exécuter pendant une longue période.

De plus, les utilisateurs ne sont certainement pas un nombre fixe de 2 millions d'utilisateurs. Il y aura une augmentation chaque jour. Mon plan est d'utiliser un script planifié pour organiser les utilisateurs incrémentiels chaque jour dans une table d'utilisateurs conçue. par moi-même et je le gère moi-même.

ps : J'ai mis tous les scripts dans un petit framework PHP natif que j'ai organisé pour une gestion unifiée, je les enverrai au bout d'un moment.

Ce qui précède est l'explication détaillée de l'exemple de code PHP redis pour une diffusion instantanée vers 2 millions d'utilisateurs. Pour plus de contenu connexe, veuillez faire attention au site Web PHP chinois (www.php.cn) !