メッセージキューとは何ですか? Linux でのメッセージ キューの使用
- PHP中文网オリジナル
- 2017-06-21 11:54:402565ブラウズ
-
int msgget(key_t, key, int msgflg);
などIPC メカニズムでは、プログラムは特定のメッセージ キューに名前を付けるためのキーを提供する必要があります。 msgflgは、メッセージキューのアクセス許可を示す許可フラグであり、ファイルのアクセス許可と同じである。 msgflg は IPC_CREAT と OR できます。これは、キーで指定されたメッセージ キューが存在しない場合にメッセージ キューを作成することを意味します。キーで指定されたメッセージ キューが存在する場合、IPC_CREAT フラグは無視され、識別子のみが返されます。
- const
- void *msg_ptr,
size _t msg_sz、int msgflg) ;
msgid は、msgget 関数によって返されるメッセージ キュー識別子です。
-
long
int message _タイプ -
/* 転送したいデータ*/
};
msg_sz は、msg_ptr が指すメッセージの長さではないことに注意してください。構造全体の長さ、つまり msg_sz には長整数のメッセージ タイプのメンバー変数の長さは含まれません。
-
int msgrcv(int msgid, void *msg_ptr, size_t msg_st, long int msgtype, int msgflg); msgid、msg_ptr、msg_st関数はmsgsnd関数と同じです。
- IPC_RMID: メッセージ キューを削除します
buf は msgid_ds 構造体へのポインターです。キュー モードとアクセス権の構造のメッセージを指します。 msgid_ds 構造体には少なくとも次のメンバーが含まれます:
[cpp]
成功した場合は 0 を返し、失敗した場合は -1 を返します。
3. メッセージを使用するキュー プロセス間通信
ノンストップ。メッセージ キューの定義と使用可能なインターフェイスを紹介した後、プロセス間通信がどのように許可されるかを見てみましょう。無関係なプロセスでも通信できるため、ここでは情報の送受信を表す msgreceive と msgsned という 2 つのプログラムを作成します。通常の状況では、両方のプログラムがメッセージを作成することを許可しますが、最後のメッセージを受信した後に削除するのは受信者だけです。 - [cpp]
- view plain copy
print?
#include
#include
#include
#include
#include
#include
struct msg_st
{
long int msg_type;
char text[BUFSIZ];
};
int main()
{
int running = 1;
int msgid = -1;
struct msg_st データ;
long int msgtype = 0; //注意1
//建立メッセージ队列
msgid = msgget((key_t)1234, 0 666 | IPC_CREAT);
if(msgid == -1)
{
fprintf(stderr, "msgget 失敗 エラー: %dn" 、エラー番号);
終了(EXIT_FAILURE);
}
//从队列中获取消息、直到遇到終了メッセージ止
-
while(running)
{
if(msgrcv(msgid ,(void*)&data, BUFSIZ, msgtype, 0) == -1)
{
fprintf(stderr, "msgrcv failed)エラー番号あり: %dn", エラー番号);
終了(EXIT_FAILURE);
}
printf("あなたが書きました: %sn",data.text);
//遇到end结束
-
if(strncmp(data.text, "end", 3) == 0)
実行中 = 0;
}
//删除消息队列
if(msgctl(msgid, IPC_RMID, 0) == -1)
{
fprintf(stderr, 「msgctl(IPC_RMID) が失敗しました」);
終了(EXIT_FAILURE);
}
exit(EXIT_SUCCESS);
}
#include
#include
#include
#include
#include
#include
#define MAX_TEXT 512
struct msg_st
{
-
long int msg_type;
char text[MAX_TEXT];
};
int main()
{
int running = 1;
struct msg_st データ;
char バッファ[BUFSIZ];
int msgid = -1;
//建立メッセージ队列
msgid = msgget((key_t)1234, 0666 | IPC_CREAT);
if(msgid == -1)
{
fprintf(stderr, "msgget 失敗 エラー: %dn" 、エラー番号);
終了(EXIT_FAILURE);
}
//向消息队列中写メッセージ、書入終了まで
while(running)
{
//输入力データ
printf("Enter some text: ");
fgets(buffer, BUFSIZ, stdin);
data.msg_type = 1; //注意2
strcpy(data.text, buffer);
//向队列送信データ
if(msgsnd(msgid, (void*)&data, MAX_TEXT, 0) == -1)
{
fprintf(stderr, "msgsnd 失敗");
終了(EXIT_FAILURE);
}
//输入end结束输入
if(strncmp(buffer, "end") , 3) == 0)
実行中 = 0;
睡眠(1);
}
exit(EXIT_SUCCESS);
}
msgreceive が情報を受信して出力せず、msgsend 入力終了時に msgreceive が終了しないことがわかります。 . jobs コマンドを使用すると、まだバックグラウンドで実行されていることがわかります。
以上がメッセージキューとは何ですか? Linux でのメッセージ キューの使用の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。