Home  >  Article  >  Backend Development  >  php如何处理并行的两个线程?

php如何处理并行的两个线程?

WBOY
WBOYOriginal
2016-06-06 20:37:551297browse

1.用户上传一张图片到A服务器的receive.php,
2.在A服务器的receive.php接收到这个图片后,会向B服务器通过curl post这张图片,
(由于图片非常大,因此,A服务器向B服务器传输图片非常耗时)
在这个耗时长久过程中,如果我再向A服务器的receive.php发送一个请求request2,但是由于这个receive.php还正在向B服务器传输图片,因此这个请求一直要等待,直到A服务器将这个图片完全发送完毕为止,才回来处理第二个请求request2。


问题:现在怎样打破这种队列效应,让A服务器的receive.php同时处理两个请求?
即使不能实现php多线程处理,那么如何能让request2做到伪请求,我的意思是,假设request2请求receive.php后,receive.php要查询大量数据库,最后echo "request done",现在我只需要输出echo "request done"即可,其余receive.php该搞啥就搞啥

回复内容:

1.用户上传一张图片到A服务器的receive.php,
2.在A服务器的receive.php接收到这个图片后,会向B服务器通过curl post这张图片,
(由于图片非常大,因此,A服务器向B服务器传输图片非常耗时)
在这个耗时长久过程中,如果我再向A服务器的receive.php发送一个请求request2,但是由于这个receive.php还正在向B服务器传输图片,因此这个请求一直要等待,直到A服务器将这个图片完全发送完毕为止,才回来处理第二个请求request2。


问题:现在怎样打破这种队列效应,让A服务器的receive.php同时处理两个请求?
即使不能实现php多线程处理,那么如何能让request2做到伪请求,我的意思是,假设request2请求receive.php后,receive.php要查询大量数据库,最后echo "request done",现在我只需要输出echo "request done"即可,其余receive.php该搞啥就搞啥

觉得你需要一个消息队列。

除此之外,可以:

<code>以是转载。

PHP语言本身是不支持多线程的. 总结了一下网上关于PHP模拟多线程的方法, 总的来说, 都是利用了PHP的好伙伴们本身所具有的多线程能力. PHP的好伙伴指的就是LINUX和APACHE啦, LAMP嘛.

另外, 既然是模拟的, 就不是真正的多线程. 其实只是多进程. 进程和线程是两个不同的概念. 好了, 以下方法都是从网上找来的.

1. 利用LINUX操作系统

<?php for ($i=0;$i<10;$i++) {
echo $i;
sleep(5);
}
?>

上面存成test.php, 然后写一段SHELL代码

#!/bin/bash
for i in 1 2 3 4 5 6 7 8 9 10
do
php -q test.php &
done

2. 利用fork子进程(其实同样是利用LINUX操作系统)

<?php declare(ticks=1);
$bWaitFlag = FALSE; /// 是否等待进程结束
$intNum = 10; /// 进程总数
$pids = array(); /// 进程PID数组
echo ("Startn");
for($i = 0; $i < $intNum; $i++) {
$pids[$i] = pcntl_fork();/// 产生子进程,而且从当前行之下开试运行代码,而且不继承父进程的数据信息
if(!$pids[$i]) {
// 子进程进程代码段_Start
$str="";
sleep(5+$i);
for ($j=0;$j<$i;$j++) {$str.="*";}
echo "$i -> " . time() . " $str n";
exit();
// 子进程进程代码段_End
}
}
if ($bWaitFlag)
{
for($i = 0; $i  " . time() . "n";
}
}
echo ("Endn");
?>

3. 利用WEB SERVER, PHP不支持多线程, APACHE可是支持的, 呵呵.

假设我们现在运行的是a.php这个文档. 但是我在程式中又请求WEB服务器运行另一个b.php

那么这两个文档将是同时执行的.

<?php function runThread()
{
$fp = fsockopen('localhost', 80, $errno, $errmsg);
fputs($fp, "GET /a.php?act=brnrn");
fclose($fp);
}
function a()
{
$fp = fopen('result_a.log', 'w');
fputs($fp, 'Set in ' . Date('h:i:s', time()) . (dou ble)microtime() . "rn");
fclose($fp);
}
function b()
{
$fp = fopen('result_b.log', 'w');
fputs($fp, 'Set in ' . Date('h:i:s', time()) . (double)microtime() . "rn");
fclose($fp);
}
if(!isset($_GET['act'])) $_GET['act'] = 'a';
if($_GET['act'] == 'a')
{
runThread();
a();
}
else if($_GET['act'] == 'b') b();
?>

当然啦,也可以把需要多线程处理的部分交给JAVA去处理, 然后在PHP里调用, 哈哈.

<?php system('java multiThread.java');
?>


</code>

pthreads扩展可以实现真正的多线程,我前阵子做苹果的推送服务有用到,不过有很多坑。
耗时任务可以考虑异步,丢到消息队列中处理。

不知楼主的 HTTP 服务器用的是什么,怎么会有这种奇怪的“队列效应”?
难道说楼主限制了 HTTP 服务器的并发请求数,同一时间只允许一个请求?

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