Linux进程通信:消息队列

目录

1.消息队列的原理：

2.消息队列的接口：

        （1）创建消息队列

        （2）向消息队列发送消息

        （3）接收消息

         （4）操作消息队列的接口

---

1.消息队列的原理：

消息队列（messagequeue）以链表作为基础，实现消息队列，由操作系统维护该链表

操作系统中，使用消息队列描述符（qid）来区分每个消息队列（qid是唯一的）

进程在消息队列的末尾增加消息，需要信息的进程按照所需的类型在队列中取消息

2.消息队列的接口：

（1）创建消息队列

        int megget(key_t,int msgflg)

参数： 

key：消息队列的标识符

megflg：创建的标志，如IPC_CREAT

IPC_CREAT :如果不存在就创建，按位或上一个权限

返回值：

成功：返回队列ID

失败：返回-1，并设置erron 

2）向消息队列发送消息      

int msgsnd（int msqid, const void *msgp, size_t msgsz, int msgflg）

参数：

msqid：消息队列的ID

msgp：指向msgbuf的指针，用来发送指定的消息，在写msgsnd、msgrev函数时，要提前定义该结构体，主要是指定mtext大小。

      msgp指向的msgbuf为发送的结构体，操作系统指定了函数发送消息的格式，只定义了一部分，mtext可以由程序员自己改变。

 msgsz：要发送的消息的长度，该参数的值不是表示msgp指向的msgbuf结构体的大小，而是该结构体中mtext的大小。

msgflg：创建标记，如果指定了IPC_NOWAIT，失败会立即返回。       

         0：阻塞发送

         IPC_NOWAIT：非阻塞发送

返回值：

        0：成功

        -1：失败，并设置errno

(3）接收消息

ssize_t msgrcv(int msqid , void *msgp,size_t msgsz,long msgtyp,int msgflg)

参数：

msgid：消息队列的ID

msgp：指向msgbuf的指针，用来接收消息

**struct  msgbuf{……}为输出型参数

msgsz：需要接受的消息的长度，注意msgsz是由msgp所指向的结构体的成员 mtext的最大大小决定的（byte）

msgtyp有三种形式：

        1.msgtyp=0：读取队列的第一个消息

        2.msgtyp>0：读取队列类型为msgtyp的第一条消息，除非在msgflg中指定了 MSG_EXCEPT，否则将读取类型不等于 megtyp的队列中的第一条消息，

        3.msgtyp<0:读取队列中最小类型小于或等于msgtyp绝对值的第一条消息

msgflg：创建标记，若指定了IPC_NOWAIT，获取失败后就直接返回 

     （4）操作消息队列的接口

int msgctl(int msqid , int cmd, struct msqid_ds *buf)

参数：

        msqid：消息队列的ID

        cmd：控制命令：

                IPC_RMID,删除命令

                IPC_STAT,获取命令

        buf：存储队列的相关信息的buf

返回值：

        成功：根据不同的cmd有不同的返回值

        失败： 返回-1，并设置errno

5.代码实现：

写端发送消息，读端从队列读取

mesgrcv:

1.  
   #include<stdio.h>
2.  
   #include<unistd.h>
3.  
   #include<sys/msg.h>
4.  
   #include<sys/ipc.h>
5.  
    
6.  
   struct msgbuf
7.  
   {
8.  
   long mtype;
9.  
   char mtext[1024];
10.  
     
11.  
    };
12.  
     
13.  
     
14.  
    int main()
15.  
    {
16.  
    int msg_id=msgget(0x06060606,IPC_CREAT|0664);
17.  
    if(msg_id<0 )
18.  
    {
19.  
    perror("msgget \n" );
20.  
    return 0;
21.  
    }
22.  
     
23.  
    printf("msggqueued id is %d\n",msg_id );
24.  
    struct msgbuf mq;
25.  
    msgrcv(msg_id,&mq,sizeof(mq.mtext),1,0);
26.  
    printf("接受的消息：%s \n",mq.mtext);
27.  
     
28.  
    return 0;
29.  
    }

msgsnd:

1.  
   #include<stdio.h>
2.  
   #include<unistd.h>
3.  
   #include<sys/msg.h>
4.  
    
5.  
   struct msgbuf
6.  
   {
7.  
   long mtype; //message type
8.  
   char mtext[512]; //message data
9.  
    
10.  
    };
11.  
     
12.  
    int main()
13.  
    {
14.  
    int msg_qid=msgget(0x06060606,IPC_CREAT|0664);
15.  
    if(msg_qid<0 )
16.  
    {
17.  
    perror("msgget\n");
18.  
    return 0;
19.  
    }
20.  
     
21.  
    struct msgbuf mq;
22.  
     
23.  
    int i;
24.  
    for(i=0;i<10;i )
25.  
    {
26.  
    mq.mtype=i 1;
27.  
    sprintf(mq.mtext,"%s,%d ","xxxxxxxxxx ",i 1);
28.  
    msgsnd(msg_qid,&mq,sizeof(mq.mtext),0);
29.  
    }
30.  
     
31.  
    return 0;
32.  
    }
33.  
     

查看系统中的message queue：

 

 

当多次读出时，由于消息已经出了队列，所以不能再读出。

这篇好文章是转载于：学新通技术网