PHP程序及程序間通訊

2022-11-24 21:26:09 字數 3836 閱讀 9560

程序是一個具有獨立功能的程式關於某個資料集合的一次執行活動。換句話說就是,在系統排程多個cpu的時候,一個程式的基本單元。程序對於大多數的語言都不是一個陌生的概念,作為"世界上最好的語言php"當然也例外。

php中的程序是以擴充套件的形式來完成。通過這些擴充套件,我們能夠很輕鬆的完成程序的一系列動作。

這些擴充套件只能在linux/mac中使用,window下是不支援。最後建議php版本為5.5+。

一個簡單的php多程序例子,該例子中,一個子程序,一個父程序。子程序輸出5次,退出程式。

$parentpid = posix_getpid();

echo "parent progress pid:\n";

$childlist = array();

$pid = pcntl_fork();

if ( $pid == -1) else if ($pid == 0) )child progress is running! \n";

$rand = rand(1,3);

sleep($rand);

}exit("()child progress end!\n");

} else

// 等待子程序結束

pcntl_wait($status);

echo "()main progress end!";

完美,終於建立了一個子程序,一個父程序。完了麼?沒有,各個程序之間相互獨立的,沒有任何交集,使用範圍嚴重受到現在。怎麼辦,哪就程序間通訊(interprogress communication)唄。

通常linux中的程序通訊方式有:訊息佇列、訊號量、共享記憶體、訊號、管道、socket。

1.訊息佇列

訊息佇列是存放在記憶體中的一個佇列。如下**將建立3個生產者子程序,2個消費者子程序。這5個程序將通過訊息佇列通訊。

$parentpid = posix_getpid();

echo "parent progress pid:\n";$childlist = array();

// 建立訊息佇列,以及定義訊息型別(類似於資料庫中的庫)

$id = ftok(__file__,'m');

$msgqueue = msg_get_queue($id);

const msg_type = 1;

// 生產者

function producer())progress create! ";

msg_send($msgqueue,msg_type,$str);

$rand = rand(1,3);

sleep($rand);

}}// 消費者

function consumer() | consumer() destroy \n";

$rand = rand(1,3);

sleep($rand);

}}function createprogress($callback) else if ($pid == 0) )child progress end!\n");

}else

}// 3個寫程序

for ($i = 0; $i < 3; $i ++ ) \n";

}// 2個寫程序

for ($i = 0; $i < 2; $i ++ ) \n";

}// 等待所有子程序結束

while(!empty($childlist))

}echo "()main progress end!\n";

由於訊息佇列去資料是,只有一個程序能去到,所以不需要額外的鎖或訊號量。

2. 訊號量與共享記憶體

訊號量:是系統提供的一種原子操作,一個訊號量,同時只有你個程序能操作。一個程序獲得了某個訊號量,就必須被該程序釋放掉。

共享記憶體:是系統在記憶體中開闢的一塊公共的記憶體區域,任何一個程序都可以訪問,在同一時刻,可以有多個程序訪問該區域,為了保證資料的一致性,需要對該記憶體區域加鎖或訊號量。

以下,建立多個程序修改記憶體中的同一個值。

$parentpid = posix_getpid();

echo "parent progress pid:\n";

$childlist = array();

// 建立共享記憶體,建立訊號量,定義共享key

$shm_id = ftok(__file__,'m');

$sem_id = ftok(__file__,'s');

$sharememory = shm_attach($shm_id);

$signal = sem_get($sem_id);

const share_key = 1;

// 生產者

function producer()) count: \n";

}else) count: 0\n";

}// 用完釋放

sem_release($signal);

$rand = rand(1,3);

sleep($rand);

}}function createprogress($callback) else if ($pid == 0) )child progress end!\n");

}else

}// 3個寫程序

for ($i = 0; $i < 3; $i ++ ) \n";

}// 等待所有子程序結束

while(!empty($childlist))

}// 釋放共享記憶體與訊號量

shm_remove($sharememory);

sem_remove($signal);

echo "()main progress end!\n";

3.訊號

訊號是一種系統呼叫。通常我們用的kill命令就是傳送某個訊號給某個程序的。具體有哪些訊號可以在liunx/mac中執行kill -l檢視。下面這個例子中,父程序等待5秒鐘,向子程序傳送sigint訊號。子程序捕獲訊號,掉訊號處理函式處理。

$parentpid = posix_getpid();

echo "parent progress pid:\n";

// 定義一個訊號處理函式

function sighandler($signo) progress,oh no ,i'm killed!\n";

exit(1);

}$pid = pcntl_fork();

if ( $pid == -1) else if ($pid == 0) child progress is running!\n";

sleep(1);

}exit("()child progress end!\n");

}else

echo "()main progress end!\n";

4.管道(有名管道)

管道是比較常用的多程序通訊手段,管道分為無名管道與有名管道,無名管道只能用於具有親緣關係的程序間通訊,而有名管道可以用於同一主機上任意程序。這裡只介紹有名管道。下面的例子,子程序寫入資料,父程序讀取資料。

// 定義管道路徑,與建立管道

$pipe_path = '/data/test.pipe';

if(!file_exists($pipe_path))

}$pid = pcntl_fork();

if($pid == 0)

exit('child end!');

}else\n";

$rand = rand(1,2);

sleep($rand);

}}

5.socket

socket即我們常說的套接字程式設計。這個待補充。