主頁 > 知識(shí)庫 > Linux消息隊(duì)列編程示例

Linux消息隊(duì)列編程示例

熱門標(biāo)簽:地圖上標(biāo)注點(diǎn)位的圖標(biāo) 常熟外呼系統(tǒng) 中山防封卡電銷卡辦理 百度地圖標(biāo)注未成功 江蘇小型外呼系統(tǒng)軟件 電話機(jī)器人服務(wù)器部署 文山外呼營(yíng)銷系統(tǒng) 拉薩銷售外呼系統(tǒng)軟件 電銷語音機(jī)器人哪個(gè)好

一、概念

消息隊(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、取得鍵值

復(fù)制代碼
代碼如下:

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ì)列

復(fù)制代碼
代碼如下:

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ā)送消息

復(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。
 
消息格式

復(fù)制代碼
代碼如下:

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

4、接收消息

復(fù)制代碼
代碼如下:

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ù)。


復(fù)制代碼
代碼如下:

#includestdio.h>
#includesys/msg.h>
#includefcntl.h>
#includestdlib.h>
#includestring.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;
}

標(biāo)簽:和田 石家莊 法律問答 淮安 湖南 馬鞍山 和田 開封

巨人網(wǎng)絡(luò)通訊聲明:本文標(biāo)題《Linux消息隊(duì)列編程示例》,本文關(guān)鍵詞  Linux,消息,隊(duì)列,編程,示例,;如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問題,煩請(qǐng)?zhí)峁┫嚓P(guān)信息告之我們,我們將及時(shí)溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò),涉及言論、版權(quán)與本站無關(guān)。
  • 相關(guān)文章
  • 下面列出與本文章《Linux消息隊(duì)列編程示例》相關(guān)的同類信息!
  • 本頁收集關(guān)于Linux消息隊(duì)列編程示例的相關(guān)信息資訊供網(wǎng)民參考!
  • 推薦文章