【正文】 }以上代碼也包含了對(duì)客戶端的請(qǐng)求信息的判斷和對(duì)客戶端返回信息的生成和傳輸。 多線程對(duì)于服務(wù)器來說，多線程是必不可少的，否則它將無法處理不斷請(qǐng)求的新連接。C。本設(shè)計(jì)實(shí)現(xiàn)代碼如下： = new Thread(new ThreadStart(Serve))。//新建一個(gè)用于監(jiān)聽的線程 ()。//打開新線程不僅僅是服務(wù)器，基于P2P模式聊天的客戶端也必須支持多線程運(yùn)行，實(shí)現(xiàn)代碼與之類似，在客戶端設(shè)計(jì)說明中將不再敘述。 計(jì)時(shí)器計(jì)時(shí)器用于實(shí)現(xiàn)心跳報(bào)文的功能，服務(wù)器在啟動(dòng)以后就開始計(jì)時(shí)，每隔一定時(shí)間就向所有連入的客戶端發(fā)送信息，核心代碼如下： //用計(jì)時(shí)器檢查客戶端是否掉線 aTimer = new ()。 += new ElapsedEventHandler(CheckStatus)。 // 設(shè)置引發(fā)時(shí)間的時(shí)間間隔　此處設(shè)置為5秒（５０００毫秒） = 5000。 = true。 CheckStatus就是用于向客戶端發(fā)送檢查信息的方法，它會(huì)向遍歷連入的客戶端(alSock),然后依次向客戶端發(fā)送信息，如果發(fā)現(xiàn)客戶端沒有響應(yīng)，就會(huì)如果發(fā)現(xiàn)對(duì)方無回應(yīng)，則關(guān)閉相應(yīng)的SOCKET，并更新數(shù)據(jù)庫的用戶在線狀態(tài)，同時(shí)向該用戶的所有好友發(fā)送用戶已下線的通知。 客戶端聊天信息好友詳細(xì)信息列表圖5 注冊(cè)界面圖6 登錄、聊天、文件傳輸界面 同步套接字客戶端客戶端發(fā)起同步套接字連接，并傳送登錄或者注冊(cè)信息，由于兩者方式類似，這里僅列出用戶登錄的代碼： region 發(fā)送服務(wù)器登錄信息，并接收服務(wù)器反饋信息 public void Client() {建立SOCKET發(fā)送信息： try { IPEndPoint ServerIPEP = new IPEndPoint((),8888)。 c = new Socket(,)。 ((EndPoint)ServerIPEP)。 s = new MemoryStream()。 (s,_message)。 byte[] d=new byte[]。 (0, )。 (d, 0, )。 int i = (d, 0, , )。 } catch(Exception ex) { ()。 }以下代碼讀取了服務(wù)器返回給客戶端的信息（注冊(cè)和登錄的成功與失?。?，如果返回了登錄成功的信息，還會(huì)讀取服務(wù)器給出的FriendStruct結(jié)構(gòu)以得到用戶的好友信息： region 接收反饋信息 byte[] data = new byte[2048]。 while(true) { int rect = (data)。 byte[] chat = new byte[rect]。 (data,0,chat,0,rect)。 UMessage bumessage = (UMessage)(new MemoryStream(chat))。 string[] fg。 string _fg=。 if(==3) { } else if(==11) { fg=(39。,39。)。 int xxx=。 ff=。 for(int i=0。ixxx。i++) { string[] ems=new string[5]。 ems[0]=ff[i].account。 ems[1]=ff[i].nickname。 ems[2]=fg[(ff[i].fg)]。 ems[3]=ff[i].IP。 ems[4]=ff[i].status。 ListViewItem item = new ListViewItem(ems)。 (item)。 }CSERVER是一個(gè)用于開啟監(jiān)聽P2P信息的方法，客戶端在登錄成功以后就會(huì)立刻開啟監(jiān)聽器，才能夠?qū)崿F(xiàn)與其它客戶端的聊天： th = new Thread(new ThreadStart(CServer))。//新建一個(gè)用于監(jiān)聽其它客戶端信息的線程 ()。//打開新線程 (+登錄成功！)。 =false。 =false。 } else if (==2) { (服務(wù)器未知錯(cuò)誤)。 } else {(())。} } endregion } endregion圖7 登錄成功后的客戶端界面客戶端之間的聊天同樣使用了序列化的XML文檔，用戶在登錄成功后就會(huì)啟動(dòng)一個(gè)新的監(jiān)聽器去監(jiān)聽其它客戶端傳入的聊天信息并且進(jìn)行判斷再將其它用戶的聊天信息顯示在界面上。這里也不再闡述代碼。 采用異步套接字的文件傳輸文件傳輸是通過一個(gè)類庫實(shí)現(xiàn)的。由于文件傳輸?shù)拇a實(shí)現(xiàn)復(fù)雜，通過類庫可以大量的簡(jiǎn)化代碼，使主程序簡(jiǎn)潔易懂。,，；。核心代碼如下：:這個(gè)類實(shí)現(xiàn)了套接字的開啟和數(shù)據(jù)的傳輸using System。using 。using 。namespace { /// summary /// ClientBase摘要. /// /summary public class ClientBase { private const int BUFFERSIZE = 4*1024。 private int _port。 private string _serverIP。 private Socket _mainSoc。 private ClientInfo _info。 private AsyncCallback _dataRecievedCallback。//異步回調(diào)方法public event NetworkEventHandler DataRecieved。//定義一個(gè)事件：接收到數(shù)據(jù)時(shí)引發(fā)事件 public ClientBase(string serverIP,int port) { _serverIP = serverIP。 _port = 11000。 _mainSoc = new Socket( , , )。 _info = new ClientInfo( _mainSoc,new byte[BUFFERSIZE])。//ClientInfo包含了建立的套接字和套接字讀取的BYTE大小_dataRecievedCallback = new AsyncCallback(OnDataRecieved)。//異步回調(diào) }// 可重寫為其它超類實(shí)現(xiàn)更強(qiáng)大的功能，例如斷點(diǎn)續(xù)傳 public virtual void OnDataRecieved(byte[] data) { if (DataRecieved != null) { DataRecieved(this, new NetworkEventArgs(_info))。 } } public void Send(byte[] data) { (data)。//發(fā)送數(shù)據(jù) } public void Connect()//建立與遠(yuǎn)程主機(jī)的連接 { ( new IPEndPoint( (_serverIP), _port))。 } public void Disconnect()//關(guān)閉連接 { if () ()。 } public void WaitForData() { // 異步接收數(shù)據(jù) (,0, , _dataRecievedCallback,null)。 } private void OnDataRecieved(IAsyncResult ar) { // 垃圾回收 ()。 int byteCount = 0。 byteCount = (ar)。 if (byteCount == 0) { // 服務(wù)器斷開連接. } else { OnDataRecieved()。//接收到了數(shù)據(jù) WaitForData()。 } } }} 派生類INPClinet：using System。using 。namespace { /// summary /// INPClient的摘要. /// /summary public class INPClient : ClientBase { public INPClient(string serverIP,int port) : base(serverIP,port) {}public void SendFile(string fileName)//發(fā)送文件類，開啟一個(gè)文件流，將文件流依次讀入，再使用CLIENTBASE類中的數(shù)據(jù)發(fā)送方法進(jìn)行發(fā)送 { FileStream fs = new FileStream( fileName,)。//根據(jù)傳入的參數(shù)打開文件 byte[] im = new byte[]。//根據(jù)文件長(zhǎng)度定義一個(gè)BYTE (im,0,)。//將文件流中讀取字節(jié)塊寫入相應(yīng)緩沖區(qū) (im)。//使用基類(CLIENTBASE）的數(shù)據(jù)發(fā)送方法進(jìn)行文件傳送 } }}INPSERVER和SERVERBASE與INPCLIENT和CLIENTBASE類似，所以這里不再詳述。結(jié) 論即時(shí)通信是是網(wǎng)絡(luò)發(fā)展的必然趨勢(shì)，它的技術(shù)仍然在不斷的改進(jìn)和蓬勃發(fā)展中。本次設(shè)計(jì)雖然實(shí)現(xiàn)了簡(jiǎn)單的即時(shí)通信功能，但是從很多方面來說都是不完善的：實(shí)現(xiàn)了字符聊天卻沒有實(shí)現(xiàn)多媒體即時(shí)通信；實(shí)現(xiàn)了同步套接字聊天和異步套接字傳送文件卻沒有實(shí)現(xiàn)更科學(xué)的異步套接字聊天和同步套接字傳送文件。在本次設(shè)計(jì)中，我深刻體會(huì)到SOCKET編程的基礎(chǔ)性，多樣化。由于與網(wǎng)絡(luò)緊密聯(lián)系，SOCKET編程的也可能出現(xiàn)各種未知的問題，需要我們更深入地了解網(wǎng)絡(luò)協(xié)議和架構(gòu)，才可能做出通用性高，穩(wěn)定性高的即時(shí)通信程序。第 27 頁 共 28 頁參考文獻(xiàn)[1] Tobin. Titus, Fabio Claudio Ferracchiati. C線程參考手冊(cè)[M].：清華大學(xué)出版社,2003。[2] 黃承安,謝東文,許聰. C網(wǎng)絡(luò)應(yīng)用案例導(dǎo)航[M].北京：中國(guó)鐵道出版社,2003。[3] Andrew Krowczyk, vinod Kumar. .NET網(wǎng)絡(luò)高級(jí)編程[M].北京：清華大學(xué)出版社,2003。[4] 周存杰. Visual C .NET網(wǎng)絡(luò)核心編程[M].北京：清華大學(xué)出版社,2002。[5] 方睿,吳四九,刁仁宏. 網(wǎng)絡(luò)數(shù)據(jù)庫原理及應(yīng)用[M].四川：四川大學(xué)出版社,2005。[6] 李文志,申劍,盧方國(guó),柳正青,王宏,陳建偉. [J].(2):6872。[7] 王躍. INTERNET上大規(guī)模用戶即時(shí)通信方法研究[D].北京：北京工業(yè)大學(xué)[碩士論文]，2004。致 謝本文是在**老師的熱情關(guān)心和指導(dǎo)下完成的，她淵博的知識(shí)和嚴(yán)謹(jǐn)?shù)闹螌W(xué)作風(fēng)使我受益匪淺，對(duì)順利完成本課題起到了極大的作用。在此向他表示我最衷心的感謝！在論文完成過程中，本人還得到了其他老師和毛磊同學(xué)的熱心幫助，本人向他們表示深深的謝意！最后向在百忙之中評(píng)審本文的各位專家、老師表示衷心的感謝！