Unix Message Queue #

Sample #

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>

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

#include <errno.h>

typedef struct
{
    long msg_type;
    char message[BUFSIZ];
}MSG;

MSG msg;

int receiver(key_t msgkey)
{
    int msgid, done = 1;

    msgid = msgget(msgkey, 0666 | IPC_CREAT);

    if (msgid == -1){
        fprintf(stderr, "msgget failed\n");
        exit(EXIT_FAILURE);
    }

    while (done){
        if (msgrcv(msgid, (void *)&msg, BUFSIZ, 0, IPC_NOWAIT) == -1){
            if (errno == ENOMSG) {
                fprintf(stderr, "더 이상 메시지가 없습니다.\n");
            } else {
                fprintf(stderr, "msgrcv 실패\n");
            }
            exit(EXIT_FAILURE);
        }
        printf("받은 메시지: %s", msg.message);

        if (strncmp(msg.message, ".", 1) == 0){
            done = 0;
        }
    }

    if (msgctl(msgid, IPC_RMID, 0) == -1){
        fprintf(stderr, "msgctl(IPC_RMID) failed\n");
        exit(EXIT_FAILURE);
    }
    printf("\n메시지 수신을 종료합니다.\n\n");
    exit(EXIT_SUCCESS);
}

int sender(key_t msgkey)
{
    int msgid, done = 1;
    char buffer[BUFSIZ];

    msgid =msgget(msgkey, 0666 | IPC_CREAT);

    if (msgid == -1){
        fprintf(stderr, "msgget failed\n");
        exit(EXIT_FAILURE);
    }

    printf("전송할 메시지를 입력하세요.\n");
    printf("메시지 입력 종료는 첫칸에 '.'를 입력하세요.\n\n");

    while (done) {
        printf("전송할 메시지: ");
        fgets(buffer, BUFSIZ, stdin);
        msg.msg_type = 1;
        strcpy(msg.message, buffer);

        if (msgsnd(msgid, (void *)&msg, BUFSIZ, 0) == -1){
            fprintf(stderr, "msgsnd failed\n");
            exit(EXIT_FAILURE);
        }

        if (strncmp(buffer, ".", 1) == 0){
            done = 0;
        }
    }
    printf("\n메시지 전송을 종료합니다.\n\n");
    exit(EXIT_SUCCESS);
}

int main(int argc, char *argv[])
{
    key_t key;

    key = ftok(".", 'M');
    if (argc > 1) receiver(key);
    else    sender(key);
}

출처 : http://blog.naver.com/eggkorea92/40003492319