Linux中怎么實(shí)現(xiàn)消息隊(duì)列編程

Linux中怎么實(shí)現(xiàn)消息隊(duì)列編程，很多新手對(duì)此不是很清楚，為了幫助大家解決這個(gè)難題，下面小編將為大家詳細(xì)講解，有這方面需求的人可以來學(xué)習(xí)下，希望你能有所收獲。

一、概念

消息隊(duì)列就是一個(gè)消息的鏈表?？梢园严⒖醋饕粋€(gè)記錄，具有特定的格式以及特定的優(yōu)先級(jí)。對(duì)消息隊(duì)列有寫權(quán)限的進(jìn)程可以向中按照一定的規(guī)則添加新消息；有讀權(quán)限的進(jìn)程則可以讀走消息。讀走就沒有了。消息隊(duì)列是隨內(nèi)核持續(xù)的。 只有內(nèi)核重啟或人工刪除時(shí)，該消息才會(huì)被刪除。在系統(tǒng)范圍內(nèi)，消息隊(duì)列與鍵值唯一對(duì)應(yīng)。

二、步驟及思路

1、取得鍵值
2、打開、創(chuàng)建消息隊(duì)列
3、發(fā)送消息
4、接收消息

下面具體看看：

1、取得鍵值

代碼如下:

     key_t ftok(char *pathname, char proj)

   頭文件為<sys/ipc.h>。返回文件名對(duì)應(yīng)的鍵值，失敗返回 -1。proj是項(xiàng)目名，隨便寫，不為0就行。
   fname就是你指定的文件名（已經(jīng)存在的文件名）。需要有-t 的權(quán)限，或用root權(quán)限執(zhí)行，通常設(shè)為/tmp或設(shè)為" . "。這里我感覺不用這個(gè)函數(shù)也行，因?yàn)閗ey值可以自己指定，例如： #define KEY_MSG 0x101
2、打開、創(chuàng)建消息隊(duì)列

代碼如下:

    int msgget(key_t key, int msgflg)

  頭文件為<sys/msg.h>。key由ftok獲得。

  msgflg有：

IPC_CREAT 創(chuàng)建新的消息隊(duì)列，應(yīng)配有文件權(quán)限0666。
IPC_EXCL  與IPC_CREAT一同使用，表示如果要?jiǎng)?chuàng)建的消息隊(duì)列已經(jīng)存在，則返回錯(cuò)誤。

IPC_NOWAIT 讀寫消息不阻塞。
 
  當(dāng)沒有與key相對(duì)應(yīng)的消息隊(duì)列并且msgflg中包含了IPC_CREAT標(biāo)志 或 key的參數(shù)為IPC_PRIVATE 時(shí)，創(chuàng)建一個(gè)新的消息隊(duì)列。
3、發(fā)送消息

代碼如下:

        int msgsnd(int msqid, struct msgbuf *msgp, int msgsz, int msgflg)

    向消息隊(duì)列發(fā)送一條消息。msqid為消息隊(duì)列的id，msgp為存放消息的結(jié)構(gòu)體。msgsz是消息的長(zhǎng)度，和數(shù)組的大小不一樣哦。msgflg為消息標(biāo)志，通常為0，也可以為IPC_NOWAIT。出錯(cuò)返回 -1。
 
消息格式

代碼如下:

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

4、接收消息

代碼如下:

       int msgrcv(int msqid, struct msgbuf *msgp, int msgsz, long msgtyp, int msgflg)

    從msqid代表的消息隊(duì)列中讀取一個(gè)msgtyp類型的消息，并把消息存儲(chǔ)在msgp指定的msgbuf結(jié)構(gòu)中。讀取后隊(duì)列中的消息將會(huì)刪除。size為結(jié)構(gòu)體中數(shù)據(jù)的大小，不要計(jì)算msgtyp。出錯(cuò)返回 -1。
三、舉例
創(chuàng)建一消息隊(duì)列，子進(jìn)程發(fā)數(shù)據(jù)，父進(jìn)程收數(shù)據(jù)。實(shí)現(xiàn)向隊(duì)列中存放數(shù)據(jù)與讀取數(shù)據(jù)。

代碼如下:

#include<stdio.h>
#include<sys/msg.h>
#include<fcntl.h>
#include<stdlib.h>
#include<string.h>
#define max 100</p>
<p>struct haha{
        long mtype;
        char data[max];
};</p>
<p>int main(int argc,char *argv[]){
        int pid;
        if(argc!=2){
                printf("Usage: msg [Message]\n");
                return -1;
        }
        key_t key;
        if((key=ftok("/tmp",'g'))<0){           //這里文件夾必須存在，有t屬性并且上級(jí)目錄也要有t屬性
                printf("Getting key error! \n");
                return -1;
        }
        int mgsid;
        if((mgsid=msgget(key,IPC_CREAT|0666))==-1){     //key值隨便寫一個(gè)數(shù)也能用
                        printf("mgs queue create error\n");
                        return -1;
        }
        pid=fork();
        if(pid <0){
                printf("fork create error!\n");
                _exit(1);
        }
        if(pid == 0){
                printf("welcome in child process\n Sending the message......\n");
                sleep(1);
                struct haha hehe;
                hehe.mtype=getppid();
                strcpy(hehe.data,argv[1]);
                if(msgsnd(mgsid,&hehe,sizeof(hehe.data),0)<0){  //此處注意長(zhǎng)度
                        printf("Sending error!!!\n");
                        _exit(1);
                }else {
                        printf("Sending complete!\n");
                        _exit(0);
                }
        }else{
                wait(NULL);
                printf("welcome in parents process\n Receiving the message......\n");
                sleep(1);
                struct haha gaga;
                if(msgrcv(mgsid,&gaga,max,getpid(),0)<0){
                        printf("Receiving error!!!\n");
                        _exit(1);
                }else {
                        printf("Receiving complete!\n");
                        printf("The message is %s \n",gaga.data);
                }
        }
        return 0;
}

看完上述內(nèi)容是否對(duì)您有幫助呢？如果還想對(duì)相關(guān)知識(shí)有進(jìn)一步的了解或閱讀更多相關(guān)文章，請(qǐng)關(guān)注億速云行業(yè)資訊頻道，感謝您對(duì)億速云的支持。