


Share php+redis to implement instant push service to 2 million users
Recommended: "PHP Video Tutorial"
How to implement instant push to 2 million users. This push can be understood as calling the first Three-party interfaces, push, SMS and the like.
At that time, I first wrote a demo to directly read the DB and then push the results individually. . . . It is conceivable
So I designed a solution based on redis+php multi-process, which is not bad but has high scalability, so I will share it.
========================================= =
The specific logic is as follows: (ignore my font)
In fact, it can be optimized here. My idea is that if there is more user data If so, you can split the data in redis and use multiple Lists. Each List corresponds to multiple PHP processes, which will be faster.
The following is the specific code I implemented:
Main management script: Just start this when applying.
<?php //push推送配置 注:使用前请确认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;//如果有推送任务 直接执行监控代码 /*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 = <<<monkey ************ 请确认信息是否有误*10秒后启动push任务! ************* * 文件名称 : {$config['file']}; * 推送标题 : {$config['Title']}; * 推送内容 : {$config['Content']}; * 是否跳转 : {$config['OpenType']}; * 进程数量 : $num;(如果为单进程无视此项) * 睡眠时间 : {$config['s']}; * 日志目录 : /log; ***************************************************************\n monkey; echo $info; sleep(3); $n = 1; while($n<=10){ echo (10-$n++),"秒\n"; sleep(1); } echo "------------------------- 任务已启动 -------------------------\n"; if($redis->Scount('push_getchannel_success')){ echo "队列有未完成任务\n"; }else{ $res = exec("php redis_getchannel.php {$config['file']}");//写入redis脚本 echo $res; } smtp_mail('xxxx@qq.com','推送任务已开启','请实时监测,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); }
As for writing redis and specific push scripts, you can just rely on your own imagination. I won’t post them.
My approach is to write specific push scripts after pushing a certain number. Will automatically terminate and call itself.
Because in actual applications, it is found that php scripts will freeze after running for a long time (maybe due to context switching issues),
So I avoid letting php scripts run for a long time.
Also, the users are definitely not a fixed 2 million users. There will be an increment every day. My plan is to use a timed script to organize the increment of users into a user table designed by myself and manage it myself.
ps: I put all the scripts into a small PHP native framework that I organized for unified management. I will send them out after a while.
Corrections are welcome, thank you.
The above is the detailed content of Share php+redis to implement instant push service to 2 million users. For more information, please follow other related articles on the PHP Chinese website!

Hot AI Tools

Undresser.AI Undress
AI-powered app for creating realistic nude photos

AI Clothes Remover
Online AI tool for removing clothes from photos.

Undress AI Tool
Undress images for free

Clothoff.io
AI clothes remover

AI Hentai Generator
Generate AI Hentai for free.

Hot Article

Hot Tools

Notepad++7.3.1
Easy-to-use and free code editor

SublimeText3 Chinese version
Chinese version, very easy to use

Zend Studio 13.0.1
Powerful PHP integrated development environment

Dreamweaver CS6
Visual web development tools

SublimeText3 Mac version
God-level code editing software (SublimeText3)

Hot Topics

PHP 8.4 brings several new features, security improvements, and performance improvements with healthy amounts of feature deprecations and removals. This guide explains how to install PHP 8.4 or upgrade to PHP 8.4 on Ubuntu, Debian, or their derivati

To work with date and time in cakephp4, we are going to make use of the available FrozenTime class.

To work on file upload we are going to use the form helper. Here, is an example for file upload.

CakePHP is an open-source framework for PHP. It is intended to make developing, deploying and maintaining applications much easier. CakePHP is based on a MVC-like architecture that is both powerful and easy to grasp. Models, Views, and Controllers gu

Visual Studio Code, also known as VS Code, is a free source code editor — or integrated development environment (IDE) — available for all major operating systems. With a large collection of extensions for many programming languages, VS Code can be c

Validator can be created by adding the following two lines in the controller.

CakePHP is an open source MVC framework. It makes developing, deploying and maintaining applications much easier. CakePHP has a number of libraries to reduce the overload of most common tasks.

This tutorial demonstrates how to efficiently process XML documents using PHP. XML (eXtensible Markup Language) is a versatile text-based markup language designed for both human readability and machine parsing. It's commonly used for data storage an
