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