Linux進(jìn)程間通信(上)之管道、消息隊(duì)列實(shí)踐

3、消息隊(duì)列

消息隊(duì)列（也叫做報(bào)文隊(duì)列）提供了一個(gè)進(jìn)程向另一個(gè)進(jìn)程發(fā)送一個(gè)數(shù)據(jù)塊的方法。每個(gè)數(shù)據(jù)塊都被認(rèn)為含有一個(gè)類(lèi)型，接收進(jìn)程可以獨(dú)立地接收含有不同類(lèi)型的數(shù)據(jù)結(jié)構(gòu)。我們可以通過(guò)發(fā)送消息來(lái)避免命名管道的同步和阻塞問(wèn)題。但是消息隊(duì)列與命名管道一樣，每個(gè)數(shù)據(jù)塊都有一個(gè)最大長(zhǎng)度的限制。

打開(kāi)或者創(chuàng)建消息隊(duì)列的內(nèi)核持續(xù)性要求每個(gè)消息隊(duì)列都在系統(tǒng)范圍內(nèi)對(duì)應(yīng)唯一的鍵值，所以，要獲得一個(gè)消息隊(duì)列的描述字，只需要提供該消息隊(duì)列的鍵值即可。

消息讀寫(xiě)操作非常簡(jiǎn)單，對(duì)于開(kāi)發(fā)人員來(lái)說(shuō)，每個(gè)消息都類(lèi)似如下的數(shù)據(jù)結(jié)構(gòu)：

struct msgbuf
{
 long mtype;
 char mtext[1];
};

3.1、msgget函數(shù)

該函數(shù)用來(lái)創(chuàng)建或者訪問(wèn)一個(gè)消息隊(duì)列。

int msgget(key_t key, int msgflg);

與其他的IPC機(jī)制一樣，程序必須提供一個(gè)鍵來(lái)命名某個(gè)特定的消息隊(duì)列。msgflg是一個(gè)權(quán)限標(biāo)志，表示消息隊(duì)列的訪問(wèn)權(quán)限，它與文件的訪問(wèn)權(quán)限一樣。msgflg可以與IPC_CREAT做或操作，表示當(dāng)key所命名的消息隊(duì)列不存在時(shí)創(chuàng)建一個(gè)消息隊(duì)列，如果key所命名的消息隊(duì)列存在時(shí)，IPC_CREAT標(biāo)志會(huì)被忽略，成功則返回一個(gè)以key命名的消息隊(duì)列的標(biāo)識(shí)符（非零整數(shù)），失敗時(shí)返回-1。

3.2、msgsnd函數(shù)

該函數(shù)用來(lái)向消息隊(duì)列發(fā)送一個(gè)消息。

int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);

將發(fā)送的消息存儲(chǔ)在msgp指向的msgbuf結(jié)構(gòu)中，消息大小由msgsz指定。對(duì)發(fā)送的消息來(lái)說(shuō)，有意義的msgflg標(biāo)準(zhǔn)為IPC_NOWAIT，指明在消息隊(duì)列沒(méi)有足夠的空間容納要發(fā)送的消息時(shí)，msgsnd是否等待。造成msgsnd()等待的條件有兩種：當(dāng)前消息的大小與當(dāng)前消息隊(duì)列中的字節(jié)數(shù)之和超過(guò)了消息隊(duì)列的總?cè)萘?；?dāng)前消息隊(duì)列的消息數(shù)不小于消息隊(duì)列的總?cè)萘浚藭r(shí)，雖然消息隊(duì)列中的消息數(shù)目并不多，但基本上都只有一個(gè)字節(jié)。調(diào)用成功的時(shí)候返回0，失敗返回-1.

3.3、msgrcv函數(shù)

該函數(shù)用來(lái)從一個(gè)消息隊(duì)列獲取消息。

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

msgrcv函數(shù)前面三個(gè)參數(shù)和msgsnd函數(shù)的三個(gè)參數(shù)一樣不做講解。msgtype可以實(shí)現(xiàn)一種簡(jiǎn)單的接收優(yōu)先級(jí)。如果msgtype為0，就獲取隊(duì)列中的第一個(gè)消息。如果它的值大于零，將獲取具有相同消息類(lèi)型的第一個(gè)信息。如果它小于零，就獲取類(lèi)型等于或小于msgtype的絕對(duì)值的第一個(gè)消息。msgflg用于控制當(dāng)隊(duì)列中沒(méi)有相應(yīng)類(lèi)型的消息可以接收時(shí)將發(fā)生的事情。當(dāng)調(diào)用成功時(shí)，該函數(shù)返回放到接收緩存區(qū)中的字節(jié)數(shù)，消息被復(fù)制到由msg_ptr指向的用戶(hù)分配的緩存區(qū)中，然后刪除消息隊(duì)列中對(duì)應(yīng)的消息；失敗則返回-1.

3.4、msgctl函數(shù)

該函數(shù)用來(lái)控制消息隊(duì)列。

int msgctl(int msgid, int command, struct msgid_ds *buf);

