C言語で作ったプロセス同士はもちろん、C言語で作ったプロセスとPHPで作ったスクリプト間でもメッセージキューであれこれやり取りしたい。手順としては、とりあえずC言語側でもPHPでも同じ。
http://www.fireproject.jp/feature/c-language/ipc/message-queue.html
より、メッセージキューの実験
semmainで作ったセマフォをsemotherでロック、すると別のsemotherを起動すると先に起動したsemotherが終わるまで後からのは待つ
cat > sendque.c
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <unistd.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
// バッファサイズBUFSIZは8192バイトもあるのでもったいないから1024にする。
#define BUFFSIZE 1024
/* メッセージキューで送受信するメッセージ
msgsnd,msgrcvの*msgpにはこの構造体へのポインタをいれる */
struct msgbuf{
/* メッセージの先頭はかならずlong int型でなければならない */
long int type;
char data[BUFFSIZE];
};
int main(int argc, char *argv[])
{
/* メッセージキューのID */
int msqid;
/* メッセージ */
struct msgbuf message;
/* パラメータチェック */
if(argc != 3){
fprintf(stderr,"Usage: %s type string\n",argv[0]);
exit(EXIT_FAILURE);
}else{
/* messageのtypeは正でなければならない */
if((message.type = atol(argv[1])) <= 0){
fprintf(stderr,"type value is invalid\n");
exit(EXIT_FAILURE);
}
strncpy(message.data,argv[2],BUFFSIZE);
}
printf("BUFFSIZEEは%0dバイトです\n",BUFFSIZE);
/* メッセージキューの作成,取得 */
errno = 0;
if((msqid = msgget((key_t)1111, 0666 | IPC_CREAT)) == -1){
perror("msgget failure");
exit(EXIT_FAILURE);
}
/* メッセージを送信 */
errno = 0;
if(msgsnd(msqid, &message, BUFFSIZE, 0) == -1){
perror("msgsnd failure");
exit(EXIT_FAILURE);
}
exit(EXIT_SUCCESS);
}
gcc -O2 sendque.c -o sendque
cat > rcvque.c
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <unistd.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
// バッファサイズBUFSIZは8192バイトもあるのでもったいないから1024にする。
#define BUFFSIZE 1024
/* メッセージキューで送受信するメッセージ
msgsnd,msgrcvの*msgpにはこの構造体へのポインタをいれる */
struct msgbuf{
/* メッセージの先頭はかならずlong int型でなければならない */
long int type;
char data[BUFFSIZE];
};
int main(int argc, char *argv[])
{
/* メッセージキューのID */
int msqid;
/* メッセージ */
struct msgbuf message;
long int read_type;
/* パラメータチェック */
if(argc != 2){
fprintf(stderr,"Usage: %s type\n",argv[0]);
exit(EXIT_FAILURE);
}else{
/* 受信タイプの設定 */
read_type = atol(argv[1]);
}
/* メッセージキューの作成,取得 */
errno = 0;
if((msqid = msgget((key_t)1111, 0666 | IPC_CREAT)) == -1){
perror("msgget failure");
exit(EXIT_FAILURE);
}
while(1){
/* メッセージの受信 */
errno = 0;
if(msgrcv(msqid, &message, BUFFSIZE, read_type, 0) == -1){
perror("msgrcv failure");
break;
}else{
fprintf(stdout,"received message:\t%s\n",message.data);
}
/* "exit"を受信すると終了する */
if(strcmp(message.data, "exit") == 0){
break;
}
}
/* メッセージキューの削除 */
errno = 0;
if(msgctl(msqid, IPC_RMID, NULL) == -1){
perror("msgctl failure");
exit(EXIT_FAILURE);
}
exit(EXIT_SUCCESS);
}
gcc -O2 rcvque.c -o rcvque
できたら、
./sendque 111 aaaaa
./sendque 333 ccccc
./sendque 222 bbbbb
./sendque 444 ddddd
./sendque 555 exit
と送ってみて、別プロセスで
./rcvque 333
とかすると該当するtype(ID)のメッセージを取ってこれる
これをPHPで受けるとすると、上記のサンプルソースではキューのキーが「1111」なので、以下のようなスクリプトで存在を確認できる。
<?php
$QKEY = 1111;
if (msg_queue_exists($QKEY))
{
print $QKEY."はあります\n";
}
else
{
print $QKEY."がありません!?\n";
}
?>
このキューに実際にアクセスするには msg_get_queue() で一度リソースを取得する必要がある。
<?php
$QKEY = 1111;
$QUEUE = msg_get_queue($QKEY, 0666);
if (msg_queue_exists($QKEY))
{
// var_dump(msg_stat_queue($QUEUE));
// キューの先頭からの
if (msg_receive($QUEUE, 0, $MSGTYPE, 4096, $MSGDATA, FALSE, MSG_IPC_NOWAIT | MSG_NOERROR, $ERRCODE) == TRUE)
{
print "TYPE:".$MSGTYPE." MSG:".$MSGDATA."\n";
}
else
{
if ($ERRCODE & MSG_NOERROR)
{
print "キューにデータがありませんでした!?\n";
}
else
{
print "キューから取得できませんでした!?\n";
}
}
}
else
{
print "キューがありません!?\n";
}
?>