共有メモリとメッセージキューに対する PHP 操作

PHP における共有メモリとメッセージキューの操作

スクリプト プログラムとして、PHP のライフ サイクルは通常短いです。たとえば、Web アプリケーションでは、1 つのリクエストが PHP の実行サイクルとなり、リクエストが終了するとライフ サイクルが終了します。したがって、PHP が共有する必要があるリソースを処理するときは、通常、共有データをデータベースや dbm などのファイルに保存し、メモリを使用して共有を実現します。 memcache などの既存のツールを選択して、オペレーティング システムの共有メモリ セグメントにアクセスする独自のコードを作成することもできます。

PHP で共有メモリ セグメントを操作するための関数には、SystemVIPC と SharedMemory の 2 つのセットがあります。その中でも、SystemVIPCシリーズの関数は、SharedMemoryのように読み書き時にオフセットや長さなどを把握する必要がなく、シリアル化とデシリアライズを行ったり来たりする必要がないため、より便利にデータを操作できます。 SharedMemory 関数は文字列パラメータのデータのみをサポートします。ただし、SystemVIPCシリーズはWindowsをサポートしていないため、win環境で使用したい場合はSharedMemoryを選択するしかありません。

PHP はデフォルトではこれらの関数をサポートしていないため、PHP を再コンパイルする必要があります。使用方法:

SystemV セマフォ、コンパイル時に –enable-sysvsem を追加

SystemV 共有メモリ、コンパイル時に –enable-sysvshm を追加

SystemV メッセージ キュー、コンパイル時に –enable-sysvmsg を追加

SharedMemory、コンパイル時に –enable-shmop を追加

まず SharedMemory の例を書きます:

beb82b51d7c0588a65946826e7bdfeca

System V shm の別の例を書きます:

f54b6b9fd18fe76d263c19571030e33d

ご覧のとおり、sysV はデータごとに対応する var_key を設定するため、shmop のように別の共有メモリ領域を適用する必要がなく、複数のデータを同じメモリ領域に保存でき、シリアル化の干渉も排除されます (ただし、データは最終的にシリアル化された形式で保存されるため、開発者が手動で実装する必要はありません)。

この例は単純ですが、shm_attach または shmop_open のいずれであっても、要求されるメモリのサイズは、後続のデータの長さを満たしている必要があります。シリアル化後のデータ自体と、PHP の少量のヘッダー情報が追加されます。公式 PHP ドキュメントの誰かが、適用されるメモリ サイズを計算する式を提案しました。この式により、要求されたメモリが指定されたデータを格納するのに十分であることが保証されます。式は次のとおりです。

eb08e5cc6f9299ffd29d7f337033b98c

この式がすべての状況に当てはまるかどうかはあえて言えませんので、プログラム側で共有メモリに置くデータ構造を設計し、データサイズが一定の範囲内になるようにするのが良いと思います。

また、共有メモリの無駄を防ぐため、データが不要になった場合には、対応するremoveメソッドを速やかに呼び出してリソースを解放します。

共有メモリを紹介した後、メッセージ キュー (これも System V IPC 関数グループに含まれます) について触れてみましょう。メッセージ キューは別のタイプの共有メモリとみなされているようですが、データの保存方法は多少異なります。簡単に言うと、各キーはキューに対応しており、各キューには複数のデータを格納できます。データは先入れ先出しの原則に従って操作されます。 PHP ドキュメントの例は、各関数のアプリケーションの優れた入門書です。

e246149486f8de267a70d0e86ebd6db2 0) {
			msg_receive($seg, $argv[2], $msgtype, 1024, $data, true, MSG_IPC_NOWAIT);
			var_dump($msgtype);
			var_dump($data);
			echo "
";
		} else {
			echo "No Msg...
";
		}
		break;

	case "stat" :
		print_r(msg_stat_queue($seg));
		break;

	case "remove" :
		msg_remove_queue($seg);
		break;
}
?>

