兩個關(guān)鍵問題的解決方法
通常一臺服務(wù)器要連接多臺客戶機，而每臺客戶機由于支持多用戶方式就會同時運行多個c_process進程。服務(wù)器如何準確地將消息送給哪一臺客戶機? 另外一臺客戶機上運行的每一個c_process進程如何正確地獲取發(fā)送給自己的消息? 這是兩個關(guān)鍵的問題。 第一個問題在前面已經(jīng)講述過,主要是通過消息的sid標志來區(qū)別的。第二個問題是這樣解決，在第①步時c_process進程先將自身的進程號pidc放在buf->cpid中，該值在以后的傳輸過程中保持不變，在第⑦步再將cpid賦值給消息類別mtype。這樣在第⑧時c_process進程就從消息隊列qid2中取走消息類別mtype等于其自身進程號pidc的消息,而不會錯將送給同一客戶機別的c_process進程的消息拿走。(圖3) ┌──────────────┐ ┌────────────┐
│Server ┌───┤ ├───┐ ┌─────┐│
│ │tcp_s │ ┌────┤tcp_c ├┐│c_process2││
│ ┌─────┐ └─┬─┤ │ ├───┤│└─────┘│
│ │s_process │┌───┴┐│ │ ┌─→┤tcp_c1││┌─────┐│
│ │服務(wù)程序 ││共享內(nèi)存││ │ │ L2├─┬─┘││c_process1││
│ └─┬─┬─┘└───┬┘│ │ │ │ ↓⑦ │└───┬┬┘│
│ ⑤↓ ↑④ ┌─┴─┤L1 │ │ │ │ └─┐ │↑⑧│
│┌──┘ │ ┌─┤tcp_s1├←──┘ │ │ │ ②↑ ││ │
││┌──┬┼┐③│ │ ├←┐L1’ │ │ │┌──┬┼┐①││ │
│││qid3│ ├←┘ ├───┤ │ │ │ ││qid1│ ├←┘│ │
││├──┼─┤ ┌┤tcp_s2├─┼───┘ │ │├──┼─┤ │ │
│││qid4│ ┼→─┘│ ├┐│┌────┐│ ││qid2│ ┼──┘ │
││└──┴┬┘⑥ └───┤│└┤ ││ │└──┴┬┘ │
│└────┘ │└→┤Client2 ││ └────┘ Client1 │
└──────────────┘ L2’└────┘└──────────┘
圖3 消息在服務(wù)器和客戶機內(nèi)傳送的過程
消息隊列與共享內(nèi)存
在運行服務(wù)器通信軟件之前應(yīng)先創(chuàng)建共享內(nèi)存和消息隊列，創(chuàng)建共享內(nèi)存的方法見文獻[3]。本文共用到四個共享內(nèi)存操作函數(shù):shm_login(cport1,cport2,client_addr)在共享內(nèi)存中申請一條記錄將三個參數(shù)登記其中,并將flag標志設(shè)為’i’表示已經(jīng)占用，同時根據(jù)記錄的位置賦值給記錄編號id。shm_logout(id)將共享內(nèi)存中第id條記錄刪除，并將后面的記錄前移,重新計算各條記錄的編號。shm_info(id,type)根據(jù)type查詢第id條記錄的內(nèi)容，比如type為GETS1時表示要查詢s_socket1的值，當type等于GETLINKN時統(tǒng)計共享內(nèi)存的記錄總數(shù)。shm_update(id,s_socket1,s_socket2,linkf1,linkf2)修改第id條記錄的內(nèi)容,如果某個參數(shù)為零則不修改這個參數(shù)，如shm_update(n,s2,0,1,0)只修改s_socket1和linkf1的值，其余內(nèi)容不作修改。在業(yè)務(wù)繁忙的情況下，有必要擴大消息隊列的存儲容量，下面的例子將消息隊列qid3的容量擴大兩倍。 來源：www.examda.com
struct msqid_ds sbuf1,*sbuf;int qid3;
sbuf=&sbuf1;
qid3=msgget(MSGKEY3,02000);
msgctl(qid1,IPC_STAT,sbuf);
sbuf->msg_qbytes*=2;
msgctl(qid3,IPC_SET,sbuf);
通常一臺服務(wù)器要連接多臺客戶機，而每臺客戶機由于支持多用戶方式就會同時運行多個c_process進程。服務(wù)器如何準確地將消息送給哪一臺客戶機? 另外一臺客戶機上運行的每一個c_process進程如何正確地獲取發(fā)送給自己的消息? 這是兩個關(guān)鍵的問題。 第一個問題在前面已經(jīng)講述過,主要是通過消息的sid標志來區(qū)別的。第二個問題是這樣解決，在第①步時c_process進程先將自身的進程號pidc放在buf->cpid中，該值在以后的傳輸過程中保持不變，在第⑦步再將cpid賦值給消息類別mtype。這樣在第⑧時c_process進程就從消息隊列qid2中取走消息類別mtype等于其自身進程號pidc的消息,而不會錯將送給同一客戶機別的c_process進程的消息拿走。(圖3) ┌──────────────┐ ┌────────────┐
│Server ┌───┤ ├───┐ ┌─────┐│
│ │tcp_s │ ┌────┤tcp_c ├┐│c_process2││
│ ┌─────┐ └─┬─┤ │ ├───┤│└─────┘│
│ │s_process │┌───┴┐│ │ ┌─→┤tcp_c1││┌─────┐│
│ │服務(wù)程序 ││共享內(nèi)存││ │ │ L2├─┬─┘││c_process1││
│ └─┬─┬─┘└───┬┘│ │ │ │ ↓⑦ │└───┬┬┘│
│ ⑤↓ ↑④ ┌─┴─┤L1 │ │ │ │ └─┐ │↑⑧│
│┌──┘ │ ┌─┤tcp_s1├←──┘ │ │ │ ②↑ ││ │
││┌──┬┼┐③│ │ ├←┐L1’ │ │ │┌──┬┼┐①││ │
│││qid3│ ├←┘ ├───┤ │ │ │ ││qid1│ ├←┘│ │
││├──┼─┤ ┌┤tcp_s2├─┼───┘ │ │├──┼─┤ │ │
│││qid4│ ┼→─┘│ ├┐│┌────┐│ ││qid2│ ┼──┘ │
││└──┴┬┘⑥ └───┤│└┤ ││ │└──┴┬┘ │
│└────┘ │└→┤Client2 ││ └────┘ Client1 │
└──────────────┘ L2’└────┘└──────────┘
圖3 消息在服務(wù)器和客戶機內(nèi)傳送的過程
消息隊列與共享內(nèi)存
在運行服務(wù)器通信軟件之前應(yīng)先創(chuàng)建共享內(nèi)存和消息隊列，創(chuàng)建共享內(nèi)存的方法見文獻[3]。本文共用到四個共享內(nèi)存操作函數(shù):shm_login(cport1,cport2,client_addr)在共享內(nèi)存中申請一條記錄將三個參數(shù)登記其中,并將flag標志設(shè)為’i’表示已經(jīng)占用，同時根據(jù)記錄的位置賦值給記錄編號id。shm_logout(id)將共享內(nèi)存中第id條記錄刪除，并將后面的記錄前移,重新計算各條記錄的編號。shm_info(id,type)根據(jù)type查詢第id條記錄的內(nèi)容，比如type為GETS1時表示要查詢s_socket1的值，當type等于GETLINKN時統(tǒng)計共享內(nèi)存的記錄總數(shù)。shm_update(id,s_socket1,s_socket2,linkf1,linkf2)修改第id條記錄的內(nèi)容,如果某個參數(shù)為零則不修改這個參數(shù)，如shm_update(n,s2,0,1,0)只修改s_socket1和linkf1的值，其余內(nèi)容不作修改。在業(yè)務(wù)繁忙的情況下，有必要擴大消息隊列的存儲容量，下面的例子將消息隊列qid3的容量擴大兩倍。 來源：www.examda.com
struct msqid_ds sbuf1,*sbuf;int qid3;
sbuf=&sbuf1;
qid3=msgget(MSGKEY3,02000);
msgctl(qid1,IPC_STAT,sbuf);
sbuf->msg_qbytes*=2;
msgctl(qid3,IPC_SET,sbuf);