php(做為現(xiàn)在的主流開(kāi)發(fā)語(yǔ)言)中實(shí)現(xiàn)多線程? 看到這個(gè)標(biāo)題, 你一定以為我瘋了..但是事實(shí)上我真的這么做了.
鳳岡ssl適用于網(wǎng)站、小程序/APP、API接口等需要進(jìn)行數(shù)據(jù)傳輸應(yīng)用場(chǎng)景,ssl證書未來(lái)市場(chǎng)廣闊!成為創(chuàng)新互聯(lián)公司的ssl證書銷售渠道,可以享受市場(chǎng)價(jià)格4-6折優(yōu)惠!如果有意向歡迎電話聯(lián)系或者加微信:13518219792(備注:SSL證書合作)期待與您的合作!
下面是我的一些做法, 已經(jīng)實(shí)驗(yàn)過(guò). 確實(shí)可以的.
我們知道php(做為現(xiàn)在的主流開(kāi)發(fā)語(yǔ)言)本身是不支持多線程的, 但是我們的WEB服務(wù)器是支持多線程的.
也就是說(shuō)可以同時(shí)讓多人一起訪問(wèn). 這也是我在php(做為現(xiàn)在的主流開(kāi)發(fā)語(yǔ)言)中實(shí)現(xiàn)多線程的基礎(chǔ).
假設(shè)我們現(xiàn)在運(yùn)行的是a.php(做為現(xiàn)在的主流開(kāi)發(fā)語(yǔ)言)這個(gè)文件. 但是我在程序中又請(qǐng)求WEB服務(wù)器運(yùn)行另一個(gè)b.php(做為現(xiàn)在的主流開(kāi)發(fā)語(yǔ)言)
那么這兩個(gè)文件將是同時(shí)執(zhí)行的.
(PS: 一個(gè)鏈接請(qǐng)求發(fā)送之后, WEB服務(wù)器就會(huì)執(zhí)行它, 而不管客戶端是否已經(jīng)退出)
有些時(shí)候, 我們想運(yùn)行的不是另一個(gè)文件, 而是本文件中的一部分代碼.該怎么辦呢?
其實(shí)可是通過(guò)參數(shù)來(lái)控制a.php(做為現(xiàn)在的主流開(kāi)發(fā)語(yǔ)言)來(lái)運(yùn)行哪一段程序.
下面看一個(gè)例子:
//a.php(做為現(xiàn)在的主流開(kāi)發(fā)語(yǔ)言)
php(做為現(xiàn)在的主流開(kāi)發(fā)語(yǔ)言)代碼:--------------------------------------------------------------------------------
?php(做為現(xiàn)在的主流開(kāi)發(fā)語(yǔ)言)
function runThread()
{
$fp = fsockopen(localhost, 80, $errno, $errmsg);
fputs($fp, "GET /a.php(做為現(xiàn)在的主流開(kāi)發(fā)語(yǔ)言)?act=b "); //這里的第二個(gè)參數(shù)是HTTP協(xié)議中規(guī)定的請(qǐng)求頭
//不明白的請(qǐng)看RFC中的定義
fclose($fp);
}
function a()
{
$fp = fopen(result_a.log, w);
fputs($fp, Set in . Date(h:i:s, time()) . (double)microtime() . " ");
fclose($fp);
}
function b()
{
$fp = fopen(result_b.log, w);
fputs($fp, Set in . Date(h:i:s, time()) . (double)microtime() . " ");
建議先使用外部工具連接數(shù)據(jù)庫(kù)試試,看是否是數(shù)據(jù)庫(kù)支撐不了大規(guī)模數(shù)據(jù)的寫入查詢等等。檢查數(shù)據(jù)庫(kù)的連接數(shù),php配置的連接數(shù)
如果是連接數(shù)滿了,簡(jiǎn)單粗暴的方式,修改連接數(shù)配置。如果是mysql所消耗的內(nèi)存服務(wù)問(wèn)題,就要修改mysql內(nèi)存,加大配置。優(yōu)化一下耗時(shí)長(zhǎng)的業(yè)務(wù),這個(gè)和程序端的代碼,是否為多線程沒(méi)有太大的關(guān)系,從你發(fā)出來(lái)的情況,就是1個(gè)請(qǐng)求耗時(shí)太長(zhǎng),讓后其他請(qǐng)求沒(méi)有返回,要么是web服務(wù)內(nèi)存吃緊,要么是mysql服務(wù)壓力過(guò)大,連接數(shù)用滿的情況,應(yīng)該不太可能。
本文實(shí)例講述了PHP使用Pthread實(shí)現(xiàn)的多線程操作。分享給大家供大家參考,具體如下:
?php
class
vote
extends
Thread
{
public
$res
=
'';
public
$url
=
array();
public
$name
=
'';
public
$runing
=
false;
public
$lc
=
false;
public
function
__construct($name)
{
$this-res
=
'暫無(wú),第一次運(yùn)行.';
$this-param
=
0;
$this-lurl
=
0;
$this-name
=
$name;
$this-runing
=
true;
$this-lc
=
false;
}
public
function
run()
{
while
($this-runing)
{
if
($this-param
!=
0)
{
$nt
=
rand(1,
10);
echo
"線程[{$this-name}]收到任務(wù)參數(shù)::{$this-param},需要{$nt}秒處理數(shù)據(jù).\n";
$this-res
=
rand(100,
999);
sleep($nt);
$this-lurl
=
$this-param;
$this-param
=
'';
}
else
{
echo
"線程[{$this-name}]等待任務(wù)..\n";
}
sleep(1);
}
}
}
//這里創(chuàng)建線程池.
$pool[]
=
new
vote('a');
$pool[]
=
new
vote('b');
$pool[]
=
new
vote('c');
//啟動(dòng)所有線程,使其處于工作狀態(tài)
foreach
($pool
as
$w)
{
$w-start();
}
//派發(fā)任務(wù)給線程
for
($i
=
1;
$i
10;
$i++)
{
$worker_content
=
rand(10,
99);
while
(true)
{
foreach
($pool
as
$worker)
{
//參數(shù)為空則說(shuō)明線程空閑
if
($worker-param=='')
{
$worker-param
=
$worker_content;
echo
"[{$worker-name}]線程空閑,放入?yún)?shù){$worker_content},上次參數(shù)[{$worker-lurl}]結(jié)果[{$worker-res}].\n";
break
2;
}
}
sleep(1);
}
}
echo
"所有線程派發(fā)完畢,等待執(zhí)行完成.\n";
//等待所有線程運(yùn)行結(jié)束
while
(count($pool))
{
//遍歷檢查線程組運(yùn)行結(jié)束
foreach
($pool
as
$key
=
$threads)
{
if
($worker-param=='')
{
echo
"[{$threads-name}]線程空閑,上次參數(shù)[{$threads-lurl}]結(jié)果[{$threads-res}].\n";
echo
"[{$threads-name}]線程運(yùn)行完成,退出.\n";
//設(shè)置結(jié)束標(biāo)志
$threads-runing
=
false;
unset($pool[$key]);
}
}
echo
"等待中...\n";
sleep(1);
}
echo
"所有線程執(zhí)行完畢.\n";
希望本文所述對(duì)大家php程序設(shè)計(jì)有所幫助。
利用WEB服務(wù)器本身的多線程來(lái)處理,從WEB服務(wù)器多次調(diào)用我們需要實(shí)現(xiàn)多線程的程序。
PHP中也能多線程了,那么問(wèn)題也來(lái)了,那就是同步的問(wèn)題。
廈門電腦培訓(xùn)知道PHP本身是不支持多線程的,所以更不會(huì)有什么像Java中synchronize的方法了。
那我們?cè)撊绾巫瞿兀?.盡量不訪問(wèn)同一個(gè)資源。
以避免沖突。
但是可以同時(shí)像數(shù)據(jù)庫(kù)操作。
因?yàn)閿?shù)據(jù)庫(kù)是支持并發(fā)操作的。
所以在多線程的PHP中不要向同一個(gè)文件中寫入數(shù)據(jù)。
如果必須要寫的話,用別的方法進(jìn)行同步。
如調(diào)用flock對(duì)文件進(jìn)行加鎖等。
或建立臨時(shí)文件,并在另外的線程中等待這個(gè)文件的消失while(file_exits('xxx'));這樣就等于這個(gè)臨時(shí)文件存在時(shí),表示其實(shí)線程正在操作。
如果沒(méi)有了這個(gè)文件,說(shuō)明其它線程已經(jīng)釋放了這個(gè)。
2.盡量不要從runThread在執(zhí)行fputs后取這個(gè)socket中讀取數(shù)據(jù)。
因?yàn)橐獙?shí)現(xiàn)多線程,需要的用非阻塞模式。
即在像fgets這樣的函數(shù)時(shí)立即返回。
。
所以讀寫數(shù)據(jù)就會(huì)出問(wèn)題。
如果使用阻塞模式的話,程序就不算是多線程了。
他要等上面的返回才執(zhí)行下面的程序。
所以如果需要交換數(shù)據(jù)最后利用外面文件或數(shù)據(jù)中完成。
實(shí)在想要的話就用socket_set_nonblock($fp)來(lái)實(shí)現(xiàn)。
說(shuō)了這么多,倒底這個(gè)有沒(méi)有實(shí)際的意義呢?在什么時(shí)候需要這種用這種方法呢?答案是肯定的。
大家知道。
在一個(gè)不斷讀取網(wǎng)絡(luò)資源的應(yīng)用中,網(wǎng)絡(luò)的速度是瓶頸。
如果采多這種形式就可以同時(shí)以多個(gè)線程對(duì)不同的頁(yè)面進(jìn)行讀取。
這個(gè)不要多線程。
?php
set_time_limit(0);
// intignore_user_abort([ string$value] ) 設(shè)置關(guān)閉 瀏覽器是否一直執(zhí)行
function aaa(){
你的代碼
}
while(1){
aaa();
sleep(30);
}
?
把這個(gè)加入定時(shí)任務(wù)中就行。
標(biāo)題名稱:php的多線程操作數(shù)據(jù)庫(kù),php是多線程還是單線程
網(wǎng)站路徑:http://jinyejixie.com/article34/hsdose.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站設(shè)計(jì)公司、軟件開(kāi)發(fā)、關(guān)鍵詞優(yōu)化、自適應(yīng)網(wǎng)站、網(wǎng)站導(dǎo)航、搜索引擎優(yōu)化
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來(lái)源: 創(chuàng)新互聯(lián)