消息隊列提供了一種從一個進程向另一個進程發送一個數據塊的方法。 每個數據塊都被認為含有一個類型,接收進程可以獨立地接收含有不同類型的數據結構。我們可以通過發送消息來避免命名管道的同步和阻塞問題。但是消息隊列與命名管道一樣,每個數據塊都有一個最大長度的限制,linux用宏MSGMAX和MSGMNB來限制一條消息的最大長度和一個隊列的最大長度。
該函數用來創建和訪問一個消息隊列。它的原型為:
int msgget(key_t, key, int msgflg); 與其他的ipC機制一樣,程序必須提供一個鍵來命名某個特定的消息隊列。msgflg是一個權限標志,表示消息隊列的訪問權限,它與文件的訪問權限一樣。msgflg可以與IPC_CREAT做或操作,表示當key所命名的消息隊列不存在時創建一個消息隊列,如果key所命名的消息隊列存在時,IPC_CREAT標志會被忽略,而只返回一個標識符。它返回一個以key命名的消息隊列的標識符(非零整數),失敗時返回-1.2、msgsnd函數
該函數用來把消息添加到消息隊列中。它的原型為:
int msgsend(int msgid, const void *msg_ptr, size_t msg_sz, int msgflg); msgid是由msgget函數返回的消息隊列標識符。msg_ptr是一個指向準備發送消息的指針,但是消息的數據結構卻有一定的要求,指針msg_ptr所指向的消息結構一定要是以一個長整型成員變量開始的結構體,接收函數將用這個成員來確定消息的類型。所以消息結構要定義成這樣:struct my_message{ long int message_type; /* The data you wish to transfer*/ }; msg_sz是msg_ptr指向的消息的長度,注意是消息的長度,而不是整個結構體的長度,也就是說msg_sz是不包括長整型消息類型成員變量的長度。msgflg用于控制當前消息隊列滿或隊列消息到達系統范圍的限制時將要發生的事情。如果調用成功,消息數據的一分副本將被放到消息隊列中,并返回0,失敗時返回-1.3、msgrcv函數
該函數用來從一個消息隊列獲取消息,它的原型為
int msgrcv(int msgid, void *msg_ptr, size_t msg_st, long int msgtype, int msgflg); msgid, msg_ptr, msg_st的作用也函數msgsnd函數的一樣。msgtype可以實現一種簡單的接收優先級。如果msgtype為0,就獲取隊列中的第一個消息。如果它的值大于零,將獲取具有相同消息類型的第一個信息。如果它小于零,就獲取類型等于或小于msgtype的絕對值的第一個消息。msgflg用于控制當隊列中沒有相應類型的消息可以接收時將發生的事情。調用成功時,該函數返回放到接收緩存區中的字節數,消息被復制到由msg_ptr指向的用戶分配的緩存區中,然后刪除消息隊列中的對應消息。失敗時返回-1.4、msgctl函數
該函數用來控制消息隊列,它與共享內存的shmctl函數相似,它的原型為:
int msgctl(int msgid, int command, struct msgid_ds *buf); command是將要采取的動作,它可以取3個值, IPC_STAT:把msgid_ds結構中的數據設置為消息隊列的當前關聯值,即用消息隊列的當前關聯值覆蓋msgid_ds的值。 IPC_SET:如果進程有足夠的權限,就把消息列隊的當前關聯值設置為msgid_ds結構中給出的值 IPC_RMID:刪除消息隊列buf是指向msgid_ds結構的指針,它指向消息隊列模式和訪問權限的結構。msgid_ds結構至少包括以下成員:struct msgid_ds { uid_t shm_perm.uid; uid_t shm_perm.gid; mode_t shm_perm.mode; }; 成功時返回0,失敗時返回-1.3、使用消息隊列進行進程間通信
實現msgsend.c文件向msgrcv.c通過消息隊列進行寫文件
1、msgsend.c文件圖片如下
2、msgrcv.c文件如下
4、結果分析
我們先運行msgsend.c文件,然后再運行msgrcv.c文件,結果如下
好了,那我就從msgsend這篇發送數據,結果如下圖
msgreceive.c文件main函數中的語句由long int msgtype = 0;改變為long int msgtype = 2;會發生什么情況,msgreceive將不能接收到程序msgsend發送的信息。因為在調用msgrcv函數時,如果msgtype(第四個參數)大于零,則將只獲取具有相同消息類型的第一個消息,修改后獲取的消息類型為2,而msgsend發送的消息類型為1,所以不能被msgreceive程序接收,如果把msgreceive.c文件main函數中的語句由long int msgtype = 0改為long int msgtype = 2,把msgsend發送的消息類型改為2,這樣也是沒問題的,一直通信總結:發送端類型為1,接收端可以為0,正常通信 發送端類型為2,接收端可以為2,正常通信
5、和命名管道對比分析
消息隊列跟命名管道有不少的相同之處,通過與命名管道一樣,消息隊列進行通信的進程可以是不相關的進程,同時它們都是通過發送和接收的方式來傳遞數據的。在命名管道中,發送數據用write,接收數據用read,則在消息隊列中,發送數據用msgsnd,接收數據用msgrcv。而且它們對每個數據都有一個最大長度的限制。與命名管道相比,消息隊列的優勢在于,1、消息隊列也可以獨立于發送和接收進程而存在,從而消除了在同步命名管道的打開和關閉時可能產生的困難。2、同時通過發送消息還可以避免命名管道的同步和阻塞問題,不需要由進程自己來提供同步方法。3、接收程序可以通過消息類型有選擇地接收數據,而不是像命名管道中那樣,只能默認地接收。
新聞熱點
疑難解答