第4章進程間通信3-資料下載頁
2025-09-19 16:03本頁面
【導讀】消息隊列滿足IPC通信機制的通用規(guī)則：使用一個消。構）來唯一標識一個消息隊列，并依此檢查訪問權限。消息隊列本身是一個臨界資源，需實現(xiàn)互斥操作。該數(shù)據(jù)結構用來存放需要發(fā)送或接收的消息類型和消息正文。mtext[1]是消息正文，該域可由程序員定義為任意數(shù)據(jù)結構，但消息及消息隊列的長度有限，*next與msgbuf鏈接成一個完整的消息實體。Linux內核維護一個消息隊列鏈表msgque，該表描述了當前系統(tǒng)中的消息隊列。列結構的頭元素：消息緩沖隊列、接收進程等待隊列、發(fā)送進程等待隊列。留有關隊列變動的時間以及進程標識等信息。接收進程是否是就緒態(tài)？緩沖區(qū)有數(shù)據(jù)嗎？共提供了4個系統(tǒng)調用
【正文】 main( ) { int msgid。 //定義消息緩沖區(qū)內部標識 char buffer[BUFSIZ]。 //定義用戶緩沖區(qū) msgid=msgget(1234,0666|IPC_CREAT)。 //創(chuàng)建消息隊列， key為 1234 while(1) { puts(Enter some text:)。 //提示鍵入消息內容 fgets(buffer,BUFSIZ,stdin)。 //標準輸入送 buffer =1。 //設置消息類型為 1 strcpy(,buffer)。 //buffer送消息緩沖 msgsnd (msgid,amp。msg,MAXMSG,0)。 //發(fā)送消息到消息隊列 if(strncmp(,end,3)==0) /消息為“ end”則結束 break。 } exit(0)。 } 2020/11/4 操作系統(tǒng)與實驗 第 4章 2 19 接收進程 include include include include includesys/ includelinux/ define MAXMSG 512 //定義消息長度 struct my_msg //定義消息 f緩沖區(qū)數(shù)據(jù)結構 { long int my_msg_type。 char some_text[MAXMSG]。 }msg。 main() { int msgid。 //定義消息緩沖區(qū)內部標識 long int msg_to_receive=0。 msgid=msgget(1234, 0666|IPC_CREAT)。 //獲取消息隊列 ， key為 1234 while (1) { msgrcv (msgid, amp。msg, BUFSIZ, msg_to_receive, 0)。 //接收消息 printf (You wrote:%s,)。 //顯示消息 if (strncmp (,end,3)==0) //消息為 “ end”則結束 break。 } msgctl (msgid, IPC_RMID,0)。 //撤消消息隊列 exit (0)。 } 2020/11/4 操作系統(tǒng)與實驗 第 4章 2 20 消息緩沖通信應用舉例 在創(chuàng)建或獲取一個消息緩沖隊列時 ， 其 key值可以由用戶給出也可以由系統(tǒng)生成 。 本例中 ， 由于發(fā)送與接收是兩個完全獨立的進程 ， 因此雙方只能使用事先約定好的key值 ， 以用戶指定的方式給出 。 如果發(fā)送和接收進程都是同一個家族的子進程 ， 則可以由其祖先創(chuàng)建后 ， 子孫使用 ， 因而可以采用由系統(tǒng)指定 key值的方式 ， 這種情況可以使用參數(shù) IPC_PRIVATE取代我們設定的 key值1234。 2020/11/4 操作系統(tǒng)與實驗 第 4章 2 21 小結 消息緩沖優(yōu)缺點、適用場合及其應用 ? 自帶同步工具 ， 使用起來較方便 。 （ 優(yōu)點 ） ? 該通信方式不適合信息量大或信息交換頻繁的場合 。 （ 缺點 ） ? 存在用戶普通緩沖區(qū)與消息緩沖區(qū)之間的信息復制過程 ， 時間開銷較大 。 ? 消息緩沖區(qū)自數(shù)據(jù)結構 msg_msg存在空間的開銷 。 ? 消息隊列機制是客戶 /服務器模型中常用的進程通信方式 。 2020/11/4 操作系統(tǒng)與實驗 第 4章 2 22 作業(yè) 第 4章 6
教學課件相關推薦
鄂ICP備17016276號-1