芯耀
8.6 消息隊列
8.6.1 消息隊列概述
顧名思義，消息隊列就是一些消息的列表。用戶可以從消息隊列中添加消息和讀取消息等。從這點上看，消息隊列具有一定的FIFO特性，但是它可以實現(xiàn)消息的隨機查詢，比FIFO具有更大的優(yōu)勢。同時，這些消息又是存在于內(nèi)核中的，由“隊列ID”來標識。
8.6.2 消息隊列的應用
1．函數(shù)說明
消息隊列的實現(xiàn)包括創(chuàng)建或打開消息隊列、添加消息、讀取消息和控制消息隊列這4種操作。其中創(chuàng)建或打開消息隊列使用的函數(shù)是msgget()，這里創(chuàng)建的消息隊列的數(shù)量會受到系統(tǒng)消息隊列數(shù)量的限制；添加消息使用的函數(shù)是msgsnd()函數(shù)，它把消息添加到已打開的消息隊列末尾；讀取消息使用的函數(shù)是msgrcv()，它把消息從消息隊列中取走，與FIFO不同的是，這里可以指定取走某一條消息；最后控制消息隊列使用的函數(shù)是msgctl()，它可以完成多項功能。
2．函數(shù)格式
表8.23列舉了msgget()函數(shù)的語法要點。
表8.23 msgget()函數(shù)語法要點
|
所需頭文件 |
#include <sys/types.h> |
|
|
函數(shù)原型 |
int msgget(key_t key, int msgflg) |
|
|
函數(shù)傳入值 |
key：消息隊列的鍵值，多個進程可以通過它訪問同一個消息隊列，其中有個特殊值IPC_PRIVATE。它用于創(chuàng)建當前進程的私有消息隊列 |
|
|
msgflg：權限標志位 |
||
|
函數(shù)返回值 |
成功：消息隊列ID |
|
|
出錯：-1 |
||
表8.24列舉了msgsnd()函數(shù)的語法要點。
表8.24 msgsnd()函數(shù)語法要點
|
所需頭文件 |
#include <sys/types.h> |
|
|
函數(shù)原型 |
int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg) |
|
|
函數(shù)傳入值 |
msqid：消息隊列的隊列ID |
|
|
msgp：指向消息結構的指針。該消息結構msgbuf通常為： { long mtype; /* 消息類型，該結構必須從這個域開始 */
char mtext[1]; /* 消息正文 */ |
||
|
msgsz：消息正文的字節(jié)數(shù)（不包括消息類型指針變量） |
||
|
msgflg： |
IPC_NOWAIT若消息無法立即發(fā)送（比如：當前消息隊列已滿），函數(shù)會立即返回 |
|
|
0：msgsnd調(diào)阻塞直到發(fā)送成功為止 |
||
|
函數(shù)返回值 |
成功：0 |
|
|
出錯：-1 |
||
表8.25列舉了msgrcv()函數(shù)的語法要點。
表8.25 msgrcv()函數(shù)語法要點
|
所需頭文件 |
#include <sys/types.h> |
|||
|
函數(shù)原型 |
int msgrcv(int msgid, void *msgp, size_t msgsz, long int msgtyp, int msgflg) |
|||
|
函數(shù)傳入值 |
msqid：消息隊列的隊列ID |
|||
|
msgp：消息緩沖區(qū), 同于msgsnd()函數(shù)的msgp |
||||
|
msgsz：消息正文的字節(jié)數(shù)（不包括消息類型指針變量） |
||||
|
msgtyp： |
0：接收消息隊列中第一個消息 |
|||
|
大于0：接收消息隊列中第一個類型為msgtyp的消息 |
||||
|
小于0：接收消息隊列中第一個類型值不小于msgtyp絕對值且類型值又最小的消息 |
||||
|
函數(shù)傳入值 |
msgflg： |
MSG_NOERROR：若返回的消息比msgsz字節(jié)多，則消息就會截短到msgsz字節(jié)，且不通知消息發(fā)送進程 |
||
|
IPC_NOWAIT若在消息隊列中并沒有相應類型的消息可以接收，則函數(shù)立即返回 |
||||
|
0：msgsnd()調(diào)用阻塞直到接收一條相應類型的消息為止 |
||||
|
函數(shù)返回值 |
成功：0 |
|||
|
出錯：-1 |
||||
表8.26列舉了msgctl()函數(shù)的語法要點。
表8.26 msgctl()函數(shù)語法要點
|
所需頭文件 |
#include <sys/types.h> #include <sys/ipc.h> #include <sys/shm.h> |
|
|
函數(shù)原型 |
int msgctl (int msgqid, int cmd, struct msqid_ds *buf ) |
|
|
函數(shù)傳入值 |
msqid：消息隊列的隊列ID |
|
|
cmd： 命令參數(shù) |
IPC_STAT：讀取消息隊列的數(shù)據(jù)結構msqid_ds，并將其存儲在buf指定的地址中 |
|
|
IPC_SET：設置消息隊列的數(shù)據(jù)結構msqid_ds中的ipc_perm域（IPC操作權限描述結構）值。這個值取自buf參數(shù) |
||
|
IPC_RMID：從系統(tǒng)內(nèi)核中刪除消息隊列 |
||
|
buf：描述消息隊列的msgqid_ds結構類型變量 |
||
|
函數(shù)返回值 |
成功：0 |
|
|
出錯：-1 |
||
3．使用實例
這個實例體現(xiàn)了如何使用消息隊列進行兩個進程（發(fā)送端和接收端）之間的通信，包括消息隊列的創(chuàng)建、消息發(fā)送與讀取、消息隊列的撤消和刪除等多種操作。
消息發(fā)送端進程和消息接收端進程之間不需要額外實現(xiàn)進程之間的同步。在該實例中，發(fā)送端發(fā)送的消息類型設置為該進程的進程號（可以取其他值），因此接收端根據(jù)消息類型確定消息發(fā)送者的進程號。注意這里使用了函數(shù)fotk()，它可以根據(jù)不同的路徑和關鍵字產(chǎn)生標準的key。以下是消息隊列發(fā)送端的代碼：
/* msgsnd.c */
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#define BUFFER_SIZE 512
struct message
{
long msg_type;
char msg_text[BUFFER_SIZE];
};
int main()
{
int qid;
key_t key;
struct message msg;
/*根據(jù)不同的路徑和關鍵字產(chǎn)生標準的key*/
if ((key = ftok(".", 'a')) == -1)
{
perror("ftok");
exit(1);
}
/*創(chuàng)建消息隊列*/
if ((qid = msgget(key, IPC_CREAT|0666)) == -1)
{
perror("msgget");
exit(1);
}
printf("Open queue %dn",qid);
while(1)
{
printf("Enter some message to the queue:");
if ((fgets(msg.msg_text, BUFFER_SIZE, stdin)) == NULL)
{
puts("no message");
exit(1);
}
msg.msg_type = getpid();
/*添加消息到消息隊列*/
if ((msgsnd(qid, &msg, strlen(msg.msg_text), 0)) < 0)
{
perror("message posted");
exit(1);
}
if (strncmp(msg.msg_text, "quit", 4) == 0)
{
break;
}
}
exit(0);
}
以下是消息隊列接收端的代碼：
/* msgrcv.c */
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#define BUFFER_SIZE 512
struct message
{
long msg_type;
char msg_text[BUFFER_SIZE];
};
int main()
{
int qid;
key_t key;
struct message msg;
/*根據(jù)不同的路徑和關鍵字產(chǎn)生標準的key*/
if ((key = ftok(".", 'a')) == -1)
{
perror("ftok");
exit(1);
}
/*創(chuàng)建消息隊列*/
if ((qid = msgget(key, IPC_CREAT|0666)) == -1)
{
perror("msgget");
exit(1);
}
printf("Open queue %dn", qid);
do
{
/*讀取消息隊列*/
memset(msg.msg_text, 0, BUFFER_SIZE);
if (msgrcv(qid, (void*)&msg, BUFFER_SIZE, 0, 0) < 0)
{
perror("msgrcv");
exit(1);
}
printf("The message from process %d : %s", msg.msg_type, msg.msg_text);
} while(strncmp(msg.msg_text, "quit", 4));
/*從系統(tǒng)內(nèi)核中移走消息隊列 */
if ((msgctl(qid, IPC_RMID, NULL)) < 0)
{
perror("msgctl");
exit(1);
}
exit(0);
}
以下是程序的運行結果。輸入“quit”則兩個進程都將結束。
$ ./msgsnd
Open queue 327680
Enter some message to the queue:first message
Enter some message to the queue:second message
Enter some message to the queue:quit
$ ./msgrcv
Open queue 327680
The message from process 6072 : first message
The message from process 6072 : second message
The message from process 6072 : quit
