資源描述:
《多線程通訊-TCP聊天程序-VC++》由會員上傳分享,免費在線閱讀,更多相關(guān)內(nèi)容在教育資源-天天文庫。
1、操作系統(tǒng)課程設(shè)計——多線程通訊-TCP聊天程序-VC++操作系統(tǒng)課程設(shè)計任務(wù)書一、設(shè)計題目:多機進程通信應(yīng)用Socket進程通信技術(shù)編寫聊天室程序,實現(xiàn)基于服務(wù)器的并發(fā)多機信息轉(zhuǎn)發(fā)。如果各客戶端在線則可以實時聊天、發(fā)送接收文件,如果某客戶端離線,則發(fā)送給他的消息可由服務(wù)器端進行內(nèi)容緩存,待重新連線后可以自動接收通過服務(wù)器轉(zhuǎn)發(fā)的信息或文件。緩存與轉(zhuǎn)發(fā)的控制算法可參考操作系統(tǒng)課程中生產(chǎn)者消費者進程同步方法、緩沖池技術(shù)等相關(guān)理論。二、設(shè)計思路和功能的詳細描述采用TCP協(xié)議,所以屬于客戶機/服務(wù)器模式,因此需要聊天服務(wù)器端和
2、聊天客戶端兩個程序,實現(xiàn)的功能是:任意一臺裝有客戶端程序的計算機都可以通過服務(wù)器端的IP地址與服務(wù)器相連,然后進入聊天室與連接到服務(wù)器的其他客戶進行聊天。當客戶聊天結(jié)束時,可以點斷開與服務(wù)器斷開連接,以釋放進程讓其他等待的客戶進入聊天室,本聊天室最大同時支持50個客戶端的連接,如果服務(wù)器配置較高可以修改程序來增加同時連接數(shù)。三、采用的方法、技術(shù)、運行環(huán)境及其配置本聊天程序采用TCP協(xié)議,用VC++編寫,屬于客戶機/服務(wù)器模式。采用了多線程的機制。其中使用windowsSockets實現(xiàn)多臺計算機(多個進程)間的通信,
3、SOCKET實際在計算機中提供了一個通信端口,可以通過這個端口與任何一個具有SOCKET接口的計算機通信。應(yīng)用程序在網(wǎng)絡(luò)上傳輸,接收的信息都通過這個SOCKET接口來實現(xiàn)。在客戶機/服務(wù)器模式中客戶應(yīng)用程序向服務(wù)器程序請求服務(wù)。一個服務(wù)程序通常在一個眾所周知的地址監(jiān)聽對服務(wù)的請求,也就是說,服務(wù)進程一直處于休眠狀態(tài),直到一個客戶對這個服務(wù)的地址提出了連接請求。在這個時刻,服務(wù)程序被“驚醒”并且為客戶提供服務(wù)即對客戶的請求作出適當?shù)姆磻?yīng)。本聊天程序就是基于這中思想實現(xiàn)的,程序分為兩大部分:TCP聊天服務(wù)器端和TCP聊天
4、客戶端。兩者都擁有各自的SOCKET接口,其中服務(wù)器端SOCKET接口需要綁定到固定地址上(實現(xiàn)語句:ock=Socket(AF_INET,SOCK_STREAM,0);),等待客戶端的連接(實現(xiàn)語句:listen(sock,5);)。等待客戶端的連接的過程就是通過多進程機制來實現(xiàn)的。聊天程序是在VISUALC++6.0上編譯實現(xiàn)的,在WINDOWS2000,XP上測試運行成功。對客戶計算機配置無特殊要求,由于所設(shè)置的最大連接進程為50,所以對服務(wù)器要求也不高。四、關(guān)鍵源程序及其詳細的注釋<一>、服務(wù)器端:1、Soc
5、ket初始化//初始化對話框BOOLCCSocketDlg::OnInitDialog(){count=0;m_list.InsertColumn(0,"消息");m_list.SetColumnWidth(0,435);m_edit.SetLimitText(99);for(inti=0;i<50;i++)//初始化SOCKET數(shù)組msgsock=NULL;serv.sin_addr.s_addr=htonl(INADDR_ANY);//設(shè)定地址serv.sin_family=AF_INET;serv.sin_po
6、rt=5000;//htons(5000);addlen=sizeof(serv);m_button.EnableWindow(FALSE);sock=socket(AF_INET,SOCK_STREAM,0);//創(chuàng)建socketif(bind(sock,(sockaddr*)&serv,addlen))//綁定{m_edit.SetWindowText("綁定錯誤");}else{m_edit.SetWindowText("服務(wù)器創(chuàng)建成功");//顯示提示信息,表示服務(wù)器創(chuàng)建成功listen(sock,5);//
7、開始偵聽AfxBeginThread(&thread,0);//調(diào)用線程}returnTRUE;}2、接收線程//服務(wù)器線程UINTthread(LPVOIDp){charbuff[100];//定義緩沖區(qū)CSizesize;size.cx=0;size.cy=30;ints=1,msgcount,loop=1,flag=0;CCSocketDlg*dlg=(CCSocketDlg*)AfxGetApp()->GetMainWnd();//獲得當前運行對話框句柄msgcount=dlg->getcount();//獲
8、取還沒有被占用的數(shù)組序號if(msgcount==-1)//如果不等于-1,則表示,還有空缺SOCKETloop=0;if(loop){s=1;dlg->msgsock[msgcount]=accept(dlg->sock,(sockaddr*)&(dlg->serv),&(dlg->addlen));//用空缺的SOCKET等待客戶連接if(