今天，我們來學習一下Unix 消息隊列的知識，首先，我們下面舉例說明一個Unix 消息隊列在 C/S 模式中的應用。 C/S 的一個重要特性就是非對等性, 多個客戶機同時向一個服務器提出不同的請求 , 服務器接收并處理客戶機的請求后 , 將結果返回給相應的客戶機。在這里 , 我們利用兩個Unix 消息隊列、一個服務進程、若干客戶進程來模擬客戶 / 服務應用。

由各客戶進程將請求信息寫入隊列 1( 鍵值 0x16), 消息類型定為 10; 服務進程從隊列 1 中讀取類型為 10 的消息進行處理 , 并將處理結果放入Unix 消息隊列 2( 鍵值0x17), 將類型置為原客戶進程號 , 這樣每個客戶進程可根據其中的消息類型即進程號再從隊列 2 中讀出屬于自己的結果 。

具體操作時先啟動服務進程 (server.c), 創建兩個Unix 消息隊列 , 鍵值分別為十六進制 16和 17; 這時再啟動若干客戶進程 (client.c), 輸入一任意字符串 , 這時服務進程則顯示客戶進程號和原字符串 , 客戶進程則回顯***個字符被改為 "_" 的處理后的字符串和消息類型( 自身進程號 ) 。如輸入字符 "q", 則刪除原Unix 消息隊列 , 同時退出。源程序清單附后 , 該程序在 UNIX3.2 、 4.2 環境下編譯調試通過。

這只是進程通信在機器內部的實現 , 要實現進程在網絡機器間的通信還要借助 UNIX 網際系統的套接字來實現。

源程序清單如下 :
 

服務進程 :(server.c)   
#include <stdio.h>   
#include <sys/types.h>   
#include <sys/ipc.h>   
#include <sys/msg.h>   
#define KEY16 (key_t)16   
#define KEY17 (key_t)17   
#include (ctype.h)   
int i,msgid1,msgid2,val;   
char *s   
struct{   
long mtype;   
short stype;   
char mtext[40];   
}buf;   
main()   
{   
 
cr_q(); /* 創建消息隊列 */   
/* 讀消息隊列 1, 消息隊列類型為 10, 等待客戶請求 */   
while   (msgrcv(msgid1,&buf,42,(long)10, ～ IPC_NOWAIT)>=0)   
{printf("\n text from client is:[%s]",buf.mtext);   
 printf ("client pid is <%d> \n",buf.stype);   
 process();/* 將處理結果寫入消息隊列 2*/   
}   
}   
cr_q()   
{  msgid1=msgget(KEY16,IPC_CREAT|0666);   
if (msgid1<0) {perror("key16 msgget failed");exit(1);}   
msgid2=msgget(KEY17,IPC_CREAT|0666);   
if (msgid2<0) {perror("key17 msgget failed");exit(1);}   
}   
process()   
{   
bufbuf.mtype=buf.stype;/* 原客戶進程號 */   
buf.mtext[0]= ‘ _ ’ ;   
if(msgsnd(msgid2,&buf,42,IPC_NOWAIT)<0)   
{perror("key17 msgsnd failed");exit(1);}   
}   

客戶進程 :(client.c)   
#include <stdio.h>   
#include <sys/types.h>   
#include <sys/ipc.h>   
#include <sys/msg.h>   
define KEY16 (key_t)16   
define KEY17 (key_t)17   
include <ctype.h>   
int msgid1,msgid2;   
struct{   
long mtype;   
short stype;   
char mtext[40];   
}buf;   
char s[41];   
int clean()   
main()   
{   
get_q();/* 取消隊列標志符 */   
while (1)   
{   
printf ("\n @ input mtext:");/* 輸入字符串 */   
scanf("%s",s);   
if ((strcmp(s,"q")==0)) break;   
strcpy(buf.mtext,s);   
buf.mtype=10; /* 消息類型置為 10*/   
buf.stype=getpid();/* 客戶進程號 */   
/* 寫消息隊列 1, 向服務進程提出請求 */   
if (msgsnd(msgid1,&buf,40, ～ IPC_NOWAIT)<0)   
{perror("key16 msgsnd failed");exit(1);}   
/* 讀消息隊列 2, 類型為自身進程號 , 接收處理結果 */   
if (msgrcv(msgid2,&buf,42,getpid(), ～ IPC_NOWAIT)<0)   
 {perror("key17 msgrcv failed");exit(1);}   
printf("\n the answer from server is:[%s]",buf.mtext);   
 printf("mtype is:[%d]",buf.mtype);   
 }   
clean();/* 刪除消息隊列 */   
}   
clean()   
{   
if(msgct1(msgid1,IPC_RMID,(struct msgid*)NULL)<0)   
{perror("key16 msgct1 failed");exit(1);}   
if(msgct1(msgid2,IPC_RMID,(struct msgid*)NULL<0)   
{perror("key17 msgct1 failed");exit(1);}   
printf("msg queue removed\n");   
exit(0);   
}   
get_q()   
{   
msgid1=msgget(KEY16,0);   
if (msgid1<0) {perror("key16 msgget failed");exit(1);}   
msgid2=msgget(KEY17,0);if (msgid2<0) {perror("key17 msgget failed");exit(1);}   
}  

關于Unix 消息隊列的應用，我們今天就講解到這里啦，希望大家能夠好好的學習，我們會帶來更多的Unix 消息隊列應用的知識。

【編輯推薦】

1. Linux多線程同步之消息隊列
2. 詳解Unix消息隊列知識
3. VB.NET消息隊列相關內容詳細介紹
4. WCF消息隊列系列介紹
5. 說明WCF消息隊列具體問題