Detaillierte Erläuterung des Beispielcodes für PHP Redis zur Implementierung von Instant Push für 2 Millionen Benutzer

Dieser Artikel stellt hauptsächlich die Implementierung von PHP Redis zur Implementierung von Instant Push für 2 Millionen Benutzer vor. Er hat einen bestimmten Referenzwert.

Wie man Instant Push für 2 Millionen Benutzer implementiert. Push, dieser Push kann als Aufruf einer Schnittstelle eines Drittanbieters, Push, SMS usw. verstanden werden.

Damals habe ich zunächst eine Demo geschrieben, um die DB direkt zu lesen und dann die Ergebnisse einzeln zu pushen. . Es ist denkbar

Also habe ich eine Lösung basierend auf Redis+php Multi-Process entwickelt. Sie funktioniert gut, ist aber hoch skalierbar, also teile ich sie.

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

Die spezifische Logik lautet wie folgt: (Ignoriere meine Schriftart)

Tatsächlich kann dies optimiert werden Wenn mehr Benutzerdaten vorhanden sind, können Sie die Daten in Redis aufteilen und mehrere Listen verwenden. Jede Liste entspricht mehreren PHP-Prozessen, was schneller ist.

Das Folgende ist der spezifische Code, den ich implementiert habe:

Hauptverwaltungsskript: Starten Sie dies einfach bei der Bewerbung.

<?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); 
}

Was das Schreiben von Redis und dem spezifischen Push-Skript betrifft, können Sie sich einfach auf Ihre eigene Fantasie verlassen und ich werde es nicht veröffentlichen, hehe

Mein Ansatz besteht darin, dass das spezifische Push-Skript automatisch beendet wird und sich selbst anruft, nachdem eine bestimmte Nummer gedrückt wurde.

Da in tatsächlichen Anwendungen festgestellt wird, dass PHP-Skripte nach längerer Ausführung einfrieren (möglicherweise aufgrund von Problemen beim Kontextwechsel), vermeide ich es immer, PHP-Skripte über einen längeren Zeitraum laufen zu lassen.

Außerdem handelt es sich bei den Benutzern definitiv nicht um eine feste Anzahl von 2 Millionen Benutzern. Es wird jeden Tag eine Erhöhung geben. Mein Plan ist, die Erhöhung der Benutzer in einer Benutzertabelle zu organisieren von mir selbst entworfen und verwaltet es selbst.

ps: Ich habe alle Skripte in ein kleines natives PHP-Framework eingefügt, das ich für eine einheitliche Verwaltung organisiert habe. Ich werde sie nach einer Weile versenden.

Das Obige ist die detaillierte Erklärung des Beispielcodes von PHP Redis für Instant Push an 2 Millionen Benutzer. Weitere verwandte Inhalte finden Sie auf der chinesischen PHP-Website (www.php.cn)!