基于VxWorks的全I(xiàn)P開(kāi)發(fā)平臺(tái)進(jìn)程通信處理機(jī)制

①點(diǎn)對(duì)點(diǎn)通信。每個(gè)需要通信的處理器之間維護(hù)一條TCP連接，所有連接組成連接表。進(jìn)程通過(guò)接口發(fā)送的消息首先掛在相應(yīng)的連接的發(fā)送隊(duì)列中。通信任務(wù)在連接表中的所有連接上監(jiān)測(cè)鏈路狀態(tài)，在連接寫(xiě)就緒時(shí)依序發(fā)送連接發(fā)送隊(duì)列中的消息，在連接讀就緒時(shí)接收連接上的消息并向上層轉(zhuǎn)發(fā)，在連接異常時(shí)告警并恢復(fù)鏈路狀態(tài)，在檢查報(bào)到達(dá)的時(shí)候?qū)㈡溌穪G失的檢查報(bào)清零。
②多對(duì)多通信。使用一個(gè)公用的UDP套接口，發(fā)送時(shí)指定協(xié)議類(lèi)型為不可靠傳輸協(xié)議的時(shí)候，根據(jù)邏輯地址查找到對(duì)應(yīng)的IP地址，直接從UDP套接口上發(fā)送出去。組播任務(wù)同樣守護(hù)在UDP套接口上，當(dāng)套接口讀就緒的時(shí)候接收消息并向上層轉(zhuǎn)發(fā)。
③組播。采用靜態(tài)分組的方法，每一個(gè)組播組對(duì)應(yīng)一個(gè)到組播地址，所有這種對(duì)應(yīng)關(guān)系組成分組表。每一處理器可以加入特定組播組，也可以隨時(shí)脫離組播組。組播任務(wù)守護(hù)在組播組表的組播套接口上，在套接口讀就緒時(shí)接收消息并向上層轉(zhuǎn)發(fā)。進(jìn)程直接在組播套接字上發(fā)送消息。
④廣播。分組表中有一個(gè)特殊項(xiàng)用作廣播，該組成員為系統(tǒng)內(nèi)所有處理器，組播任務(wù)在該項(xiàng)上守護(hù)，進(jìn)行和上面相同的處理。
⑤處理器內(nèi)廣播。向同一個(gè)進(jìn)程類(lèi)型的實(shí)例分別發(fā)送一條消息的拷貝。
消息的派發(fā)過(guò)程如圖4所示。調(diào)度任務(wù)從自己的郵箱接收消息，并負(fù)責(zé)向各個(gè)進(jìn)程的消息隊(duì)列中派發(fā)，在派發(fā)的過(guò)程中區(qū)別消息的類(lèi)型。根據(jù)消息類(lèi)型描述處理流程，派發(fā)同步應(yīng)答消息時(shí)，將目標(biāo)進(jìn)程轉(zhuǎn)入就緒狀態(tài)，設(shè)置解除阻塞原因?yàn)閼?yīng)答到；派發(fā)同步超時(shí)消息時(shí)，將目標(biāo)進(jìn)程轉(zhuǎn)入就緒狀態(tài)，設(shè)置解除阻塞原因?yàn)橥匠瑫r(shí)；派發(fā)延時(shí)結(jié)束消息時(shí)，將目標(biāo)進(jìn)程轉(zhuǎn)入就緒狀態(tài)，設(shè)置解除阻塞原因?yàn)檠訒r(shí)結(jié)束；派發(fā)其他類(lèi)型的消息時(shí)，將消息掛到目標(biāo)進(jìn)程消息隊(duì)列尾部，如果目標(biāo)進(jìn)程因?yàn)闆](méi)有消息而阻塞，將目標(biāo)進(jìn)程轉(zhuǎn)入就緒狀態(tài)。

