使用訊號和管道傳遞訊息存在一定的限制：訊號傳遞的訊息有限，管道雖然可以傳輸一定量的資訊，但是隻能傳遞無格式的位元組流。3種新的程序間通訊（IPC）機制---訊息佇列、訊號量、共享記憶體，可以解決這些問題。這些機制最早出現在UNIX中，被編入POSIC:XSI中，Linux支援POSIX標準。 （1）關於IPC資源 訊息佇列、訊號量、共享記憶體都是IPC資源，這些資源在使用之前都需要先建立。Linux核心中，IPC資源都可以使用一個非負整數——IPC識別符號（訊息佇列識別符號、訊號量識別符號、共享記憶體識別符號）來進行標識。 在建立一個IPC識別符號之前，需要指定一個關鍵字key，可以呼叫函式ftok（）獲得。 int ftok(const char *pathname, int prj_id);//失敗返回-1 （2）關於訊息佇列 訊息佇列實際上就是一個連結串列（工作就是倒騰連結串列的，從來沒倒騰過這種，o(∩_∩)o...），而訊息就是連結串列中具有特定格式和優先順序的記錄，程序可以根據一定規則在訊息連結串列中新增訊息，需要訊息的程序則可以從訊息佇列中獲得所需的資訊。 訊息寫入訊息佇列時，系統會將訊息加入到訊息佇列維護的訊息連結串列中。如圖所示： msg_next------| msg_type       |------>msg_next------| msg_ts                       msg_type       |------>msg_next msg_spot|                  msg_ts                   | -訊息      msg_spot---訊息 msg_next:下一個訊息指標 msg_type:訊息型別，使用者自己定義 msg_ts：訊息長度 msg_spot:訊息內容 （3）訊息佇列相關函式 1、建立訊息佇列：int msgget(key_t key,int msgflag) 該函式用於建立或者訪問訊息佇列，獲得訊息佇列識別符號符。key就是上面用ftok（）獲得的IPC關鍵字。 2、獲得/修改訊息佇列屬性：int msgctl(int msqid,int cmd,struct msqid_ds *buf); msqid為要修改、讀取屬性的訊息佇列識別符號， 引數cmd如果為IPC_STAT時表示讀取核心中記錄訊息佇列資訊的資料結構msqid_ds, 返回的訊息佇列屬性存放在buf指向的結構體中。 3、訊息傳送：int msgsnd(int msqid,const void *msgp,size_t msgsz,int msgflg); msqid：要將訊息傳送的訊息佇列識別符號 msgp:指標指向訊息結構體msgbuf typedef struct {     long msgtype;  //訊息型別，任何大於0的整數，自定義     char mtext[？]; //訊息文字，文字大小由msgsnd中的msgsz決定  }msgbuf; msgsz:訊息位元組數 msgflg：可以為0（忽略該引數）或者IPC_NOWAIT(如果訊息佇列沒有足夠空間，如果設定了IPC_NOWAIT,立刻返回；否則函式阻塞，直到等到空間)。 4、訊息接收：int msgrcv(int msqid,void *msgp,size_t msgsz,long msgtyp,int msgflg); 從msqid代表的訊息佇列取出訊息，存放在msgp指向的緩衝區，緩衝結構定義和傳送時使用的msgbuf類似； msgsz:訊息內容長度，msgbuf結構體中mtext的長度； msgtpye：請求讀取的訊息型別 msgflg:引數可以取0，也可以取IPC_NOWAIT等。如果為IPC_NOWAIT時，訊息佇列如果為空，則函式阻塞，直到有訊息可以取。 （4）例項： 【建立訊息佇列、發訊息】 程式碼儲存systemcall2.c #include <stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <string.h> #define BUF_SIZE 100 typedef struct {
 long mtype;
 char mtext[BUF_SIZE];
}msg_info;   //用於訊息傳送 //建立訊息佇列 int creat_msg_queue()
{
 int proj_id = 1;
 int msg_id;
 key_t key;
 
 key = ftok("/home/gaolu",proj_id);  //建立IPC識別符號，需要先獲得一個key
 if(-1 == key)
 {
  perror("Can't generate the IPC key.\n");
  return -1;
 }  msg_id = msgget(key,IPC_CREAT|0660); //如果msg_id不存在，則建立，否則，返回已經存在的佇列識別符號
 if(-1 == msg_id)
 {
  printf("Can't creat message queue resource.\n");
  return -1;
 }
 
 return msg_id;
} //向佇列發訊息 int send_msg(int msg_id,char* message)
{
 int result;
 msg_info MsgInfo;
 
 MsgInfo.mtype = 10;  //隨意定義，大於0 && 整數 即可
 strcpy(MsgInfo.mtext,message);  result = msgsnd(msg_id,&MsgInfo,strlen(message),0);
 if(-1 == result)
 {
  perror("Fail to send message to message queue.\n");
 }
 return result;
} //顯示訊息資訊|驗證訊息是否發入佇列 int show_msg_queue_stat(int msg_id)
{
 struct msqid_ds MsgQueueInfo;
 int result;
 
 result = msgctl(msg_id,IPC_STAT,&MsgQueueInfo); //獲得訊息佇列資訊（所有者，許可權，訊息數……）
 if(-1 == result)
 {
  perror("Can't get status of message queue.\n");
  return -1;
 } 
 printf("======================Message Queue Info=======================\n");
 printf("Effective user id: %d.\n",MsgQueueInfo.msg_perm.uid);
 printf("Effective user group id: %d.\n",MsgQueueInfo.msg_perm.gid);
 printf("Current numbers of bytes in message queue(non-standard): %ld.\n",MsgQueueInfo.__msg_cbytes);
 printf("Current numbers of message in message queue: %ld.\n",MsgQueueInfo.msg_qnum);
 printf("===============================================================\n");  return 0;
} int main(void)
{
 int msg_id; 
 int result;
 msg_id = creat_msg_queue();
 send_msg(msg_id,"Test data..............");
 show_msg_queue_stat(msg_id);
 return 0; }
