PHP下操作Linux消息隊列完成進程間通信的方法
更新時間:2010年07月24日 01:13:05 作者:
當我們開發(fā)的系統(tǒng)需要使用多進程方式運行時,進程間通信便成了至關重要的環(huán)節(jié)。消息隊列(message queue)是Linux系統(tǒng)進程間通信的一種方式。
關于Linux系統(tǒng)進程通信的概念及實現(xiàn)可查看:http://www.ibm.com/developerworks/cn/linux/l-ipc/
關于Linux系統(tǒng)消息隊列的概念及實現(xiàn)可查看:http://www.ibm.com/developerworks/cn/linux/l-ipc/part4/
PHP的sysvmsg模塊是對Linux系統(tǒng)支持的System V IPC中的System V消息隊列函數(shù)族的封裝。我們需要利用sysvmsg模塊提供的函數(shù)來進進程間通信。先來看一段示例代碼_1:
<?php
$message_queue_key = ftok(__FILE__, 'a');
$message_queue = msg_get_queue($message_queue_key, 0666);
var_dump($message_queue);
$message_queue_status = msg_stat_queue($message_queue);
print_r($message_queue_status);
//向消息隊列中寫
msg_send($message_queue, 1, "Hello,World!");
$message_queue_status = msg_stat_queue($message_queue);
print_r($message_queue_status);
//從消息隊列中讀
msg_receive($message_queue, 0, $message_type, 1024, $message, true, MSG_IPC_NOWAIT);
print_r($message."\r\n");
msg_remove_queue($message_queue);
?>
這段代碼的運行結果如下:
resource(4) of type (sysvmsg queue)
Array
(
[msg_perm.uid] => 1000
[msg_perm.gid] => 1000
[msg_perm.mode] => 438
[msg_stime] => 0
[msg_rtime] => 0
[msg_ctime] => 1279849495
[msg_qnum] => 0
[msg_qbytes] => 16384
[msg_lspid] => 0
[msg_lrpid] => 0
)
Array
(
[msg_perm.uid] => 1000
[msg_perm.gid] => 1000
[msg_perm.mode] => 438
[msg_stime] => 1279849495
[msg_rtime] => 0
[msg_ctime] => 1279849495
[msg_qnum] => 1
[msg_qbytes] => 16384
[msg_lspid] => 2184
[msg_lrpid] => 0
)
Hello,World!
可以看到已成功從消息隊列中讀取“Hello,World!”字符串
下面列舉一下示例代碼中的主要函數(shù):
ftok ( string $pathname , string $proj )
手冊上給出的解釋是:Convert a pathname and a project identifier to a System V IPC key。這個函數(shù)返回的鍵值唯一對應linux系統(tǒng)中一個消息隊列。在獲得消息隊列的引用之前都需要調用這個函數(shù)。
msg_get_queue ( int $key [, int $perms ] )
msg_get_queue()會根據(jù)傳入的鍵值返回一個消息隊列的引用。如果linux系統(tǒng)中沒有消息隊列與鍵值對應,msg_get_queue()將會創(chuàng)建一個新的消息隊列。函數(shù)的第二個參數(shù)需要傳入一個int值,作為新創(chuàng)建的消息隊列的權限值,默認為0666。這個權限值與linux命令chmod中使用的數(shù)值是同一個意思,因為在linux系統(tǒng)中一切皆是文件。
msg_send ( resource $queue , int $msgtype , mixed $message [, bool $serialize [, bool $blocking [, int &$errorcode ]]] )
顧名思義,該函數(shù)用來向消息隊列中寫數(shù)據(jù)。
msg_stat_queue ( resource $queue )
這個函數(shù)會返回消息隊列的元數(shù)據(jù)。消息隊列元數(shù)據(jù)中的信息很完整,包括了消息隊列中待讀取的消息數(shù)、最后讀寫隊列的進程ID等。示例代碼在第8行調用該函數(shù)返回的數(shù)組中隊列中待讀取的消息數(shù)msg_qnum值為0。
msg_receive ( resource $queue , int $desiredmsgtype , int &$msgtype , int $maxsize , mixed &$message [, bool $unserialize [, int $flags [, int &$errorcode ]]] )
msg_receive用于讀取消息隊列中的數(shù)據(jù)。
msg_remove_queue ( resource $queue )
msg_remove_queue用于銷毀一個隊列。
示例代碼_1只是展示了PHP操作消息隊列函數(shù)的應用。下面的代碼具體描述了進程間通信的場景
<?php
$message_queue_key = ftok(__FILE__, 'a');
$message_queue = msg_get_queue($message_queue_key, 0666);
$pids = array();
for ($i = 0; $i < 5; $i++) {
//創(chuàng)建子進程
$pids[$i] = pcntl_fork();
if ($pids[$i]) {
echo "No.$i child process was created, the pid is $pids[$i]\r\n";
} elseif ($pids[$i] == 0) {
$pid = posix_getpid();
echo "process.$pid is writing now\r\n";
msg_send($message_queue, 1, "this is process.$pid's data\r\n");
posix_kill($pid, SIGTERM);
}
}
do {
msg_receive($message_queue, 0, $message_type, 1024, $message, true, MSG_IPC_NOWAIT);
echo $message;
//需要判斷隊列是否為空,如果為空就退出
//break;
} while(true)
?>
運行結果為:
No.0 child process was created, the pid is 5249
No.1 child process was created, the pid is 5250
No.2 child process was created, the pid is 5251
No.3 child process was created, the pid is 5252
No.4 child process was created, the pid is 5253
process.5251 is writing now
this is process.5251's data
process.5253 is writing now
process.5252 is writing now
process.5250 is writing now
this is process.5253's data
this is process.5252's data
this is process.5250's data
process.5249 is writing now
this is process.5249's data
這段程序每次的運行結果都會不同,這正說明了多進程的異步性。從結果也能看出消息隊列FIFO特性。
以上便是我研究的一點心得。接下來將會繼續(xù)研究PHP利用信號、socket等進行進程間通信的方法。
關于Linux系統(tǒng)消息隊列的概念及實現(xiàn)可查看:http://www.ibm.com/developerworks/cn/linux/l-ipc/part4/
PHP的sysvmsg模塊是對Linux系統(tǒng)支持的System V IPC中的System V消息隊列函數(shù)族的封裝。我們需要利用sysvmsg模塊提供的函數(shù)來進進程間通信。先來看一段示例代碼_1:
復制代碼 代碼如下:
<?php
$message_queue_key = ftok(__FILE__, 'a');
$message_queue = msg_get_queue($message_queue_key, 0666);
var_dump($message_queue);
$message_queue_status = msg_stat_queue($message_queue);
print_r($message_queue_status);
//向消息隊列中寫
msg_send($message_queue, 1, "Hello,World!");
$message_queue_status = msg_stat_queue($message_queue);
print_r($message_queue_status);
//從消息隊列中讀
msg_receive($message_queue, 0, $message_type, 1024, $message, true, MSG_IPC_NOWAIT);
print_r($message."\r\n");
msg_remove_queue($message_queue);
?>
這段代碼的運行結果如下:
復制代碼 代碼如下:
resource(4) of type (sysvmsg queue)
Array
(
[msg_perm.uid] => 1000
[msg_perm.gid] => 1000
[msg_perm.mode] => 438
[msg_stime] => 0
[msg_rtime] => 0
[msg_ctime] => 1279849495
[msg_qnum] => 0
[msg_qbytes] => 16384
[msg_lspid] => 0
[msg_lrpid] => 0
)
Array
(
[msg_perm.uid] => 1000
[msg_perm.gid] => 1000
[msg_perm.mode] => 438
[msg_stime] => 1279849495
[msg_rtime] => 0
[msg_ctime] => 1279849495
[msg_qnum] => 1
[msg_qbytes] => 16384
[msg_lspid] => 2184
[msg_lrpid] => 0
)
Hello,World!
可以看到已成功從消息隊列中讀取“Hello,World!”字符串
下面列舉一下示例代碼中的主要函數(shù):
復制代碼 代碼如下:
ftok ( string $pathname , string $proj )
手冊上給出的解釋是:Convert a pathname and a project identifier to a System V IPC key。這個函數(shù)返回的鍵值唯一對應linux系統(tǒng)中一個消息隊列。在獲得消息隊列的引用之前都需要調用這個函數(shù)。
msg_get_queue ( int $key [, int $perms ] )
msg_get_queue()會根據(jù)傳入的鍵值返回一個消息隊列的引用。如果linux系統(tǒng)中沒有消息隊列與鍵值對應,msg_get_queue()將會創(chuàng)建一個新的消息隊列。函數(shù)的第二個參數(shù)需要傳入一個int值,作為新創(chuàng)建的消息隊列的權限值,默認為0666。這個權限值與linux命令chmod中使用的數(shù)值是同一個意思,因為在linux系統(tǒng)中一切皆是文件。
msg_send ( resource $queue , int $msgtype , mixed $message [, bool $serialize [, bool $blocking [, int &$errorcode ]]] )
顧名思義,該函數(shù)用來向消息隊列中寫數(shù)據(jù)。
msg_stat_queue ( resource $queue )
這個函數(shù)會返回消息隊列的元數(shù)據(jù)。消息隊列元數(shù)據(jù)中的信息很完整,包括了消息隊列中待讀取的消息數(shù)、最后讀寫隊列的進程ID等。示例代碼在第8行調用該函數(shù)返回的數(shù)組中隊列中待讀取的消息數(shù)msg_qnum值為0。
msg_receive ( resource $queue , int $desiredmsgtype , int &$msgtype , int $maxsize , mixed &$message [, bool $unserialize [, int $flags [, int &$errorcode ]]] )
msg_receive用于讀取消息隊列中的數(shù)據(jù)。
msg_remove_queue ( resource $queue )
msg_remove_queue用于銷毀一個隊列。
示例代碼_1只是展示了PHP操作消息隊列函數(shù)的應用。下面的代碼具體描述了進程間通信的場景
復制代碼 代碼如下:
<?php
$message_queue_key = ftok(__FILE__, 'a');
$message_queue = msg_get_queue($message_queue_key, 0666);
$pids = array();
for ($i = 0; $i < 5; $i++) {
//創(chuàng)建子進程
$pids[$i] = pcntl_fork();
if ($pids[$i]) {
echo "No.$i child process was created, the pid is $pids[$i]\r\n";
} elseif ($pids[$i] == 0) {
$pid = posix_getpid();
echo "process.$pid is writing now\r\n";
msg_send($message_queue, 1, "this is process.$pid's data\r\n");
posix_kill($pid, SIGTERM);
}
}
do {
msg_receive($message_queue, 0, $message_type, 1024, $message, true, MSG_IPC_NOWAIT);
echo $message;
//需要判斷隊列是否為空,如果為空就退出
//break;
} while(true)
?>
運行結果為:
復制代碼 代碼如下:
No.0 child process was created, the pid is 5249
No.1 child process was created, the pid is 5250
No.2 child process was created, the pid is 5251
No.3 child process was created, the pid is 5252
No.4 child process was created, the pid is 5253
process.5251 is writing now
this is process.5251's data
process.5253 is writing now
process.5252 is writing now
process.5250 is writing now
this is process.5253's data
this is process.5252's data
this is process.5250's data
process.5249 is writing now
this is process.5249's data
這段程序每次的運行結果都會不同,這正說明了多進程的異步性。從結果也能看出消息隊列FIFO特性。
以上便是我研究的一點心得。接下來將會繼續(xù)研究PHP利用信號、socket等進行進程間通信的方法。
您可能感興趣的文章:
- php實現(xiàn)的一個簡單json rpc框架實例
- php xml-rpc遠程調用
- AMFPHP php遠程調用(RPC, Remote Procedure Call)工具 快速入門教程
- php中關于codeigniter的xmlrpc的類在進行數(shù)據(jù)交換時的類型問題
- PHP實現(xiàn)與java 通信的插件使用教程
- php與java通過socket通信的實現(xiàn)代碼
- PHP與Java進行通信的實現(xiàn)方法
- PHP的Socket通信之UDP通信實例
- PHP 與 js的通信(via ajax,json)
- PHP與Go語言之間的通信詳解
- php中socket通信機制實例詳解
- PHP實現(xiàn)創(chuàng)建一個RPC服務操作示例
相關文章
php利用iframe實現(xiàn)無刷新文件上傳功能的代碼
上傳原理很簡單就是利用表單的打開方式為iframe的id名,這樣就可以在當前頁面的iframe打來了,實現(xiàn)文件上傳,再利用js返回上傳結果。2011-09-09fleaphp crud操作之findByField函數(shù)的使用方法
fleaphp crud操作之findByField函數(shù)的用法分享,需要的朋友可以參考下。2011-04-04php使用ZipArchive提示Fatal error: Class ZipArchive not found in的
這篇文章主要介紹了php使用ZipArchive提示Fatal error: Class ZipArchive not found in的解決方法,是使用ZipArchive時經(jīng)常會遇到的問題,需要的朋友可以參考下2014-11-11詳談php ip2long 出現(xiàn)負數(shù)的原因及解決方法
下面小編就為大家?guī)硪黄斦刾hp ip2long 出現(xiàn)負數(shù)的原因及解決方法。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2017-04-04