消息队列实现接收发送的例子

系统 1141 0

msg消息队列,实线不同进程之间的通信,主要依靠key来识别:

发送端

      
         1
      
       #include <stdio.h>


      
         2
      
       #include <stdlib.h>


      
         3
      
       #include <
      
        string
      
      .h>


      
         4
      
       #include <sys/types.h>


      
         5
      
       #include <sys/msg.h>


      
         6
      
       #include <unistd.h>


      
         7
      
       #include <time.h>


      
         8
      
       #include <sys/ipc.h>


      
         9
      
      
        struct
      
      
         msgmbuf{


      
      
        10
      
      
        int
      
      
         mtype;


      
      
        11
      
      
        char
      
       mtext[
      
        40
      
      
        ];


      
      
        12
      
      
        };


      
      
        13
      
      
        14
      
      
        int
      
      
         main()


      
      
        15
      
      
        {


      
      
        16
      
      
        int
      
       ret = -
      
        1
      
      
        ;


      
      
        17
      
      
        int
      
      
         msg_flags,msg_id;


      
      
        18
      
      
            key_t key;


      
      
        19
      
      
        struct
      
      
         msqid_ds msg_info;


      
      
        20
      
      
        struct
      
      
         msgmbuf msg_mbuf;


      
      
        21
      
           key = 
      
        1024
      
      
        ;


      
      
        22
      
           msg_flags =
      
         IPC_CREAT;


      
      
        23
      
      
        24
      
      
        while
      
      (
      
        1
      
      
        )


      
      
        25
      
      
            {


      
      
        26
      
               msg_id = msgget(key,msg_flags|
      
        0666
      
      
        );


      
      
        27
      
      
        if
      
      (-
      
        1
      
      ==
      
        msg_id)


      
      
        28
      
      
                {


      
      
        29
      
                   printf(
      
        "
      
      
        create message failed!\n
      
      
        "
      
      
        );


      
      
        30
      
      
        return
      
      
        0
      
      
        ;


      
      
        31
      
      
                }


      
      
        32
      
               printf(
      
        "
      
      
        Input message to send:
      
      
        "
      
      
        );


      
      
        33
      
               scanf(
      
        "
      
      
        %s
      
      
        "
      
      
        ,msg_mbuf.mtext);


      
      
        34
      
      
                getchar();


      
      
        35
      
               msg_mbuf.mtype = 
      
        10
      
      
        ;


      
      
        36
      
               ret = msgsnd(msg_id,&msg_mbuf,
      
        sizeof
      
      (
      
        struct
      
       msgmbuf),
      
        0
      
      
        );


      
      
        37
      
      
        if
      
      (-
      
        1
      
      ==
      
        ret)


      
      
        38
      
      
                {


      
      
        39
      
                   printf(
      
        "
      
      
        send message failed!\n
      
      
        "
      
      
        );


      
      
        40
      
      
                }


      
      
        41
      
      
        42
      
      
            }


      
      
        43
      
      
        return
      
      
        0
      
      
        ;


      
      
        44
      
       }
    

接收端:

      
         1
      
       #include <stdio.h>


      
         2
      
       #include <stdlib.h>


      
         3
      
       #include <
      
        string
      
      .h>


      
         4
      
       #include <sys/types.h>


      
         5
      
       #include <sys/msg.h>


      
         6
      
       #include <unistd.h>


      
         7
      
       #include <time.h>


      
         8
      
       #include <sys/ipc.h>


      
         9
      
      
        struct
      
      
         msgmbuf{


      
      
        10
      
      
        int
      
      
         mtype;


      
      
        11
      
      
        char
      
       mtext[
      
        40
      
      
        ];


      
      
        12
      
      
            };


      
      
        13
      
      
        14
      
      
        int
      
      
         main()


      
      
        15
      
      
        {


      
      
        16
      
      
        int
      
       ret = -
      
        1
      
      
        ;


      
      
        17
      
      
        int
      
      
         msg_flags,msg_id;


      
      
        18
      
      
            key_t key;


      
      
        19
      
      
        struct
      
      
         msgmbuf msg_mbuf;


      
      
        20
      
           key =
      
        1024
      
      
        ;


      
      
        21
      
           msg_flags =
      
         IPC_CREAT;


      
      
        22
      
      
        while
      
      (
      
        1
      
      
        )


      
      
        23
      
      
            {


      
      
        24
      
               msg_id = msgget(key,msg_flags|
      
        0666
      
      
        );


      
      
        25
      
      
        if
      
      (-
      
        1
      
      ==
      
        msg_id)


      
      
        26
      
      
                {


      
      
        27
      
                   printf(
      
        "
      
      
        create message failed!\n
      
      
        "
      
      
        );


      
      
        28
      
      
        return
      
      
        0
      
      
        ;


      
      
        29
      
      
                }


      
      
        30
      
      
        31
      
               ret = msgrcv(msg_id,&msg_mbuf,
      
        sizeof
      
      (
      
        struct
      
       msgmbuf),
      
        0
      
      ,
      
        0
      
      
        );


      
      
        32
      
      
        if
      
      (-
      
        1
      
      ==
      
        ret)


      
      
        33
      
      
                {


      
      
        34
      
                   printf(
      
        "
      
      
        receive message failed!\n
      
      
        "
      
      
        );


      
      
        35
      
      
                }


      
      
        36
      
      
        else
      
      
        37
      
      
                {


      
      
        38
      
                   printf(
      
        "
      
      
        receive message successful!message[%s]\n
      
      
        "
      
      
        ,msg_mbuf.mtext);


      
      
        39
      
      
                }


      
      
        40
      
      
        41
      
      
            }


      
      
        42
      
      
        return
      
      
        0
      
      
        ;


      
      
        43
      
       }
    

 

消息队列实现接收发送的例子


更多文章、技术交流、商务合作、联系博主

微信扫码或搜索:z360901061

微信扫一扫加我为好友

QQ号联系: 360901061

您的支持是博主写作最大的动力,如果您喜欢我的文章,感觉我的文章对您有帮助,请用微信扫描下面二维码支持博主2元、5元、10元、20元等您想捐的金额吧,狠狠点击下面给点支持吧,站长非常感激您!手机微信长按不能支付解决办法:请将微信支付二维码保存到相册,切换到微信,然后点击微信右上角扫一扫功能,选择支付二维码完成支付。

【本文对您有帮助就好】

您的支持是博主写作最大的动力,如果您喜欢我的文章,感觉我的文章对您有帮助,请用微信扫描上面二维码支持博主2元、5元、10元、自定义金额等您想捐的金额吧,站长会非常 感谢您的哦!!!

发表我的评论
最新评论 总共0条评论