【取訊息】 程式碼儲存msgrcv.c #include <stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <string.h> #define BUF_SIZE 100 typedef struct {
 long mtype;
 char mtext[BUF_SIZE];
}msg_info; //讀取訊息佇列中指定型別的訊息，將訊息內容儲存在msg指向的地址空間 int rcv_msg(int msg_id,int msg_type,char* msg)
{
 int result;
 msg_info MsgInfo;  result = msgrcv(msg_id,&MsgInfo,BUF_SIZE,msg_type,0);
 if(-1 == result)
 {
  perror("Can't receive message from message queue.\n");
  return result;
 }
 strcpy(msg,MsgInfo.mtext);
 return result;
}
int main(int argc,char* argv[])
{
 int result;
 char message[BUF_SIZE];
 int msg_type;
 int msg_id;
 if(3 != argc)
 {
  printf("Useage:%s msgid msg_type.\n",argv[0]);
  return -1;
 }
 msg_type = atoi(argv[2]);
 msg_id = atoi(argv[1]); //獲得指定型別訊息並顯示訊息內容
 result = rcv_msg(msg_id,msg_type,message);
 if(-1 == result)
 {
  perror("Fail to receive message.\n");
 }
 else
 {
  printf("Message: %s.\n",message);
 }
 return result; 
}
【執行結果】

[email protected]:~$
[email protected]:~$
[email protected]:~$ gcc -o msgq systemcall2.c
[email protected]:~$ gcc -o rcv msgrcv.c
[email protected]:~$ ./msgq
======================Message Queue Info=======================
Effective user id: 1000.
Effective user group id: 1000.
Current numbers of bytes in message queue(non-standard): 23.
Current numbers of message in message queue: 1.
================================================================

[email protected]:~$
[email protected]:~$ ipcs -q  //IPC命令 引數q表示訊息佇列(m:共享記憶體，s:訊號量) ------ Message Queues --------
key        msqid      owner      perms      used-bytes   messages   
0x01018b15 0          gaolu      777        23           1