メッセージ キュー内のデータにもサイズ制約が適用されます。具体的な制約範囲は、msg_stat_queue の msg_qbytes で確認できます。このコードの唯一の小さな変更は、メッセージを受信するときに MSG_IPC_NOWAIT が指定されていることです。それ以外の場合、ターゲット キューにデータがない場合、デフォルトで永久に待機します。

一般に、共有メモリまたはメッセージ キューが使用され、これにはマルチスレッド/プロセス、または言語間のデータ転送が含まれます。プロセス間で共有されるphpスクリプト・データであれば、気をつければ問題ありません。クロスランゲージが必要な場合は、あらゆる種類の奇妙な問題に遭遇する可能性があります（笑）、私はまだ試していませんが、インターネット上で他の人が投稿した苦い投稿を見ました。将来的にはチャンスがあります。

共有メモリ、セマフォ、メッセージ キューをデバッグする場合、ipcs や ipcrm コマンドなどの Linux システム コマンドと連携して、セマフォやメッセージ キューのデータ ストレージとリソース割り当てを監視できます。

PHP を使用して Linux メッセージ キューを操作し、プロセス間通信を完了します

私たちが開発するシステムをマルチプロセス モードで実行する必要がある場合、プロセス間通信が重要なリンクになります。メッセージキュー（messagequeue）は、Linuxシステムにおけるプロセス間通信の方式です。

Linux システムにおけるプロセス通信の概念と実装については、http://www.ibm.com/developerworks/cn/linux/l-ipc/

を参照してください。

Linux システムにおけるメッセージキューの概念と実装については、http://www.ibm.com/developerworks/cn/linux/l-ipc/part4/

を参照してください。

PHP の sysvmsg モジュールは、Linux システムでサポートされる SystemVIPC の SystemV メッセージ キュー関数ファミリーをカプセル化したものです。プロセス間通信には sysvmsg モジュールが提供する関数を使用する必要があります。まずサンプルコードを見てみましょう_1:

2c25003fb24a933dc75183eda8898229

このコードを実行した結果は次のとおりです:

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!」という文字列がメッセージ キューから正常に読み取られたことがわかります

サンプルコードの主な関数は以下のとおりです。

ftok ( string $pathname , string $proj )

　　手册上给出的解释是：Convert a pathname and a project identifier to a System V IPC key。这个函数返回的键值唯一对应linux系统中一个消息队列。在获得消息队列的引用之前都需要调用这个函数。

　　msg_get_queue ( int $key [, int $perms ] )

　　msg_get_queue()会根据传入的键值返回一个消息队列的引用。如果linux系统中没有消息队列与键值对应，msg_get_queue()将会创建一个新的消息队列。函数的第二个参数需要传入一个int值，作为新创建的消息队列的权限值，默认为0666。这个权限值与linux命令chmod中使用的数值是同一个意思，因为在linux系统中一切皆是文件。

　　msg_send ( resource $queue , int $msgtype , mixed $message [, bool $serialize [, bool $blocking [, int &$errorcode ]]] )

　　顾名思义，该函数用来向消息队列中写数据。

　　msg_stat_queue ( resource $queue )

　　这个函数会返回消息队列的元数据。消息队列元数据中的信息很完整，包括了消息队列中待读取的消息数、最后读写队列的进程ID等。示例代码在第8行调用该函数返回的数组中队列中待读取的消息数msg_qnum值为0。

　　msg_receive ( resource $queue , int $desiredmsgtype , int &$msgtype , int $maxsize , mixed &$message [, bool$unserialize [, int $flags [, int &$errorcode ]]] )

　　msg_receive用于读取消息队列中的数据。

　　msg_remove_queue ( resource $queue )

　　msg_remove_queue用于销毁一个队列。

　　示例代码_1只是展示了PHP操作消息队列函数的应用。下面的代码具体描述了进程间通信的场景

 

 

66d550f793a917456a182ccc3cd44695

运行结果为：
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特性。