Home >Backend Development >PHP Tutorial >PHP多线程实现技术总结

PHP多线程实现技术总结

WBOY
WBOYOriginal
2016-06-20 13:05:15958browse

PHP多线程实现技术总结

众所周知,PHP没有多线程,不过可以通过一些技巧方法来实现多线程的效果,比如使用AJAX异步访问等等。总结一下自己这几天接触到的PHP异步调用需求和解决方法。

 一、实现AJAX异步访问处理,需要一个完整的操作界面,一个采集进度的动态进度条。(AJAX)用AJAX来实现,通过ajax不停地访问服务器,,通过setInterval来设置间隔时间,访问data.php文件处理数据,然后更新页面相应DOM的内容即可。

例子: 

<p> jQuery(document).ready(function($) { <br /> $('#submit').click(function(){ <br /> setInterval("updateMsg()", 1000); <br /> $.post('data.php', $('#form1').serialize(), function(data, textStatus){ <br /> var new_data = "<p>本次处理的数据总数为:" + data + "</p>"; <br /> $('#total_area').html(new_data); <br /> $('#monitor_area').html('<p>正在初始化信息监控.....</p>'); <br />}); <br /> $.post('test.php',$('#form1').serialize()); <br /> return false; <br /> });<br /> <br /> function updateMsg(){ <br /> $.get("backend.php",{},function(data, textStatus){ <br /> var now_total = "<p>目前已采集数量:" + data + "</p>"; <br /> $("#monitor_area").html(now_total); <br /> }); </p><p> }  </p>

二、PHP邮件发送提醒功能实现。(消息队列)一个报名系统,想在第一时间知道报名者的信息并与其取得联系,并发极低,可能十多天就那么一条报名信息。手机提醒用了发邮件到139的方法。但是有一个问题,就是将发邮件的代码写到用户提交个人信息的程序段里以后,提交的过程会变得非常慢,可能达到3S多,简直无法忍受。对于邮件发送这种耗时很长的东西,采用了“队列”的方法。当然,这个队列没有RabbitMQ和ZeroMQ这种东西这么高级,其实就是将信息存到数据库里,算作是入队列了,然后设置一个cron来处理数据库里的这些信息,处理了,也就是出队列的,这也是个笨办法了。 

三、自然就是到处都是的消息队列了,自己用数据库模拟的,只不过是最低端的方法而已,不是针对并发的,若是面对高并发,必然会挂掉。这个时候,用上传说中的RabbitMQ这些东西,性能应该有极大的提升。还有就是Redis数据库,用过这个东西,感觉用它的list来做消息队列,应该也是非常棒的

四、CURL的方法,curl_multi据说也是个好东西,但是由于CUROPT_TIMEOUT最小是1,所以客户端至少要等待1S,这也是硬伤。

五、popen()函数,打开一个指向进程的管道,该进程由派生给定的 command 命令执行而产生。

<p>pclose(popen("/home/xinchen/backend.php &", 'r'));  </p><p>fsockopen()</p>

这个方法要自己拼接处http头来才行。5.PHP多进程,其实这个方法自己用过,就是将要处理的大段数据按照for循环,用vim处理分成小段,然后在CLI模式下跑

php –f example1.php &<br />php –f example2.php &

用这种笨办法将PHP的进程放到后台来执行……PHP在*uinx下可以直接pcntl类似于C那样fork出进程来,才知道了这个方法,在采集数据的时候,挺好用的,配合CURL和fsockopen,速度飞快。

 for($i = 0; $i <$intNum; $i++) {<br />$pids[$i] = pcntl_fork();// 产生子进程,而且从当前行之下开试运行代码,而且不继承父进程的数据信息<br />if($pids[$i] == -1) {<br />echo "couldn't fork". "n";<br />} elseif(!$pids[$i]) {<br />sleep(1);<br />echo "n"."第".$i."个进程 -> " . time(). "n";<br />//这里就可以放信息采集抓取等东西的代码了。<br />exit(0);//子进程要exit否则会进行递归多进程,父进程不要exit否则终止多进程<br />}<br />} 

六、gearman分布式计算,开很多的worker来支持将job分布到不同机器上去执行。


Statement:
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn