zoukankan      html  css  js  c++  java
  • Linux _msg 消息队列 demo

    main1/msg_rcv.c

    #include <sys/types.h>
    #include <sys/ipc.h>
    #include <sys/msg.h>
    #include <sys/stat.h>
    #include <fcntl.h>
    #include <stdio.h>
    #include <stdlib.h>
    
    #define MSG_SIZE 80
    
    struct my_msg_st {
        long int msg_type;
        char msg[MSG_SIZE];
    };
    
    int main(void)
    {
        int msgid;
        int ret;
        struct my_msg_st msg;
    
        msgid = msgget((key_t)1235, 0666|IPC_CREAT);
        if (msgid == -1) {
            printf("msgget failed!
    ");
            exit(1);
        }
    
        msg.msg_type = 0;   
        ret = msgrcv(msgid, &msg, MSG_SIZE, 0, 0);
        if (ret == -1) {
            printf("msgrcv failed!
    ");
            exit(1);
        }
    
        printf("received: %s
    ", msg.msg);
    
        ret = msgctl(msgid, IPC_RMID, 0);
        if (ret == -1) {
            printf("msgctl(IPC_RMID) failed!
    ");
            exit(1);
        }
    
        return 0;
    }
    
    

    main1.msg_sed.c

    #include <sys/types.h>
    #include <sys/ipc.h>
    #include <sys/msg.h>
    #include <sys/stat.h>
    #include <fcntl.h>
    #include <stdio.h>
    #include <stdlib.h>
    #include <string.h>
    
    #define MSG_SIZE 80
    
    struct my_msg_st {
        long int msg_type;
        char msg[MSG_SIZE];
    };
    
    int main(void)
    {
        int msgid;
        int ret;
        struct my_msg_st msg;
    
        msgid = msgget((key_t)1235, 0666|IPC_CREAT);
        if (msgid == -1) {
            printf("msgget failed!
    ");
            exit(1);
        }
    
        msg.msg_type = 1;   
        strcpy(msg.msg, "Hello world!");
        ret = msgsnd(msgid, &msg, MSG_SIZE, 0);
        if (ret == -1) {
            printf("msgsnd failed!
    ");
            exit(1);
        }
    
        return 0;
    }
    
    

    main2/msg_rcv.c

    #include <sys/types.h>
    #include <sys/ipc.h>
    #include <sys/msg.h>
    #include <sys/stat.h>
    #include <fcntl.h>
    #include <stdio.h>
    #include <stdlib.h>
    
    #define MSG_SIZE 80
    
    struct my_msg_st {
        long int msg_type;
        char msg[MSG_SIZE];
    };
    
    int main(void)
    {
        int msgid;
        int ret;
        struct my_msg_st msg;
    
        msgid = msgget((key_t)1235, 0666|IPC_CREAT);
        if (msgid == -1) {
            printf("msgget failed!
    ");
            exit(1);
        }
    
        while(1) {
            msg.msg_type = 0;   
            ret = msgrcv(msgid, &msg, MSG_SIZE, 0, 0);
            if (ret == -1) {
                printf("msgrcv failed!
    ");
                exit(1);
            }
    
            printf("received: %s
    ", msg.msg);
    
            if (strncmp(msg.msg, "exit", 4) == 0) {
                break;
            }
        }
    
        ret = msgctl(msgid, IPC_RMID, 0);
        if (ret == -1) {
            printf("msgctl(IPC_RMID) failed!
    ");
            exit(1);
        }
    
        return 0;
    }
    
    

    main2/msg_snd.c

    #include <sys/types.h>
    #include <sys/ipc.h>
    #include <sys/msg.h>
    #include <sys/stat.h>
    #include <fcntl.h>
    #include <stdio.h>
    #include <stdlib.h>
    #include <string.h>
    
    #define MSG_SIZE 80
    
    struct my_msg_st {
        long int msg_type;
        char msg[MSG_SIZE];
    };
    
    int main(void)
    {
        int msgid;
        int ret;
        struct my_msg_st msg;
    
        msgid = msgget((key_t)1235, 0666|IPC_CREAT);
        if (msgid == -1) {
            printf("msgget failed!
    ");
            exit(1);
        }
    
        while(1) {
            fgets(msg.msg, sizeof(msg.msg), stdin);
    
            msg.msg_type = 1;   
            ret = msgsnd(msgid, &msg, MSG_SIZE, 0);
            if (ret == -1) {
                printf("msgsnd failed!
    ");
                exit(1);
            }
    
            if (strncmp(msg.msg, "exit", 4) == 0) {
                break;
            }
        }
    
        return 0;
    }
    
  • 相关阅读:
    或得最新的采购单号并改变为定长
    javaScript学习之路(1)词法结构
    如何让IE下载时下载内容自动跳转到迅雷等下载软件中
    简单的数据库查询操作
    1.1软件工程概述之软件危机
    SQL基础(巧记范式)
    给程序员的五点建议--如何成为编程高手并以此创业
    License控制解决方案
    MVC+三层+ASP.NET简单登录验证
    我曾七次鄙视自己的灵魂
  • 原文地址:https://www.cnblogs.com/Sico2Sico/p/5384208.html
Copyright © 2011-2022 走看看