該系統(tǒng)調(diào)用對(duì)由msqid標(biāo)識(shí)的消息隊(duì)列執(zhí)行cmd操作，共有三種cmd操作：

• IPC_STAT：把msgid_ds結(jié)構(gòu)中的數(shù)據(jù)設(shè)置為消息隊(duì)列的當(dāng)前關(guān)聯(lián)值，即用消息隊(duì)列的當(dāng)前關(guān)聯(lián)值覆蓋msgid_ds的值。
• IPC_SET：如果進(jìn)程有足夠的權(quán)限，就把消息列隊(duì)的當(dāng)前關(guān)聯(lián)值設(shè)置為msgid_ds結(jié)構(gòu)中給出的值。
• IPC_RMID：刪除消息隊(duì)列。buf是指向msgid_ds結(jié)構(gòu)的指針，它指向消息隊(duì)列模式和訪問(wèn)權(quán)限的結(jié)構(gòu)。成功返回0，否則返回-1。

通過(guò)上面的函數(shù)我們清楚如何去創(chuàng)建一個(gè)消息隊(duì)列那我們簡(jiǎn)單的來(lái)看一個(gè)案例。

(1)創(chuàng)建一條消息隊(duì)列msg_get.c

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

int main(void)
{
 int  msgid ; 
 //創(chuàng)建消息隊(duì)列，注意，創(chuàng)建后面要有IPC_CREAT標(biāo)志
 msgid = msgget(0x123456 , IPC_CREAT | 0777);
 if(msgid < 0)
 {
  perror("msgget fail");
  return -1 ; 
 }
 printf("success ... ! \n");
 return 0  ;
}

運(yùn)行結(jié)果：

那消息隊(duì)列呢？怎么查看？使用ipcs –q命令可以查看到剛剛我們創(chuàng)建的消息隊(duì)列0x123456。

(2)向消息隊(duì)列發(fā)送消息 msgsend.c

#include <stdio.h>
#include <string.h>
#include <sys/ipc.h>
#include <sys/msg.h>

int main(void)
{
    int msgid ;
    msgid = msgget(0x123456 , 0);
    if(msgid == -1)
    {
        perror("create msg queue fail");
        return -1 ;
    }
    printf("open msg success ... \n");
    int ret ;
    char *p = "hello world" ;
   //發(fā)送hello world到消息隊(duì)列0x123456
   //在這里可以直接發(fā)送
    ret = msgsnd(msgid , p , strlen(p) , 0);
    if(ret == -1)
    {
        perror("send msgid fail");
        return -2 ;
    }
    return 0 ;
}

運(yùn)行結(jié)果：

使用ipcs –p命令查看：

(3)獲取消息隊(duì)列中的信息 msgrecv.c 在上面msgsend.c的基礎(chǔ)上，這個(gè)例程將上面發(fā)送到消息隊(duì)列的信息讀取回來(lái)。

#include <stdio.h>
#include <string.h>
#include <sys/ipc.h>
#include <sys/msg.h>

int main(void)
{
    int msgid ;
    msgid = msgget(0x123456 , 0);
    if(msgid == -1)
    {
        perror("create msg queue fail");
        return -1 ;
    }
    printf("open msg success ... \n");
    int ret ;
    char buffer[1024] = {0};
    //接收消息隊(duì)列中的信息
    ret = msgrcv(msgid , buffer , 11 , 0 , 0);
    if(ret == -1)
    {
        perror("recv msgid fail");
        return -2 ;
    }
    printf("ret: %d  buffer:%s \n" , ret , buffer);
    return 0 ;
}

運(yùn)行結(jié)果，如圖所示:

那么，如何刪除一個(gè)消息隊(duì)列呢？先用ipcs –q查看消息隊(duì)列，如圖所示：

有兩種方法：

• 1、使用命令ipcrm –q msqid 刪除消息隊(duì)列，如圖所示

• 2、使用msgctl函數(shù)，寫(xiě)IPC_RMID標(biāo)志刪除消息隊(duì)列

(4)刪除消息隊(duì)列 msgrm.c

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

int main(void)
{
    int  msgid ;
    msgid = msgget(0x123456 , 0);
    if(msgid < 0)
    {
        perror("msgget fail");
        return -1 ;
    }
    printf("success ... ! msgid:%d \n" , msgid);
    //寫(xiě)IPC_RMID標(biāo)志
    if(msgctl(msgid , IPC_RMID , NULL) == 0)
    {
        printf("remove success ... \n");
    }
    return 0  ;
}

運(yùn)行結(jié)果，如圖所示：

使用系統(tǒng)提供的API的方式，可以將消息隊(duì)列刪除。消息隊(duì)列克服了信號(hào)傳遞信息少、管道只能承載無(wú)格式字節(jié)流以及緩沖區(qū)大小受限等缺點(diǎn)，相對(duì)于管道通信有很大的改觀，而且消息隊(duì)列對(duì)數(shù)據(jù)的順序處理也是非常有條理性的不會(huì)產(chǎn)生混雜性。