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

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了多线程-PHP怎么做批量的发送请求!!!!，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2683字，纯文字阅读大概需要4分钟。

内容图文

回复内容：

比如说这么一个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

内容总结

以上是互联网集市为您收集整理的多线程-PHP怎么做批量的发送请求!!!!全部内容，希望文章能够帮你解决多线程-PHP怎么做批量的发送请求!!!!所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端