進(jìn)程間通信之：消息隊(duì)列
加入技術(shù)交流群
8.6消息隊(duì)列
8.6.1消息隊(duì)列概述
顧名思義，消息隊(duì)列就是一些消息的列表。用戶可以從消息隊(duì)列中添加消息和讀取消息等。從這點(diǎn)上看，消息隊(duì)列具有一定的FIFO特性，但是它可以實(shí)現(xiàn)消息的隨機(jī)查詢，比FIFO具有更大的優(yōu)勢(shì)。同時(shí)，這些消息又是存在于內(nèi)核中的，由“隊(duì)列ID”來標(biāo)識(shí)。
8.6.2消息隊(duì)列的應(yīng)用
1．函數(shù)說明
消息隊(duì)列的實(shí)現(xiàn)包括創(chuàng)建或打開消息隊(duì)列、添加消息、讀取消息和控制消息隊(duì)列這4種操作。其中創(chuàng)建或打開消息隊(duì)列使用的函數(shù)是msgget()，這里創(chuàng)建的消息隊(duì)列的數(shù)量會(huì)受到系統(tǒng)消息隊(duì)列數(shù)量的限制；添加消息使用的函數(shù)是msgsnd()函數(shù)，它把消息添加到已打開的消息隊(duì)列末尾；讀取消息使用的函數(shù)是msgrcv()，它把消息從消息隊(duì)列中取走，與FIFO不同的是，這里可以指定取走某一條消息；最后控制消息隊(duì)列使用的函數(shù)是msgctl()，它可以完成多項(xiàng)功能。
2．函數(shù)格式
表8.23列舉了msgget()函數(shù)的語法要點(diǎn)。
表8.23 msgget()函數(shù)語法要點(diǎn)
所需頭文件 | #includesys/types.h> | |
函數(shù)原型 | intmsgget(key_tkey,intmsgflg) | |
函數(shù)傳入值 | key：消息隊(duì)列的鍵值，多個(gè)進(jìn)程可以通過它訪問同一個(gè)消息隊(duì)列，其中有個(gè)特殊值IPC_PRIVATE。它用于創(chuàng)建當(dāng)前進(jìn)程的私有消息隊(duì)列 | |
msgflg：權(quán)限標(biāo)志位 | ||
函數(shù)返回值 | 成功：消息隊(duì)列ID | |
出錯(cuò)：-1 | ||
表8.24列舉了msgsnd()函數(shù)的語法要點(diǎn)。
表8.24 msgsnd()函數(shù)語法要點(diǎn)
所需頭文件 | #includesys/types.h> | |
函數(shù)原型 | intmsgsnd(intmsqid,constvoid*msgp,size_tmsgsz,intmsgflg) | |
函數(shù)傳入值 | msqid：消息隊(duì)列的隊(duì)列ID | |
msgp：指向消息結(jié)構(gòu)的指針。該消息結(jié)構(gòu)msgbuf通常為： { longmtype;/*消息類型，該結(jié)構(gòu)必須從這個(gè)域開始*/ charmtext[1];/*消息正文*/ | ||
msgsz：消息正文的字節(jié)數(shù)（不包括消息類型指針變量） | ||
msgflg： | IPC_NOWAIT若消息無法立即發(fā)送（比如：當(dāng)前消息隊(duì)列已滿），函數(shù)會(huì)立即返回 | |
0：msgsnd調(diào)阻塞直到發(fā)送成功為止 | ||
函數(shù)返回值 | 成功：0 | |
出錯(cuò)：-1 | ||
表8.25列舉了msgrcv()函數(shù)的語法要點(diǎn)。
表8.25 msgrcv()函數(shù)語法要點(diǎn)
所需頭文件 | #includesys/types.h> | |||
函數(shù)原型 | intmsgrcv(intmsgid,void*msgp,size_tmsgsz,longintmsgtyp,intmsgflg) | |||
函數(shù)傳入值 | msqid：消息隊(duì)列的隊(duì)列ID | |||
msgp：消息緩沖區(qū),同于msgsnd()函數(shù)的msgp | ||||
msgsz：消息正文的字節(jié)數(shù)（不包括消息類型指針變量） | ||||
msgtyp： | 0：接收消息隊(duì)列中第一個(gè)消息 | |||
大于0：接收消息隊(duì)列中第一個(gè)類型為msgtyp的消息 | ||||
小于0：接收消息隊(duì)列中第一個(gè)類型值不小于msgtyp絕對(duì)值且類型值又最小的消息 | ||||
函數(shù)傳入值 | msgflg： | MSG_NOERROR：若返回的消息比msgsz字節(jié)多，則消息就會(huì)截短到msgsz字節(jié)，且不通知消息發(fā)送進(jìn)程 | ||
IPC_NOWAIT若在消息隊(duì)列中并沒有相應(yīng)類型的消息可以接收，則函數(shù)立即返回 | ||||
0：msgsnd()調(diào)用阻塞直到接收一條相應(yīng)類型的消息為止 | ||||
函數(shù)返回值 | 成功：0 | |||
出錯(cuò)：-1 | ||||
評(píng)論