【文章內(nèi)容簡(jiǎn)介】 己的群組列表GetGroupMember客服端到服務(wù)端客戶端向服務(wù)端發(fā)起請(qǐng)求，獲取群組成員，參數(shù)包括群組IDCreateGroup客服端到服務(wù)端客戶端向服務(wù)器發(fā)起創(chuàng)建群組請(qǐng)求，參數(shù)包括群組名稱、群組描述、所邀請(qǐng)的群組成員等GroupMsg客服端到服務(wù)端客戶端發(fā)送的群組消息，有服務(wù)端進(jìn)行轉(zhuǎn)發(fā)，參數(shù)包括發(fā)送者ID、字體、字號(hào)、字體大小、消息內(nèi)容InviteGroupMember客服端到服務(wù)端客戶端向服務(wù)器發(fā)送邀請(qǐng)其他員工加入群組請(qǐng)求，參數(shù)包括群組ID、以及邀請(qǐng)的人員列表RemoveGroupMember客服端到服務(wù)端群組創(chuàng)建者向服務(wù)端發(fā)送移除群組成員請(qǐng)求，參數(shù)包括群組ID、要移除的群組成員IDQuitGroup客服端到服務(wù)端群組成員向服務(wù)端發(fā)送退出群組請(qǐng)求，參數(shù)包括要退出的群組IDDestoryGroup客服端到服務(wù)端服務(wù)端到客戶端群組創(chuàng)建者向服務(wù)端發(fā)送解散群組請(qǐng)求，服務(wù)端向群組成員發(fā)送群組解散通知，參數(shù)包括群組ID標(biāo)識(shí)名傳輸方向描述UpdateGroupStatus客服端到服務(wù)端服務(wù)端到客戶端群組創(chuàng)建者向服務(wù)端發(fā)送群組說明更新通知，服務(wù)端向群組成員發(fā)送群組說明更新通知，參數(shù)包括群組ID、群組說明UpLoadFile客服端到服務(wù)端群組成員向服務(wù)端發(fā)送上傳共享文件請(qǐng)求，參數(shù)包括群組ID、文件名、文件大小、傳輸文件所用的端口號(hào)DownLoadFile客服端到服務(wù)端群組成員向服務(wù)端發(fā)送下載共享文件請(qǐng)求，參數(shù)包括群組ID、文件名、傳輸文件所用的端口號(hào)GetGroupFile客服端到服務(wù)端群組成員向服務(wù)端發(fā)送獲取群共享文件列表請(qǐng)求，參數(shù)包括群組IDDeleteGroupFile客服端到服務(wù)端創(chuàng)建者通知服務(wù)端刪除群共享文件，參數(shù)包括群ID、要?jiǎng)h除的文件名Comment客服端到服務(wù)端服務(wù)端到客戶端客戶端向服務(wù)端傳輸發(fā)布的評(píng)論，服務(wù)端向客戶端發(fā)送員工對(duì)某一公告的評(píng)論。參數(shù)包括公告ID、發(fā)布者ID、評(píng)論內(nèi)容IssueAnnounce客服端到服務(wù)端客戶端向服務(wù)端發(fā)送發(fā)布公告請(qǐng)求，參數(shù)包括公告內(nèi)容GetAnnounce客服端到服務(wù)端客戶端向服務(wù)端發(fā)送獲取公告請(qǐng)求DeleteAnnounce客服端到服務(wù)端客戶端向服務(wù)端發(fā)送刪除公告請(qǐng)求，參數(shù)包括要?jiǎng)h除的公告IDGetComment客服端到服務(wù)端客戶端向服務(wù)端發(fā)送獲取公告評(píng)論請(qǐng)求，參數(shù)包括要獲取評(píng)論的公告IDStaff服務(wù)端到客戶端服務(wù)端向客戶端發(fā)送員工基本信息，參數(shù)包括員工ID、昵稱、性別、在線狀態(tài)等StaffEndpoint服務(wù)端到客戶端服務(wù)端通知在線用戶員工上線信息，包括上線員工的ID、IP、通信所需的端口號(hào)DropLine服務(wù)端到客戶端服務(wù)端通知在線用戶員工下線信息標(biāo)識(shí)名傳輸方向描述BeKickedOut服務(wù)端到客戶端服務(wù)端通知用戶被移出群組信息，包括群組IDAnnounceMent服務(wù)端到客戶端服務(wù)端向客戶端發(fā)送公司公告，參數(shù)包括發(fā)布者ID、時(shí)間、公告內(nèi)容GroupFile服務(wù)端到客戶端服務(wù)端向群組成員發(fā)送群共享文件列表，參數(shù)包括群組ID、文件名、文件大小 本節(jié)小結(jié)本節(jié)主要介紹了本系統(tǒng)客戶端與客戶端之間、客戶端與服務(wù)端之間的數(shù)據(jù)傳輸辦法，詳細(xì)設(shè)計(jì)出了數(shù)據(jù)在網(wǎng)絡(luò)上傳輸?shù)耐ㄐ艆f(xié)議。并詳細(xì)講解的通信協(xié)議數(shù)據(jù)包結(jié)構(gòu)在實(shí)現(xiàn)中的定義。 數(shù)據(jù)包傳輸模塊的設(shè)計(jì)與實(shí)現(xiàn)本模塊在整個(gè)系統(tǒng)設(shè)計(jì)中是非常重要的一個(gè)模塊，在企業(yè)即時(shí)通信系統(tǒng)中，所有功能的實(shí)現(xiàn)都必須依賴客戶端與服務(wù)端以及客戶端與客戶端的數(shù)據(jù)交換。而能否可靠、快速的進(jìn)行數(shù)據(jù)交換直接決定了其它后續(xù)業(yè)務(wù)處理模塊的正常運(yùn)行，而本模塊就承擔(dān)了數(shù)據(jù)包交換這個(gè)關(guān)鍵任務(wù)，它確保其它模塊要處理的數(shù)據(jù)是一個(gè)個(gè)完整的數(shù)據(jù)包，此模塊成功實(shí)現(xiàn)后，其它模塊將完全從繁瑣的數(shù)據(jù)包交換中解放出來，將可以完全關(guān)注于與用戶的交互以及其它業(yè)務(wù)的實(shí)現(xiàn)。 套接字的模型選擇和多線程的運(yùn)用 套接字I/O模型選擇在利用SOCKET進(jìn)行編程時(shí)，有以下幾個(gè)概念需要了解，同步、異步、阻塞、非阻塞【2】 方敏、張彤，網(wǎng)絡(luò)應(yīng)用程序設(shè)計(jì)，西安電子科技大學(xué)出版社，2005； 。同步、異步屬于通信模式，而阻塞、非阻塞屬于套接字模式。216。 同步方式通信的同步是指客戶端在發(fā)送請(qǐng)求后，需要在得到服務(wù)端的回應(yīng)后才可以發(fā)送下次請(qǐng)求。216。 異步方式與同步方式相反，在異步方式下，客戶端再發(fā)送請(qǐng)求后，不必等待服務(wù)端做出回應(yīng)即可以發(fā)送下次請(qǐng)求。216。 阻塞阻塞套接字是指在調(diào)用某一套接字的網(wǎng)絡(luò)調(diào)用時(shí)，如讀取數(shù)據(jù)、寫入數(shù)據(jù)等，所調(diào)用的函數(shù)只有在得到結(jié)果后才會(huì)返回，在得到調(diào)用結(jié)果前，該調(diào)用所在的線程會(huì)掛起，該套接字會(huì)阻塞在該網(wǎng)絡(luò)調(diào)用上，直到有數(shù)據(jù)到來或操作完成。216。 非阻塞同樣，與阻塞套接字不同的是，非阻塞套接字在進(jìn)行某一網(wǎng)絡(luò)調(diào)用時(shí)，不論調(diào)用能否立刻完成，它都會(huì)直接返回，因此對(duì)非阻塞套接字的網(wǎng)絡(luò)調(diào)用不會(huì)將線程掛起。在本系統(tǒng)開發(fā)中，如果采用一般的同步阻塞套接字，當(dāng)在發(fā)起一個(gè)不能立刻完成的網(wǎng)絡(luò)調(diào)用時(shí)，由于阻塞套接字的特性，會(huì)將發(fā)起套接字網(wǎng)絡(luò)調(diào)用的線程掛起，直接的結(jié)果就是導(dǎo)致UI主線程掛起，最后導(dǎo)致這個(gè)應(yīng)用程序阻塞，界面無響應(yīng)。所以本系統(tǒng)開發(fā)中采用了異步非阻塞套接字。而在用C進(jìn)行網(wǎng)絡(luò)編程【3】 張立，C，機(jī)械工業(yè)出版社，2007；時(shí)， Framework SDK對(duì)阻塞和非阻塞套接字機(jī)制的封裝，其中TcpClient、UdpClien中的BeginRead、BeginWrite等方法對(duì)套接字的非阻塞操作提供了很好地支持，、TcpClient、UdpClient等進(jìn)行代碼編寫。 多線程技術(shù)的運(yùn)用正如人可以同時(shí)思考、聽歌、走路，汽車可以同時(shí)轉(zhuǎn)彎、播放音樂、加速一樣，計(jì)算機(jī)也可以同時(shí)進(jìn)行許多工作，這就是多線程的思想。多線程的好處是能使多個(gè)線程在應(yīng)用程序中同時(shí)運(yùn)行，這樣就可以使多個(gè)工作并發(fā)的進(jìn)行，大大的提高了程序處理數(shù)據(jù)的速度。例如在進(jìn)行數(shù)據(jù)交換時(shí)，如果數(shù)據(jù)交換比較耗時(shí)，那就可以開啟一個(gè)線程在后臺(tái)專門負(fù)責(zé)數(shù)據(jù)交換，而這時(shí)候主線程還可以同時(shí)響應(yīng)用戶的其它操作，這樣也大大的提高了響應(yīng)速度。綜上所述，本系統(tǒng)在開發(fā)時(shí)充分的利用了多線程的諸多優(yōu)點(diǎn)，對(duì)各種耗時(shí)操作都放在了單獨(dú)的線程中進(jìn)行處理。例如在進(jìn)行文件傳輸時(shí)，由于文件傳輸是個(gè)非常耗時(shí)的工作，于是專門開啟一個(gè)線程進(jìn)行文件傳輸。這樣即可以使用戶在文件傳輸時(shí)進(jìn)行其它操作，例如聊天、發(fā)布公告、評(píng)論公告等，又可以避免在文件傳輸時(shí)將主線程阻塞導(dǎo)致界面無響應(yīng)，程序崩潰。在C下進(jìn)行多線程開發(fā)【4】 [美]Wrox Press Inc ，C高級(jí)編程(第三版)，清華大學(xué)出版社；時(shí)，提供了大量的類和接口支持多線程程序設(shè)計(jì)所需要實(shí)現(xiàn)的功能，包括線程的創(chuàng)建、停止、同步等。 數(shù)據(jù)包傳輸模塊的設(shè)計(jì) 數(shù)據(jù)包傳輸面臨的一些問題在使用TCP/IP協(xié)議【5】 羅軍舟，TCP/IP協(xié)議及網(wǎng)絡(luò)編程技術(shù)，清華大學(xué)出版社，2004；的套接字編程的非阻塞操作中，當(dāng)你發(fā)起一個(gè)BeginRead調(diào)用時(shí)，調(diào)用函數(shù)會(huì)直接返回，當(dāng)異步調(diào)用完成時(shí)，會(huì)通知你設(shè)好的回調(diào)函數(shù)進(jìn)行處理。當(dāng)你的回調(diào)函數(shù)從緩沖區(qū)讀取數(shù)據(jù)進(jìn)行處理時(shí)就會(huì)遇到一個(gè)問題，如果對(duì)方多次數(shù)據(jù)包發(fā)送時(shí)間非常接近，在你讀取數(shù)據(jù)包時(shí)數(shù)據(jù)緩沖區(qū)中就會(huì)存在多個(gè)數(shù)據(jù)包，而由于不同的數(shù)據(jù)包長度不一樣，當(dāng)你讀取時(shí)你就無法準(zhǔn)確的讀取一個(gè)數(shù)據(jù)包，你有可能讀取多個(gè)數(shù)據(jù)包或者讀取到不完整的數(shù)據(jù)包，這時(shí)候就需要某種機(jī)制來確保能夠?qū)⒕彌_區(qū)中的數(shù)據(jù)解析成一條條完整的協(xié)議。 數(shù)據(jù)包緩沖區(qū)的設(shè)計(jì)與實(shí)現(xiàn)為了能夠正確的進(jìn)行通信，并且解決上一節(jié)提到的問題，將數(shù)據(jù)包緩沖區(qū)設(shè)計(jì)如下，在系統(tǒng)中創(chuàng)建一個(gè)數(shù)據(jù)緩沖區(qū)存儲(chǔ)將要發(fā)送的數(shù)據(jù)或者接收到的數(shù)據(jù)，在緩沖區(qū)中所以數(shù)據(jù)以字節(jié)流的形式存儲(chǔ)。數(shù)據(jù)緩沖區(qū)的大小為1025，其中前1024字節(jié)存儲(chǔ)數(shù)據(jù)，第1025字節(jié)存儲(chǔ)緩沖區(qū)中原有數(shù)據(jù)長度。每次收到數(shù)據(jù)后調(diào)用ProtocolHelper的GetActualString方法從數(shù)據(jù)包緩沖區(qū)中解析得到協(xié)議數(shù)組，并將剩余的數(shù)據(jù)保存在數(shù)據(jù)包緩沖區(qū)中。在ProtocolHelper的GetActualString中用到了一些C對(duì)于正則表達(dá)式【6】 30分鐘學(xué)習(xí)正則表達(dá)式，的支持，其中首先定義了一個(gè)符合通信協(xié)議格式的匹配規(guī)則，用來對(duì)輸入的字符串input進(jìn)行匹配，proList存儲(chǔ)匹配得到的協(xié)議列表，由于可能讀取到多個(gè)數(shù)據(jù)包，所以也可能匹配得到多條協(xié)議。匹配結(jié)束后將input中的剩余部分移到input最前部，并將匹配得到的協(xié)議列表proList返回。 數(shù)據(jù)包傳輸模塊的實(shí)現(xiàn) 客戶端與服務(wù)端的數(shù)據(jù)包傳輸對(duì)于客戶端與服務(wù)端的通信，客戶端啟動(dòng)后先調(diào)用StartClient方法做一些初始化，然后在StartClient方法中投送一個(gè)異步接受操作（BeginRead），異步操作直接返回，在異步接受操作完成后，會(huì)調(diào)用OnStreamToServerReadComplete方法，在OnStreamToServerReadComplete中，先調(diào)用ProtocolHelper的GetActualString方法對(duì)數(shù)據(jù)包緩沖區(qū)中的數(shù)據(jù)進(jìn)行解析。解析完畢后繼續(xù)投送下一次異步接受操作（BeginRead），然后再將解析得到的每個(gè)數(shù)據(jù)包委托給主線程進(jìn)行處理，處理過程在主線程的HandleServerProtocol方法中。 初始化嘗試連接服務(wù)器獲取錯(cuò)誤信息，向業(yè)務(wù)邏輯層反饋開始監(jiān)聽網(wǎng)絡(luò)事件（BeginRead）調(diào)用讀響應(yīng)事件（OnStreamToServerReadComplete）將消息重新封裝，交給業(yè)務(wù)邏輯層進(jìn)行處理。（HandleServerProtocol）調(diào)用連接斷開響應(yīng)事件連接失敗有數(shù)據(jù)發(fā)來與服務(wù)器斷開連接 客戶端與服務(wù)端通信模塊的工作流程其中讀響應(yīng)事件的具體工作流程則需要更詳細(xì)的說明。在讀響應(yīng)事件中，在通過ProtocolHelper的GetActualString得到一個(gè)個(gè)完整的數(shù)據(jù)包后，會(huì)根據(jù)包頭中的信息，將包體中的信息進(jìn)行預(yù)處理，然后將預(yù)處理得到的信息（要進(jìn)行的操作、參數(shù)）重新封裝以便于交給業(yè)務(wù)邏輯層進(jìn)行處理。進(jìn)入讀響應(yīng)事件讀取緩沖區(qū)中的數(shù)據(jù)數(shù)據(jù)是否完整否對(duì)數(shù)據(jù)重新封裝（ProtocolHelper）是調(diào)用數(shù)據(jù)處理函數(shù) 讀響應(yīng)事件工作流程 客戶端與客戶端的數(shù)據(jù)包傳輸對(duì)于客戶端于客戶端的通信，客戶端于客戶端的通信采用UDP協(xié)議，客戶端啟動(dòng)后，首先調(diào)用StartClient方法，在StartClient方法中同樣先投送一個(gè)異步接受操作（BeginReceive），在異步接受操作完成后，會(huì)調(diào)用UDPRecvCallBack方法，由于在使用UDP通信的套接字中不會(huì)出現(xiàn)多個(gè)數(shù)據(jù)包疊加在一起的情況，所以在UDPRecvCallBack對(duì)收到的數(shù)據(jù)包進(jìn)行處理時(shí)，直接開啟新線程進(jìn)行處理，并投送下一次異步接受操作。線程對(duì)數(shù)據(jù)包的處理工程在HandleClientProtocol方法中。初始化監(jiān)聽網(wǎng)絡(luò)事件（BeginReceive）調(diào)用讀響應(yīng)事件（UDPRecvCallBack）有數(shù)據(jù)到來將消息重新封裝，交給業(yè)務(wù)邏輯層處理。（HandleClientProtocol）調(diào)用客戶端退出響應(yīng)事件客戶端退出 客戶端與客戶端通信模塊的工作流程 本節(jié)小結(jié)本節(jié)詳細(xì)講解了數(shù)據(jù)包傳輸模塊的設(shè)計(jì)與編碼實(shí)現(xiàn)，本模塊的實(shí)現(xiàn)為其它模塊提供了可靠、快捷的數(shù)據(jù)包傳輸保障。第4章 第四章 業(yè)務(wù)邏輯模塊 引言本章節(jié)主要講解系統(tǒng)功能的詳細(xì)實(shí)現(xiàn)，本章節(jié)的內(nèi)容是整個(gè)系統(tǒng)開發(fā)中編碼最為繁瑣、耗時(shí)最長的一部分。評(píng)價(jià)一個(gè)即時(shí)