學習API當然用man嘍。

API：

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>

int msgget(key_t key, int msgflg);
get a message queue identifier
key -- 關鍵字
msgflg -- 標誌 IPC_CREAT 或 IPC_EXCL
一般使用msgget建立訊息佇列，key自定義一個，如果系統已經使用了該key值，那有可能就建立失敗了。
還有建立完許可權的問題，這個還沒有深入研究。
return -- -1 if error and errno indicating the error.

int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);
傳送訊息
msgp -- 指向訊息的結構，例如訊息的結構如下
struct msgbuf {
  long mtype;       /* message type, must be > 0 */
  char mtext[64];    /* message data */
};
其中 mtest 陣列的大小就是 msgsz 的值。 
mtype -- 訊息型別，在接收時需要這個值用來區分各個訊息。注意，這個取值是有講究的。The mtype field must have a strictly positive integer value. 正數可以，負數就不行！！！
msgflg -- 標誌 IPC_NOWAIT MSG_EXCEPT MSG_NOERROR 等，
return -- -1 if error and errno indicating the error.

ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg);
接收訊息
知道傳送的話，接收就容易了。


int msgctl (int msqid, int cmd, struct msqid_ds *buf)
訊息佇列屬性控制
msqid：訊息佇列的識別符號。
cmd：執行的控制命令，即要執行的操作。（包括以下選項：
IPC_STAT：讀取訊息佇列屬性。取得此佇列的msqid_ds 結構，並將其存放在buf指向的結構中。
IPC_SET ：設定訊息佇列屬性。
IPC_RMID：刪除訊息佇列。
IPC_INFO：讀取訊息佇列基本情況。此命令等同於 ipcs 命令。
這 4 條命令（IPC_STAT、IPC_SET、IPC_INFO 和 IPC_RMID）也可用於訊號量和共享儲存。）

buf：臨時的 msqid_ds 結構體型別的變數。用於儲存讀取的訊息佇列屬性或需要修改的訊息佇列屬性。

舉例：msgctl(qid, IPC_RMID, NULL) //刪除訊息佇列

看了API，就可以寫兩個程序跑一下了。

process1

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <string.h>
#include <stdio.h>
#include <stdlib.h>
#include <errno.h>

#define MY_MSG_TYPE 0xaabb
struct msg {
    long msg_types;
    char msg_buf[3];
};

static key_t mykey = 0x1234;

static char buf[5][3] =
{
    { 'a', 'b', 'c'},
    { 'd', 'e', 'r'},
    { 'g', 'h', 'i'},
    { 'j', 'k', 'l'},
    { 'm', 'n', 'o'}
};

int main()
{
    struct msg pmsg;
    int msgid;
    int i;
    int ret;

    printf("process send start\n");
    i = 0;
    msgid = msgget(mykey, IPC_CREAT | 00666);
    if (msgid < 0) {
        printf("creat msg failed\n");
        return 0;
    }

    pmsg.msg_types = MY_MSG_TYPE;

    while (1) {
        memcpy(&pmsg.msg_buf, &(buf[i][0]), 3);

        printf("msgid %d pmsg.msg_buf %c %c %c\n", msgid, pmsg.msg_buf[0], pmsg.msg_buf[1], pmsg.msg_buf[2]);
        ret = msgsnd(msgid, &pmsg, 3, IPC_NOWAIT);
        if (ret < 0) {
            switch (errno)
			{
				case E2BIG:	printf("<xmpp>1111訊息文字長度大於msgsz，並且msgflg中沒有指定MSG_NOERROR\n");	break;
				case EACCES: printf("<xmpp>2222呼叫程序沒有讀權能，同時沒具有CAP_IPC_OWNER權能\n"); break;
				case EAGAIN: printf("<xmpp>3333訊息佇列為空，並且msgflg中沒有指定IPC_NOWAIT\n"); break;
				case EFAULT: printf("<xmpp>444msgp指向的空間不可訪問\n"); break;
				case EIDRM: printf("<xmpp>555當程序睡眠等待接收訊息時，訊息佇列已被刪除\n"); break;
				case EINTR: printf("<xmpp>666當程序睡眠等待接收訊息時，被訊號中斷\n"); break;
				case EINVAL: printf("<xmpp>777 inval\n"); break;
				case ENOMSG: printf("<xmpp>888msgflg中指定了IPC_NOWAIT，同時所請求型別的訊息不存在\n"); break;
				default: printf("<xmpp>999其他錯誤\n"); break;
			}
            break;
        }
        i++;
        if (i >= 5) {
            i = 0;
        }

        sleep(3);
    }

    msgctl(msgid, IPC_RMID, NULL);

    return 0;
}
 

process2

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <string.h>
#include <stdio.h>
#include <stdlib.h>

#define MY_MSG_TYPE 0xaabbccdd

struct msg {
    long msg_types;
    char msg_buf[3];
};

static key_t mykey = 0x1234;

int main()
{
    struct msg pmsg;
    int msgid;
    int i;
    ssize_t ret;

    printf("process receive start\n");

    printf("aaaaaaaaaaaaaaaaaa\n");

    i = 0;
    msgid = msgget(mykey, IPC_CREAT | 00666);
    if (msgid < 0) {
        printf("GET MSG FAILE\n");
        return 0;
    }
    printf("!!!!\n");
    while (1) {
        ret = msgrcv(msgid, &pmsg, 3, MY_MSG_TYPE, 0);
        if (ret < 0) {
            printf("receive error!!!\n");

        } else {
            printf("get message ret = %d %c %c %c\n", ret, pmsg.msg_buf[0], pmsg.msg_buf[1], pmsg.msg_buf[2]);
        }

        sleep(1);
    }

    msgctl(msgid, IPC_RMID, NULL);

    return 0;
}

把 process2 放在後臺執行，再執行 process1。

就會有列印了

.out  main.c
[[email protected] p1]$ ./a.out 
process send start
msgid 884736 pmsg.msg_buf a b c
get message ret = 3 a b c

成功。