TCP/IP網(wǎng)絡(luò)重復型服務(wù)器通信軟件的設(shè)計(三)

函數(shù)connect_to_client(n,type)表示服務(wù)器與第n臺客戶機建立第type次連接。該函數(shù)由兩個子進程同時調(diào)用，分別從共享內(nèi)存中查出客戶機的IP地址和端口號后與客戶機建立連接，建立的連接分別處于各個子進程自己的數(shù)據(jù)空間中，彼此并不相通，所以又要用到共享內(nèi)存，將連接的套接字句柄登記在共享內(nèi)存中，使得與同一臺客戶機建立連接的兩個套接字形成一一對應的關(guān)系。這樣tcp_s2才可根據(jù)數(shù)據(jù)讀入的套接字去查詢出對應的寫套接字，才能正確地將處理結(jié)果發(fā)送給對應的客戶機。tcp_s1以type=1調(diào)用該函數(shù)，使用共享內(nèi)存中第n條記錄的cport1和客戶機IP地址與客戶機建立第一個連接,同時將這一連接服務(wù)器方的套接字(讀套接字)登記在共享內(nèi)存第n條記錄的s_socket1中，同時將連接標志linkf1置1。tcp_s2以type=2調(diào)用該函數(shù)，使用共享內(nèi)存中第n條記錄的cport2和客戶機IP地址與客戶機建立第二條連接，同樣也要將這一連接服務(wù)器方的套接字(寫套接字)登記在共享內(nèi)存第n條記錄的s_socket2中,將連接標志linkf2置1。因為該函數(shù)由兩個子進程同時調(diào)用，為了保持進程間同步，當type=2時必需等到第n條記錄的linkf1為1時才能繼續(xù)執(zhí)行，即必須先建立第一個連接才能再建立第二個連接，這是由客戶機通信程序決定的，因為客戶機通信程序是先監(jiān)聽并建立起第一個連接后再監(jiān)聽并建立第二個連接。子進程tcp_s1和tcp_s2通過共享內(nèi)存實現(xiàn)進程間通信,在實際應用中總是使用共享內(nèi)存的最后一條記錄。
    ②:(5991,5990,168.1.1.71) ┌─────┐①:(5991,5990) 168.1.1.21
    ┌─────────────┤ 守護進程 ├←─────────┐┌─────┐
    │ │ tcp_s │ 初始連接L0 ││ Client 1 │
    │ 共享內(nèi)存 └─────┘ │├──┬──┤
    │ id s1 linkf1 cport1 s2 linkf2 cport2 IP_Address flag ││5999│5998│
    │ ┌─┬──┬──┬──┬──┬──┬──┬─────┬─┐│└──┴──┘
    │ │1 │ 12 │ 1 │5999│ 13 │ 1 │5998│168.1.1.21│i ││ 168.1.1.22
    │ ├─┼──┼──┼──┼──┼──┼──┼─────┼─┤│┌─────┐
    │ │2 │ 14 │ 1 │5995│ 17 │ 1 │5994│168.1.1.22│i │││ Clinet 2 │
    │ ├─┼──┼──┼──┼──┼──┼──┼─────┼─┤│├──┬──┤
    └→┤3 │0/22│0/1 │5991│0/23│0/1 │5990│168.1.1.71│i│││5995│5994│
    └─┴──┼──┴┬─┴──┼──┴┬─┴─────┴─┘│──┴──┘
    ⑤:(22,1)↑ │ ↑ ↓⑥:(5990,168.1.1.71)│ 168.1.1.71
    │ │ │ └─────┐ │┌─────┐
    │ │ │⑧:(23,1) ┌──┴┬─┐ └┤ Client 3 │
    │ │ └──────┤ │13│ ├──┬──┤
    │ ↓③:(5991,168.1.1.71) │通信 ├─┤ │5991│5990│
    │┌──┴┬─┐ │子進程│17│ └┬─┴─┬┘
    └┤ │12│ │tcp_s2├─┤ │ L2↑⑦
    │通信 ├─┤ │ │23├───┼───┘
    │子進程│14│ └───┴─┘ │
    │tcp_s1├─┤L1 (讀套接字22) (寫套接字23) │
    │ │22├←─────────────────┘
    └───┴─┘④
    圖1 服務(wù)器和客戶機建立連接的過程
    這里必須置套接字的讀取標志位O_NDELAY，這樣在讀數(shù)據(jù)時如果沒有數(shù)據(jù)可讀read函數(shù)就不會堵塞住，這是重復型服務(wù)器能夠?qū)崿F(xiàn)的關(guān)鍵。因為UNIX系統(tǒng)將套接字與普通文件等同處理，所以就能夠使用設(shè)置文件標志的函數(shù)fcntl來處理套接字。 來源：www.examda.com
    int connect_to_client(n,type){
    u_long client_addr; /* type=1,2 */
    int s2,cport,sport,i;
    if(type==2){
    for(;;) if(shm_info(n,GETLINKF1)==1) break;
    }
    sport=6000-1;s2=rresvport(&sport);
    cport=shm_info(n,GETCPORT1+type-1);
    client_addr=shm_info(n,GETCADDR);
    peeraddr_in.sin_port=htons((short)cport);
    peeraddr_in.sin_addr.s_addr=client_addr;
    connect(s2,(struct sockaddr *)&peeraddr_in,sizeof(peeraddr_in));
    flags=fcntl(s2,F_GETFL,0);
    fcntl(s2,F_SETFL,flags|O_NDELAY);
    if(type==1) i=shm_update(n,s2,0,1,0);
    if(type==2) i=shm_update(n,0,s2,0,1);
    return(i);
    }
    ⑺ tcp_c在接收到服務(wù)器的兩個連接后,生成子進程tcp_c1調(diào)用函數(shù)Client_Receive用于接收數(shù)據(jù)，tcp_c則調(diào)用函數(shù)Client_Send用于發(fā)送數(shù)據(jù)。如果函數(shù)Client_Receive從循環(huán)中退出，就說明服務(wù)器通信軟件已退出，于是子進程在退出之前要先殺掉父進程。
    cpid=getpid(); /* 父進程的進程號 */
    if(fork()==0){ /* tcp_c1 */
    close(s_w);
    Client_Receive();
    sprintf(cmdline,"kill -9 %d",cpid);
    system(cmdline);