訊息佇列是訊息的連結串列，存放在核心中並有訊息佇列標示符標示。

　　msgget用於建立一個新佇列或開啟一個現存的佇列。msgsnd將新訊息加入到訊息佇列中；每個訊息包括一個long型的type；和訊息快取；msgrcv用於從佇列中取出訊息；取訊息很智慧，不一定先進先出

　　①msgget，建立一個新佇列或開啟一個現有佇列

　　#include <sys/msg.h>

　　int msgget ( key_t key, int flag )；

　　//成功返回訊息佇列ID；錯誤返回-1

　　②msgsnd: 傳送訊息

　　#include <sys/msg.h>

　　int msgsnd( int msgid, const void* ptr, size_t nbytes, int flag )

　　//成功返回0，錯誤返回-1

　　a:   flag可以指定為IPC_NOWAIT;  若訊息佇列已滿，則msgsnd立即出錯返回EABAIN；

　　若沒指定IPC_NOWAIT； msgsnd會阻塞，直到訊息佇列有空間為止

　　③msgrcv: 讀取訊息：

　　ssize_t msgrcv( int msgid, void* ptr, size_t nbytes, long type, int flag );

　　a. type == 0; 返回訊息佇列中第一個訊息，先進先出

　　b. type > 0    返回訊息佇列中型別為tpye的第一個訊息

　　c. type < 0    返回訊息佇列中型別 <=  |type| 的資料；若這種訊息有若干個，則取型別值最小的訊息

　　訊息佇列建立步驟：

　　#define   MSG_FILE "."

　　struct msgtype {

　　long mtype;

　　char buffer[BUFFER+1];

　　};

　　if((key=ftok(MSG_FILE,'a'))==-1)

　　{

　　fprintf(stderr,"Creat Key Error:%s\n", strerror(errno));

　　exit(1);

　　}

　　if((msgid=msgget(key, IPC_CREAT | 0666/*PERM*/))==-1)

　　{

　　fprintf(stderr,"Creat Message  Error:%s\n", strerror(errno));

　　exit(1);

　　}

　　msg.mtype = 1;

　　strncpy(msg.buffer, argv[1], BUFFER);

　　msgsnd(msgid, &msg, sizeof(struct msgtype), 0);

　　msgrcv(msgid, &msg, sizeof(struct msgtype), 1, 0);

　　示例程式碼：

　　#include <stdio.h>

　　#include <stdlib.h>

　　#include <string.h>

　　#include <errno.h>

　　#include <sys/types.h>

　　#include <sys/ipc.h>

　　#include <sys/msg.h>

　　#include <sys/stat.h>

　　#include <pthread.h>

　　#define   MSG_FILE "."

　　#define   BUFFER 255

　　#define   PERM S_IRUSR|S_IWUSR

　　#define IPCKEY 0x111

　　struct msgtype {

　　long mtype;

　　char buffer[BUFFER+1];

　　};

　　void* thr_test( void* arg ){

　　struct msgtype msg;

　　int msgid;

　　msgid =  *((int*)arg);

　　printf("msqid = %d  IPC_NOWAIT = %d\n", msgid, IPC_NOWAIT);

　　time_t tt = time(0)+8;

　　//while( time(0) <= tt )

　　//{

　　msgrcv(msgid, &msg, sizeof(struct msgtype), 1, 0);

　　fprintf(stderr,"Server Receive:%s\n", msg.buffer);

　　msg.mtype = 2;

　　msgsnd(msgid, &msg, sizeof(struct msgtype), 0);

　　//}

　　pthread_exit( (void*)2 );

　　}

　　int main(int argc, char **argv)

　　{

　　struct msgtype msg;

　　key_t key;

　　int msgid;

　　pthread_t tid;

　　if(argc != 2)

　　{

　　fprintf(stderr,"Usage:%s string\n", argv[0]);

　　exit(1);

　　}

　　/*

　　char path[256];

　　sprintf( path, "%s/", (char*)getenv("HOME") );

　　printf( "path is %s\n", path );

　　msgid=ftok( path, IPCKEY );

　　*/

　　if((key=ftok(MSG_FILE,'a'))==-1)

　　{

　　fprintf(stderr,"Creat Key Error:%s\n", strerror(errno));

　　exit(1);

　　}

　　if((msgid=msgget(key, IPC_CREAT | 0666/*PERM*/))==-1)

　　{

　　fprintf(stderr,"Creat Message  Error:%s\n", strerror(errno));

　　exit(1);

　　}

　　pthread_create( &tid, NULL, thr_test, &msgid );

　　fprintf(stderr,"msid is :%d\n", msgid);

　　msg.mtype = 1;

　　strncpy(msg.buffer, argv[1], BUFFER);

　　msgsnd(msgid, &msg, sizeof(struct msgtype), 0);

　　exit(0);

　　}