多线程 - PHP怎么做批量的发送请求!!!!

比如说这么一个web后台页面,要有一个操作,对几万用户发送邮件或者发送推送~要怎么做才能调到php去而且不影响这个操作后的其他操作呢?因为php 这种请求是串行处理的,调用一个函数方法等只有跑完下来才能退出,如果用循环发送,那在发送的时候就只能卡在这个页面不能进行其他操作了,而且找过类似java的多线程实现方法~调一个方法循环发送,然后主进程退出来,调一个接口查看发送的状态,发送了多少,结果是不行的,因为PHP只能并行处理这种web的请求~这个跟php用来做app接口的时候的高并发调用是不同的,因为当php作为这种数据请求的时候,是属于不同用户调用~apache可以做并行~所以要怎么实现呢?

回复内容：

比如说这么一个web后台页面,要有一个操作,对几万用户发送邮件或者发送推送~要怎么做才能调到php去而且不影响这个操作后的其他操作呢?因为php 这种请求是串行处理的,调用一个函数方法等只有跑完下来才能退出,如果用循环发送,那在发送的时候就只能卡在这个页面不能进行其他操作了,而且找过类似java的多线程实现方法~调一个方法循环发送,然后主进程退出来,调一个接口查看发送的状态,发送了多少,结果是不行的,因为PHP只能并行处理这种web的请求~这个跟php用来做app接口的时候的高并发调用是不同的,因为当php作为这种数据请求的时候,是属于不同用户调用~apache可以做并行~所以要怎么实现呢?

这个问题已经找到一个比较简单不用引用库的解决办法了.
http://www.htmlgoodies.com/beyond/javascript/providing-feedback-on-long-running-scripts-in-older-browsers.html
贴出一个网址.
方法的原理是利用session_write_close()函数,当一个长循环在跑的时候,在长循环中加入session_write_close(),关闭一下session~由于php的web service 是针对同一session用户串行的,关闭一次session相当于抛出一次锁,其他服务就可以排队拿到这个锁执行程序~
总的来说相当于一个长循环中每次抛出锁,可以插入其他操作,这样就实现了切换运行~

我目前的做法是，借用redis的队列，把要发送的消息，全部放到里面，然后就不管了
有一个后台发送进程，来处理队列里面的数据
1.如果需要重发，则把发送失败的消息放到一个备份的队列里，每次循环开始前，都把备份队列里的数据放到发送的队列里。
2.php进程不建议常驻，因此，可以把一个进程的生命周期设置为1min，再借用cron来实现进程的重启

对接一个消息队列，把你要处理的任务放入消息队列，简单的可以用redis，复杂点的可以beanstalkd, rabbitmq等
如果坚持用PHP实现，写CLI脚本去这个消息队列拿消息，拿到消息之后处理你的耗时任务
亦可使用其它技术实现，python，java，看你们团队的实际情况和技术栈

PS: PHP有多任务的解决方案，用pthread扩展实现多线程或者pcntl扩展实现多进程，但也不要在web端做这个事情

这个可以借用消息队列做异步处理， 你web后台只是做个触发， 真正的邮件之类的通知，要到异步处理， 这样不会堵塞你web后台的操作，消息队列的话，有很多种方案， 简单点的就是利用redis自己实现一个，或者网上有类似的。
队列处理发送消息的动作的时候， 你可以根据你业务的重要， 比如， 我发送一次，不管成功不成功，无所谓，还是必须把消息发送成功， 必须发送成功的话， 你可以把失败的， 写到另外队列，做处理，或者做log记录之类的， 这个跟公司业务比较接近了。

use swoole