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