Linux消息隊列編程示例

一、概念
消息隊列就是一個消息的鏈表。可以把消息看作一個記錄,具有特定的格式以及特定的優(yōu)先級。對消息隊列有寫權(quán)限的進(jìn)程可以向中按照一定的規(guī)則添加新消息;有讀權(quán)限的進(jìn)程則可以讀走消息。讀走就沒有了。消息隊列是隨內(nèi)核持續(xù)的。 只有內(nèi)核重啟或人工刪除時,該消息才會被刪除。在系統(tǒng)范圍內(nèi),消息隊列與鍵值唯一對應(yīng)。
二、步驟及思路
1、取得鍵值
2、打開、創(chuàng)建消息隊列
3、發(fā)送消息
4、接收消息
下面具體看看:
1、取得鍵值
key_t ftok(char *pathname, char proj)
頭文件為<sys/ipc.h>。返回文件名對應(yīng)的鍵值,失敗返回 -1。proj是項目名,隨便寫,不為0就行。
fname就是你指定的文件名(已經(jīng)存在的文件名)。需要有-t 的權(quán)限,或用root權(quán)限執(zhí)行,通常設(shè)為/tmp或設(shè)為" . "。這里我感覺不用這個函數(shù)也行,因為key值可以自己指定,例如: #define KEY_MSG 0x101
2、打開、創(chuàng)建消息隊列
int msgget(key_t key, int msgflg)
頭文件為<sys/msg.h>。key由ftok獲得。
msgflg有:
IPC_CREAT 創(chuàng)建新的消息隊列,應(yīng)配有文件權(quán)限0666。
IPC_EXCL 與IPC_CREAT一同使用,表示如果要創(chuàng)建的消息隊列已經(jīng)存在,則返回錯誤。
IPC_NOWAIT 讀寫消息不阻塞。
當(dāng)沒有與key相對應(yīng)的消息隊列并且msgflg中包含了IPC_CREAT標(biāo)志 或 key的參數(shù)為IPC_PRIVATE 時,創(chuàng)建一個新的消息隊列。
3、發(fā)送消息
int msgsnd(int msqid, struct msgbuf *msgp, int msgsz, int msgflg)
向消息隊列發(fā)送一條消息。msqid為消息隊列的id,msgp為存放消息的結(jié)構(gòu)體。msgsz是消息的長度,和數(shù)組的大小不一樣哦。msgflg為消息標(biāo)志,通常為0,也可以為IPC_NOWAIT。出錯返回 -1。
消息格式
struct msgbuf {
long mtype;
char mtext[100];
};
4、接收消息
int msgrcv(int msqid, struct msgbuf *msgp, int msgsz, long msgtyp, int msgflg)
從msqid代表的消息隊列中讀取一個msgtyp類型的消息,并把消息存儲在msgp指定的msgbuf結(jié)構(gòu)中。讀取后隊列中的消息將會刪除。size為結(jié)構(gòu)體中數(shù)據(jù)的大小,不要計算msgtyp。出錯返回 -1。
三、舉例
創(chuàng)建一消息隊列,子進(jìn)程發(fā)數(shù)據(jù),父進(jìn)程收數(shù)據(jù)。實現(xiàn)向隊列中存放數(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屬性并且上級目錄也要有t屬性
printf("Getting key error! \n");
return -1;
}
int mgsid;
if((mgsid=msgget(key,IPC_CREAT|0666))==-1){ //key值隨便寫一個數(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){ //此處注意長度
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;
}
相關(guān)文章
Fedora Linux 42 穩(wěn)定版發(fā)布: 帶來大量新功能和軟件更新
Fedora 42昨日發(fā)布,這是 Red Hat 贊助開發(fā)的杰出前沿 Linux 發(fā)行版的最新版,包含大量新功能和軟件更新,使其成為 2025 年上半年發(fā)布的一款出色的 Linux 操作系統(tǒng)之一,內(nèi)2025-04-16如何在Linux查看硬盤信息? 查看Linux硬盤大小類型和硬件信息的5種方法
使用Linux系統(tǒng)的過程中,查看和了解硬盤信息是非常重要的工作,尤其是對于系統(tǒng)管理員而言,那么在Linux系統(tǒng)中如何查看硬盤信息?以下是具體內(nèi)容介紹2025-03-12如何在 Linux 中查看 CPU 詳細(xì)信息? 3招輕松查看CPU型號、核心數(shù)和溫度
在日常運維工作中,獲取 CPU 信息是系統(tǒng)運維管理員常見的工作內(nèi)容,無論是為了性能調(diào)優(yōu)、硬件升級還是僅僅滿足好奇心2025-03-11什么是 Arch Linux? 獨樹一幟的Arch Linux發(fā)行版分析
Arch Linux是為簡化,優(yōu)化,現(xiàn)代化,實用主義,用戶中心和多功能性而創(chuàng)建Linux發(fā)行版,究竟是什么讓 Arch 與眾不同?下面我們就來簡要解讀2025-02-19如何在Linux環(huán)境下制作 Win11裝機(jī)U盤?
一直用的linux辦公,想要將筆記本電腦從 Linux 系統(tǒng)切換回 Windows 11,我們可以制作一個win11裝機(jī)u盤,詳細(xì)如下2025-02-17Rsnapshot怎么用? 基于Rsync的強大Linux備份工具使用指南
Rsnapshot 不僅可以備份本地文件,還能通過 SSH 備份遠(yuǎn)程文件,接下來詳細(xì)介紹如何安裝、配置和使用 Rsnapshot,包括創(chuàng)建每小時、每天、每周和每月的本地備份,以及如何進(jìn)2025-02-06Linux Kernel 6.13發(fā)布:附更新內(nèi)容及新特性解讀
Linux 內(nèi)核 6.13 正式發(fā)布,新版本引入了惰性搶占支持,簡化內(nèi)核搶占邏輯,通過減少與調(diào)度器相關(guān)的調(diào)用次數(shù),讓內(nèi)核在運行時表現(xiàn)更優(yōu),從而提高效率2025-01-23五大特性引領(lǐng)創(chuàng)新! 深度操作系統(tǒng) deepin 25 Preview預(yù)覽版發(fā)布
今日,深度操作系統(tǒng)正式推出deepin 25 Preview版本,該版本集成了五大核心特性:磐石系統(tǒng)、全新DDE、Treeland窗口合成器、AI For OS以及Distrobox子系統(tǒng)2025-01-18Linux Mint Xia 22.1重磅發(fā)布: 重要更新一覽
Beta 版 Linux Mint“Xia” 22.1 發(fā)布,新版本基于 Ubuntu 24.04,內(nèi)核版本為 Linux 6.8,這次更新帶來了諸多優(yōu)化和改進(jìn),進(jìn)一步鞏固了 Mint 在 Linux 桌面操作系統(tǒng)領(lǐng)域的2025-01-16LinuxMint怎么安裝? Linux Mint22下載安裝圖文教程
Linux Mint22發(fā)布以后,有很多新功能,很多朋友想要下載并安裝,該怎么操作呢?下面我們就來看看詳細(xì)安裝指南2025-01-16