【Linux编程】XSI IPC

• 消息队列
• 信号量
• 共享存储器

• msgget：创建一个新队列或打开一个现存的队列。
• msgsnd：将消息添加到队列尾端。
• msgrcv：从队列中取消息。

struct mest_t {
    long type;          // 消息类型
    char text[512];     // 消息内容
};

#include <stdio.h>
#include <sys/msg.h>
#include <sys/types.h>
#include <string.h>
#include <errno.h>
 
struct mest_t {
    long type;
    char text[512];
};
 
int main(void)
{
    pid_t pid;
    int mq_id;
    struct mest_t msg;
 
    /* IPC_PRIVATE用于创建一个新队列
     * 设置了IPC_EXCL并且设置了IPC_CREAT，当文件存在时返回错误
     */
    mq_id = msgget(IPC_PRIVATE, IPC_CREAT | IPC_EXCL);
    if (mq_id == EEXIST)
        return -1;  /* 返回EEXIST表示IPC已存在 */
 
    if ((pid = fork()) < 0)
        return -1;
    else if (pid == 0)
    {
        /* 子进程 */
        msg.type = 123;                     /* 消息类型 */
        strcpy(msg.text, "Hello world!");   /* 消息内容 */
 
        /* 非阻塞方式将消息放入消息队列
         * 队列已满则返回EAGAIN
         */
        while (msgsnd(mq_id, (long *)&msg, 512, IPC_NOWAIT) == EAGAIN)
            sleep(1);
    }
    else
    {
        /* 非阻塞方式从队列中取消息
         * 如果没有指定类型的消息，函数返回-1，errno设置为ENOMSG
         */
        while (msgrcv(mq_id, (long *)&msg, 512, 123, IPC_NOWAIT) == -1)
        {
            if (errno == ENOMSG)
            {
                printf("There is no this type message!\n");
                sleep(1);
            }
        }
 
        printf("%s\n", msg.text);
    }
  
    return 0;
}