linux.调整收发队列,linux消息队列通信
程序目的：學習linux消息隊列通信
所用主要函數：msgget(),msgsnd(),msgrcv(),msgctl()
首先介紹每個函數的用法：
(1)msgget
使用格式：
#include
#include
#include
int msgget(key_t k e y, int? f l a g) ;
功能：是打開一個現存隊列或創建一個新隊列。
返回值：成功執行時，返回消息隊列標識值。失敗返回-1，有時也會返回0，這個時候也是可以正常使用的。
參數key：消息隊列關聯的鍵，可以直接賦值設為固定的的鍵值。也可以用ftok()。
也介紹一下ftok函數key_t ftok( char * fname, int id )
fname就是你指定的文件名(已經存在的文件名)，一般使用當前目錄；id是子序號。
這樣就能得到一個固定的key_t值。
參數f l a g：消息隊列的建立標志和存取權限，建立標志一般為指定為IPC_CREAT和IPC_EXCL標志 。
IPC_CREAT：如果內核中沒有此隊列，則創建它。當IPC_CREAT和IPC_EXCL一起使用時，如果隊列已經存在，則失敗。
例：msgget(ftok("./file",123),IPC_CREAT |0666)
(2)msgsnd
功能：在消息隊列上進行收發消息。為了發送消息，調用進程對消息隊列必須有寫權能。接收消息時必須有讀權能。
使用格式：
#include
#include
#include
int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);
返回值：成功執行時，返回消息隊列標識值。失敗返回-1。
參數：
msqid：消息隊列的識別碼。
msgp：指向消息緩沖區的指針，此位置用來暫時存儲發送和接收的消息，是一個用戶可定義的通用結構，如下
struct msgbuf {
long mtype; //消息類型，必須 大于0
char mtext[1]; // 消息文本
};
msgsz：消息的大小。
msgflg:用來指明核心程序在隊列沒有數據的情況下所應采取的行動。當msgflg為IPC_NOWAIT不會阻塞。當msgflg為0時msgsnd()在隊列呈滿或呈空的情形時，采取阻塞等待的處理模式。
(3)msgrcv
使用格式：
#include
#include
#include
ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg);
參數：(同上2)
msgtyp：消息類型
其他參數同上(2)。
(4)msgctl
原型： int msgctl ( int msgqid, int cmd, struct msqid_ds *buf );
返回值： 如果成功為0 錯誤返回- 1。
參數msgqid ：是消息隊列對象的標識符。
第二個參數cmd：是函數要對消息隊列進行的操作，它可以是：
IPC_STAT取出系統保存的消息隊列的msqid_ds 數據，并將其存入參數buf 指向的msqid_ds 結構
中。
IPC_SET設定消息隊列的msqid_ds 數據中的msg_perm 成員。設定的值由buf 指向的msqid_ds
結構給出。
IPC_EMID將隊列從系統內核中刪除。
這三個命令的功能都是明顯的。唯一需要強調的是在IPC_STAT
命令中隊列的msqid_ds 數據中唯一能被設定的只有msg_perm 成員，是ipc_perm 類型的
數據。而ipc_perm 中能被修改的只有mode,pid 和uid 成員。其他的都是只能由系統來設定
的。
******************************有關范例*********************************************
下面就看一個用消息隊列通信寫的一個簡單的銀行取號小程序：
在這里我用到了兩個進程：msgc.c? 和 msg.c
(1)msg.c
#include
#include
#include
#include
#include
#define MSG_KEY 8888
struct mymesg{
long mtype;//消息類型
char mtext[512];//消息內容
};
int main(void)
{
int msgid;
struct msqid_ds buf;
struct mymesg mymsg;
msgid=msgget(MSG_KEY,IPC_CREAT |0600);//創建一個新隊列
if(-1==msgid)
{
perror("msggit");
exit(EXIT_FAILURE);
}
while(1)
{
printf("請輸入號碼和內容：\n");
scanf("%d %s",&mymsg.mtype,mymsg.mtext);
msgsnd(msgid,&mymsg,strlen(mymsg.mtext)+1,0);//發送mymsg中的信息到msgid對應的消息隊列
}
return 0;
}
(2)msg.c
#include
#include
#include
#include
#include
#define MSG_KEY 8888
struct mymesg{
long mtype;
char mtext[512];
};
int main(void)
{
int msgid;
struct mymesg mymsgrcv;
msgid=msgget(MSG_KEY,IPC_CREAT |0600);
if(-1==msgid)
{
perror("msggit");
exit(EXIT_FAILURE);
}
while(1)
{
printf("請選擇號碼：");
scanf("%d",&mymsgrcv.mtype);
int ms=msgrcv(msgid,&mymsgrcv,512,mymsgrcv.mtype,0);//接收消息隊列相應類型(號碼)信息
if(-1==ms)
{
perror("msgrcv");
exit(EXIT_FAILURE);
}
printf("received:%s\n",mymsgrcv.mtext);
}
int msg=msgctl(msgid,IPC_RMID,0);//將隊列從系統內核中刪除。
if(-1==msg)
{
perror("msgctl");
exit(EXIT_FAILURE);
}
return 0;
}
/*********************程序運行結果*********************
[root@localhost msg]#gcc -o msg.c msg.c
[root@localhost msg]# ./msg.c第一個進程
請輸入號碼和內容：
1? Personal business
請輸入號碼和內容：
2?? company business
請輸入號碼和內容：
3?? Other business
[root@localhost msg]# gcc -o msgc.c msgc.c
[root@localhost msg]# ./msgc.c第二個進程
請選擇號碼：1
received：Personal business
請選擇號碼：2
received：company business
……
***********************************************************/
本人初學者，在寫本博文中可能有一些不當的地方，歡迎大家向我指正。
總結
以上是生活随笔為你收集整理的linux.调整收发队列,linux消息队列通信的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： linux x64 asm 参数传递,N
- 下一篇： linux tracepoint例子,t