2．2 TCP連接狀態(tài)機(jī)設(shè)計(jì)
TCP連接的狀態(tài)記錄在TCP連接控制塊的狀態(tài)域里面，本端上層應(yīng)用發(fā)起TCP連接建立請(qǐng)求時(shí)，TCP連接的狀態(tài)遷移如圖5所示。①?zèng)]有激活狀態(tài)：接收到來(lái)自上層應(yīng)用的連接發(fā)起請(qǐng)求后，向?qū)Χ税l(fā)起連接，進(jìn)入等待寫(xiě)就緒狀態(tài)。②等待寫(xiě)就緒狀態(tài)：如果接收到本端套接字的寫(xiě)就緒事件，向?qū)Χ税l(fā)送檢查報(bào)，進(jìn)入等待對(duì)端檢查報(bào)狀態(tài)；如果接收到對(duì)端連接請(qǐng)求(連接請(qǐng)求1)并且對(duì)端IP地址比自己的IP地址小，拒絕請(qǐng)求，繼續(xù)等待；如果接收到對(duì)端連接請(qǐng)求(連接請(qǐng)求2)并且對(duì)端IP地址比自己的IP地址大，接收請(qǐng)求，終止本端發(fā)起的連接過(guò)程，啟動(dòng)連接接收的狀態(tài)機(jī)。③等待檢查報(bào)狀態(tài)：收到檢查報(bào)后，連接成功，進(jìn)入工作狀態(tài)；如果接收到對(duì)端連接請(qǐng)求(連接請(qǐng)求1)并且對(duì)端IP地址比自己的IP地址小，拒絕請(qǐng)求，繼續(xù)等待；如果接收到對(duì)端連接請(qǐng)求(連接請(qǐng)求2)并且對(duì)端IP地址比自己的IP地址大，接收請(qǐng)求，終止本端發(fā)起的連接過(guò)程，啟動(dòng)連接接收的狀態(tài)機(jī)。④工作狀態(tài)：如果收到數(shù)據(jù)收發(fā)請(qǐng)求，則進(jìn)行數(shù)據(jù)收發(fā)，并保持狀態(tài)；如果收到連接的關(guān)閉請(qǐng)求，則關(guān)閉本連接，轉(zhuǎn)到連接沒(méi)有激活狀態(tài)；如果收到對(duì)端的連接建立請(qǐng)求，則啟動(dòng)連接的接收狀態(tài)機(jī)，并保持現(xiàn)在的連接在工作狀態(tài)。

在上述各種狀態(tài)下收到連接異常的信息都異常關(guān)閉連接，轉(zhuǎn)到連接沒(méi)有激活狀態(tài)。

本端收到對(duì)端發(fā)起TCP連接建立請(qǐng)求時(shí)，TCP連接的狀態(tài)遷移如圖6所示。①?zèng)]有激活狀態(tài)：接收到對(duì)端的連接請(qǐng)求后，進(jìn)入等待檢查報(bào)狀態(tài)；②等待檢查報(bào)狀態(tài)：如果接收到對(duì)端的檢查報(bào)，進(jìn)入等待寫(xiě)就緒狀態(tài)；如果接收到對(duì)端連接請(qǐng)求，接收請(qǐng)求，終止上次的連接過(guò)程，進(jìn)入等待檢查報(bào)狀態(tài)；③等待寫(xiě)就緒狀態(tài)：如果收到寫(xiě)就緒事件，向?qū)Χ税l(fā)送檢查報(bào)，連接成功，如果以前存在工作的鏈路，關(guān)閉該鏈路，本鏈路投入工作狀態(tài)；如果接收到對(duì)端連接請(qǐng)求，接收請(qǐng)求，終止本次連接過(guò)程，切換到等待檢查報(bào)狀態(tài)；④工作狀態(tài)：如果收到數(shù)據(jù)收發(fā)請(qǐng)求，則進(jìn)行數(shù)據(jù)收發(fā)，并保持狀態(tài)；如果收到連接的關(guān)閉請(qǐng)求，則關(guān)閉本連接，轉(zhuǎn)到連接沒(méi)有激活狀態(tài)；如果收到對(duì)端的連接建立請(qǐng)求，則啟動(dòng)備份連接的建立狀態(tài)機(jī)，并保持狀態(tài)。
在上述各種狀態(tài)下收到連接異常的信息都異常關(guān)閉連接。