基于UDP協(xié)議的聊天程序設(shè)計(jì)報(bào)告

1、-. z.編號(hào)：計(jì)算機(jī)網(wǎng)絡(luò)課程設(shè)計(jì)題 目： 基于UDP的聊天程序 系 別： 計(jì)算機(jī)科學(xué)與工程學(xué)院 摘要隨著網(wǎng)絡(luò)技術(shù)的開展及人們生活的需求，網(wǎng)絡(luò)聊天已越來越受到人們的青睞 。網(wǎng)絡(luò)聊天已經(jīng)成為人們工作生活中傳遞信息、交流感情的重要工具，給人們帶來了很大的方便。 本課題是開發(fā)一個(gè)基于UDP的局域網(wǎng)聊天系統(tǒng),運(yùn)用軟件工程的設(shè)計(jì)流程，綜合運(yùn)用數(shù)據(jù)庫編程技術(shù)、Windows程序設(shè)計(jì)技術(shù)、網(wǎng)絡(luò)通訊技術(shù)，此網(wǎng)絡(luò)聊天工具采用客戶端/效勞器C/S模式,客戶端采用UDP與效勞器連接，客戶端與客戶端之間通過UDP互相通訊。效勞器端具有效勞器端口設(shè)置，此聊天工具能實(shí)現(xiàn)多人聊天功能，適用于局域網(wǎng)使用的網(wǎng)絡(luò)聊天工具，其操作

2、簡單，靈活性好，運(yùn)行也比擬穩(wěn)定。關(guān)鍵詞：網(wǎng)絡(luò)通訊；客戶端/效勞器模型；用戶數(shù)據(jù)報(bào)協(xié)議；套接字-. z.一、需求分析1.1 課程設(shè)計(jì)目的 開發(fā)一個(gè)專用于實(shí)現(xiàn)兩臺(tái)計(jì)算機(jī)之間即時(shí)通訊的軟件以方便兩臺(tái)計(jì)算機(jī)之間信息的交流。在連接并通信時(shí)尤其是近程的即時(shí)通訊徹底的脫離了遠(yuǎn)程的效勞器防止了和遠(yuǎn)程效勞器連接時(shí)過多的浪費(fèi)網(wǎng)絡(luò)資源。并且防止了效勞器忙或與效勞器無法連接時(shí)浪費(fèi)過多時(shí)間用于和效勞器建立連接因此這個(gè)軟件是極具適應(yīng)性和實(shí)用性的即時(shí)通訊軟件本次課程設(shè)計(jì)的目的是學(xué)習(xí)基于UDP協(xié)議實(shí)現(xiàn)網(wǎng)絡(luò)聊天程序已到達(dá)學(xué)會(huì)面向無連接方式的程序設(shè)計(jì)方法并理解網(wǎng)絡(luò)編程中面向無連接的概念。 1.2 課程設(shè)計(jì)的容 用戶數(shù)據(jù)報(bào)UDP是

3、一個(gè)無連接協(xié)議使用這種協(xié)議時(shí)并不需要在兩臺(tái)計(jì)算機(jī)之間建立固定的連接也就是說通信雙方?jīng)]有效勞器和客戶機(jī)之分它們之間進(jìn)展的是對(duì)等通信所以它的優(yōu)勢很明顯是現(xiàn)代通信不可或缺的一局部。所以利用它的優(yōu)勢設(shè)計(jì)一個(gè)可以聊天的軟件實(shí)現(xiàn)兩臺(tái)計(jì)算機(jī)間的即時(shí)通訊。 1.3 課程設(shè)計(jì)要求 基于UDP協(xié)議實(shí)現(xiàn)的聊天和一對(duì)多的聊天提供友好的用戶界面便于用戶進(jìn)展操作。 二 . UDP協(xié)議的理解：UDP協(xié)議是英文UserDatagramProtocol的縮寫，即用戶數(shù)據(jù)報(bào)協(xié)議，主要用來支持那些需要在計(jì)算機(jī)之間傳輸數(shù)據(jù)的網(wǎng)絡(luò)應(yīng)用。包括網(wǎng)絡(luò)視頻會(huì)議系統(tǒng)在的眾多的客戶/效勞器模式的網(wǎng)絡(luò)應(yīng)用都需要使用UDP協(xié)議。UDP協(xié)議從問世至今已

4、經(jīng)被使用了很多年，雖然其最初的光榮已經(jīng)被一些類似協(xié)議所掩蓋，但是即使是在今天，UDP仍然不失為一項(xiàng)非常實(shí)用和可行的網(wǎng)絡(luò)傳輸層協(xié)議。UDP協(xié)議直接位于IP網(wǎng)際協(xié)議協(xié)議的頂層。UDP協(xié)議的主要作用是將網(wǎng)絡(luò)數(shù)據(jù)流量壓縮成數(shù)據(jù)報(bào)的形式。一個(gè)典型的數(shù)據(jù)報(bào)就是一個(gè)二進(jìn)制數(shù)據(jù)的傳輸單位。每一個(gè)數(shù)據(jù)報(bào)的前8個(gè)字節(jié)用來包含報(bào)頭信息，剩余字節(jié)則用來包含具體的傳輸數(shù)據(jù)。UDP協(xié)議使用端口號(hào)為不同的應(yīng)用保存其各自的數(shù)據(jù)傳輸通道。正是采用這一機(jī)制實(shí)現(xiàn)對(duì)同一時(shí)刻多項(xiàng)應(yīng)用同時(shí)發(fā)送和接收數(shù)據(jù)的支持。數(shù)據(jù)發(fā)送一方可以是客戶端或效勞器端將UDP數(shù)據(jù)報(bào)通過源端口發(fā)送出去，而數(shù)據(jù)接收一方則通過目標(biāo)端口接收數(shù)據(jù)。有的網(wǎng)絡(luò)應(yīng)用只能使用預(yù)

5、先為其預(yù)留或注冊的靜態(tài)端口；而另外一些網(wǎng)絡(luò)應(yīng)用則可以使用未被注冊的動(dòng)態(tài)端口。因?yàn)閁DP報(bào)頭使用兩個(gè)字節(jié)存放端口號(hào)，所以端口號(hào)的有效圍是從0到65535。一般來說，大于49151的端口號(hào)都代表動(dòng)態(tài)端口。數(shù)據(jù)報(bào)的長度是指包括報(bào)頭和數(shù)據(jù)局部在的總的字節(jié)數(shù)。因?yàn)閳?bào)頭的長度是固定的，所以該域主要被用來計(jì)算可變長度的數(shù)據(jù)局部又稱為數(shù)據(jù)負(fù)載。數(shù)據(jù)報(bào)的最大長度根據(jù)操作環(huán)境的不同而各異。從理論上說，包含報(bào)頭在的數(shù)據(jù)報(bào)的最大長度為65535字節(jié)。不過，一些實(shí)際應(yīng)用往往會(huì)限制數(shù)據(jù)報(bào)的大小，有時(shí)會(huì)降低到8192字節(jié)。UDP協(xié)議使用報(bào)頭中的校驗(yàn)值來保證數(shù)據(jù)的平安。校驗(yàn)值首先在數(shù)據(jù)發(fā)送方通過特殊的算法計(jì)算得出，在傳遞到接

6、收方之后，還需要再重新計(jì)算。如果*個(gè)數(shù)據(jù)報(bào)在傳輸過程中被第三方篡改或者由于線路噪音等原因受到損壞，發(fā)送和接收方的校驗(yàn)計(jì)算值將不會(huì)相符，由此UDP協(xié)議可以檢測是否出錯(cuò)。UDP協(xié)議并不提供數(shù)據(jù)傳送的保證機(jī)制。如果在從發(fā)送方到接收方的傳遞過程中出現(xiàn)數(shù)據(jù)報(bào)的喪失，協(xié)議本身并不能做出任何檢測或提示，由于排除了信息可靠傳遞機(jī)制，將平安和排序等功能移交給上層應(yīng)用來完成，極大降低了執(zhí)行時(shí)間，使速度得到了保證。三. UDP協(xié)議特點(diǎn) 1、UDP傳送數(shù)據(jù)前并不與對(duì)方建立連接，即UDP是無連接的，在傳輸數(shù)據(jù)前，發(fā)送方和接收方相互交換信息使雙方同步。 2、UDP不對(duì)收到的數(shù)據(jù)進(jìn)展排序，在UDP報(bào)文的首部中并沒有關(guān)于數(shù)據(jù)

7、順序的信息如TCP所采用的序號(hào)，而且報(bào)文不一定按順序到達(dá)的，所以接收端無從排起。 3、UDP對(duì)接收到的數(shù)據(jù)報(bào)不發(fā)送確認(rèn)信號(hào)，發(fā)送端不知道數(shù)據(jù)是否被正確接收，也不會(huì)重發(fā)數(shù)據(jù)。 4、UDP傳送數(shù)據(jù)較TCP快速，系統(tǒng)開銷也少。 5、由于缺乏擁塞控制congestion control，需要基于網(wǎng)絡(luò)的機(jī)制來減小因失控和高速UDP流量負(fù)荷而導(dǎo)致的擁塞崩潰效應(yīng)。換句話說，因?yàn)閁DP發(fā)送者不能夠檢測擁塞，所以像使用包隊(duì)列和丟棄技術(shù)的路由器這樣的網(wǎng)絡(luò)根本設(shè)備往往就成為降低UDP過大通信量的有效工具。數(shù)據(jù)報(bào)擁塞控制協(xié)議(DCCP)設(shè)計(jì)成通過在諸如流媒體類型的高速率UDP流中增加主機(jī)擁塞控制來減小這個(gè)潛在的問題。

8、 從以上特點(diǎn)可知，UDP提供的是無連接的、不可靠的數(shù)據(jù)傳送方式，是一種盡力而為的數(shù)據(jù)交付效勞。四. 基于C/S的多客服端相互通信原理分析：在C/S模式中，它是在分散式 ，集中式，以及分布式根底上開展起來的一種新模型，目前大多數(shù)網(wǎng)絡(luò)通信以及應(yīng)用都屬于這種模型，C/S模式將一個(gè)網(wǎng)絡(luò)事務(wù)分為兩局部，一局部是客戶端(Client,他為用戶提供網(wǎng)絡(luò)請求效勞的接口，另一局部是效勞端Server,它負(fù)責(zé)承受用戶對(duì)效勞的請求，并將這些效勞透明的提供應(yīng)用戶，既適用于實(shí)際應(yīng)用的程序，又實(shí)用于真正的計(jì)算裝置，舉例來說，我們到飯店吃飯時(shí)，要首先提出請求吃什么，屬于客戶端，飯店效勞員根據(jù)請求提供相應(yīng)的效勞，屬于效勞端，

9、至于相應(yīng)的飯菜是由哪一個(gè)廚師來做，則由飯店的效勞員去聯(lián)系，而客戶端只需要和效勞器打交道就行了，從程序?qū)崿F(xiàn)上來說，客戶端和效勞器打交道實(shí)際上是兩個(gè)進(jìn)程打交道，效勞端啟動(dòng)server進(jìn)程，并等待客戶端與其聯(lián)系，而客戶端則啟動(dòng)客戶進(jìn)程和效勞器打交道。當(dāng)效勞器進(jìn)程處理完一個(gè)客服進(jìn)程請求的信息之后，由接著等待其他客戶的請求。套接字編程原理分析：圖1.1 套接字編程原理圖注釋：socket()，使用前創(chuàng)立一個(gè)新的套接字；bind()，將套接字地址與所創(chuàng)立的套接字號(hào)聯(lián)系起來；send()與recv()，數(shù)據(jù)的發(fā)送與接收；closesocket()，關(guān)閉套接字。六、概要設(shè)計(jì)效勞器客戶機(jī)甲客戶機(jī)乙客戶機(jī)丙圖2.

10、1 整體框架設(shè)計(jì)圖效勞器端主要實(shí)現(xiàn)的功能是啟動(dòng)一個(gè)監(jiān)聽的進(jìn)程，開放自己的端口號(hào)為7777，不斷的監(jiān)聽是否有新的客服端進(jìn)程向自己發(fā)送連接請求，為每一個(gè)主動(dòng)連接自己的客戶端設(shè)置一個(gè)ID號(hào)設(shè)置一個(gè)threads的容器用來管理客戶端的線程。與客戶端建立連接，實(shí)現(xiàn)socket通信，對(duì)于效勞器端是先承受數(shù)據(jù)流然后再發(fā)送數(shù)據(jù)流，客服端發(fā)送過來的信息經(jīng)效勞器端然后轉(zhuǎn)發(fā)到其他所有的客戶端，效勞器端相當(dāng)于中間的橋梁?？蛻舳艘笾饕獙?shí)現(xiàn)的功能是建立一個(gè)圖形的界面，用于顯示聊天信息等，并且建立與效勞器端的通信，主動(dòng)的向效勞器端發(fā)送連接請求，然后對(duì)輸入文本框注冊事件監(jiān)聽并且發(fā)送給客服端，不斷的監(jiān)聽效勞器端發(fā)來的信息，然

11、后顯示出來。七、詳細(xì)設(shè)計(jì)效勞器端：創(chuàng)立效勞端接口建立一個(gè)seversocket的類svsocket創(chuàng)立一個(gè)容器用來管理客戶端進(jìn)程開場監(jiān)聽，監(jiān)聽是否有客戶端連接，有的話與其建立連接分配ID監(jiān)聽線程監(jiān)聽端口是否有消息傳入如果有的話接收信息再將信息發(fā)送到其他的所有的客服端當(dāng)*客戶離開，完畢他與其他人的通信為客戶端連接創(chuàng)立線程沉著器vector中刪除該線程表示該線程已經(jīng)離開聊天室，完畢兩者之間連接圖7.1 效勞器端整體設(shè)計(jì)流程圖客戶端建立一個(gè)seversocket的類，并且創(chuàng)立一個(gè)vector用來管理客戶端的線程，然后就開場檢測，如果有客戶端請求與效勞器連接就與其建立socket連接，創(chuàng)立進(jìn)程設(shè)置ID

12、，告訴其他的客戶端有新的客戶端接入，然后開場監(jiān)聽所有的客戶端線程如果有信息通過端口進(jìn)入就承受然后再發(fā)送給其他客戶端，如果有客戶端退出，就會(huì)告訴其他的客戶端并且關(guān)閉與該客戶端的socket連接，然后在vector里面刪除相應(yīng)的線程。主界面效勞器界面，當(dāng)運(yùn)行效勞器端則出現(xiàn)運(yùn)行客服端登錄心得體會(huì)：經(jīng)過兩個(gè)星期的學(xué)習(xí)和實(shí)踐，我也算是順利的完成了計(jì)算機(jī)網(wǎng)絡(luò)課程設(shè)計(jì)，同時(shí)對(duì)計(jì)算機(jī)網(wǎng)絡(luò)有一個(gè)大致的了解，在實(shí)踐過程中遇到了很多的困難，感覺自己很難將理論與實(shí)踐相結(jié)合，覺得我們學(xué)習(xí)的那些知識(shí)也派不上用場，通過這次課設(shè)，我深刻的認(rèn)識(shí)到實(shí)踐與理論必須 要想結(jié)合才能使所學(xué)的知識(shí)變成可用的，通過自己的努力和教師同學(xué)們的幫

13、助，多了一種對(duì)待問題的角度；我也發(fā)現(xiàn)了我所學(xué)知識(shí)不扎實(shí)，只是走馬觀花的應(yīng)付考試，在以后的學(xué)習(xí)中需要時(shí)刻的告誡自己，踏踏實(shí)實(shí)做好每一步。本次課程設(shè)計(jì)是利用java語言編寫的，雖說自己以前接觸過這種語言，但是經(jīng)過這兩周的學(xué)習(xí)，我受益匪淺。首先，我進(jìn)一步弄懂了JAVA語言的編程方法和原則，并學(xué)會(huì)了編寫java程序。其次，使我更深層次的理解到JAVA語言是一種面向?qū)ο蟮恼Z言，具有可視化編程的特點(diǎn)且代碼具有可移植等特點(diǎn)。本次課程設(shè)計(jì)是實(shí)現(xiàn)一個(gè)UDP即時(shí)通訊程序。經(jīng)過編寫程序和運(yùn)行，調(diào)試程序，我對(duì)java語言有了更深的了解。另外，使我對(duì)UDP協(xié)議的特點(diǎn)和工作過程有了更深的了解。UDP協(xié)議提供無連接的、不可

14、靠的效勞。它工作于傳輸層，是傳輸層的重要協(xié)議之一。最后，UDP協(xié)議是利用客戶端和效勞器端模型來實(shí)現(xiàn)傳輸?shù)摹?本次課程設(shè)計(jì)使我明白了知識(shí)的重要性，同時(shí)也更加懂得實(shí)踐更不可少。我們要經(jīng)常把所學(xué)的知識(shí)運(yùn)用到實(shí)踐，這樣，才能充分的融會(huì)貫穿。同時(shí)，也使我認(rèn)識(shí)到自己動(dòng)手能力太差，為我以后的學(xué)習(xí)和開展提供了一個(gè)警鐘！本次課程設(shè)計(jì)的過程中，雖然遇到了不少問題，但最后還是成功的完成了。這次課設(shè)對(duì)于我而言是有很大的收獲，懂得獨(dú)立尋找資料學(xué)習(xí)，這是最大的收獲，在以后的工作中肯定會(huì)面臨不懂得問題，有了這次課設(shè)的經(jīng)歷，就能夠去獨(dú)立學(xué)習(xí)并解決困難。主要代碼package server; import java.awt.C

15、ontainer; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.awt.event.WindowAdapter; import java.awt.event.WindowEvent; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOE*ception; import; import; import .ServerSocket; import .Socket

16、; import java.util.ArrayList; import java.util.Date; import java*.swing.utton; import java*.swing.JFrame; import; import java*.swing.JOptionPane; import; import java*.swing.JScrollPane; import java*.swing.JTe*tArea; import java*.swing.JTe*tField; publicclassservere*tends JFrame private JTe*tArea all

17、msg; private JTe*tField currnum,totalnum,copyright,chatmsg; private utton send; private JScrollPane js; intnum1,num2,port;/* - num1:當(dāng)前在線人數(shù) num2:總上線人數(shù) port:效勞端口號(hào) -*/private ServerSocket ss; ArrayListlists;/存放所有在線用戶 public server() super(聊天室效勞器端); this.setSize(310,660); this.setLocation(200,50); lists

18、 = newArrayList(); num1 = num2 =0; port = 7777; currnum = new JTe*tField( 當(dāng)前在線人數(shù)： +num1); currnum.setEnabled(false); totalnum = new JTe*tField( 上線總?cè)藬?shù)： +num2); totalnum.setEnabled(false); allmsg = new JTe*tArea(); allmsg.append( - 系統(tǒng)消息 -n); allmsg.setEditable(false); allmsg.setLineWrap(true); /允許自動(dòng)換行

19、 js = new JScrollPane(allmsg);/為JTe*tArea添加滾動(dòng)條 chatmsg = new JTe*tField(在此輸入系統(tǒng)信息); chatmsg.addActionListener(new ActionListener() publicvoid actionPerformed(ActionEvent arg0) String str = chatmsg.getTe*t().trim(); if(!.equals(str) sendmsg(new Date().toLocaleString()+ - 系統(tǒng)消息： +str);chatmsg.setTe*t();

20、 else JOptionPane.showMessageDialog(null, 消息不能為空,錯(cuò)誤,JOptionPane.OK_OPTION); chatmsg.setTe*t();/* - 發(fā)送信息后，將輸入欄中的信息清空 - */ ); send = new utton(發(fā)送); send.addActionListener(new ActionListener() publicvoid actionPerformed(ActionEvent arg0) String str = chatmsg.getTe*t().trim(); if(!.equals(str) sendmsg(n

21、ew Date().toLocaleString()+ - 系統(tǒng)消息： +str);chatmsg.setTe*t(); else JOptionPane.showMessageDialog(null, 消息不能為空,錯(cuò)誤,JOptionPane.OK_OPTION); chatmsg.setTe*t();/* - 發(fā)送信息后，將輸入欄中的信息清空 - */ ); addponettocontainer(); this.addWindowListener(new WindowAdapter() publicvoid windowClosing(WindowEvent we) sendmsg(S

22、YSTEM_CLOSED);/* - 向客戶端發(fā)送效勞器關(guān)閉信息 - */ destory(); ); start(); /* - 啟動(dòng)連接效勞 - */ publicvoid addponettocontainer() Container c = this.getContentPane(); c.setLayout(null); currnum.setBounds(20,15,130,20); totalnum.setBounds(155,15,125,20); js.setBounds(10,50,280,500); chatmsg.setBounds(10,560,180,30); se

23、nd.setBounds(220,560,70,30); copyright.setBounds(10,600,280,20); c.add(currnum); c.add(totalnum); c.add(js); c.add(chatmsg); c.add(send); c.add(copyright); this.setVisible(true); this.setResizable(false); publicvoid start() boolean isStarted = false;/* - 用于標(biāo)記效勞器是否已經(jīng)正常啟動(dòng) - */try this.ss = new ServerS

24、ocket(port); isStarted = true; this.allmsg.append(new Date().toLocaleString()+ 效勞器啟動(dòng) 端口: +port+n); while(isStarted) Socket client = this.ss.accept(); /* - 監(jiān)聽客戶端的連接 - */ DataInputStream in = new DataInputStream(client.getInputStream(); String name = in.readUTF(); user u = new user(); = name; u

25、.socket = client; lists.add(u); /將該用戶加到列表中去 num1+; num2+; currnum.setTe*t( 當(dāng)前在線人數(shù)： +num1); totalnum.setTe*t( 上線總?cè)藬?shù)： +num2); this.allmsg.append(new Date().toLocaleString()+ : ++ 登錄 n); new Thread(new ClientThread(u).start();/* - 為該用戶啟動(dòng)一個(gè)通信線程 - */ catch (IOE*ception e) System.out.println(效勞器已經(jīng)啟動(dòng)

26、.); System.e*it(0); class ClientThread implements Runnable user user = null; booleanisConnected = true; DataInputStream dis = null; DataOutputStream dos = null; public ClientThread(user u) this.user = u; try this.dis = new DataInputStream(this.user.socket.getInputStream(); this.dos = new DataOutputS

27、tream(this.user.socket.getOutputStream(); catch (IOE*ception e) / TODO Auto-generated catch block e.printStackTrace(); publicvoid run() readmsg(); /* - 讀取客戶的聊天信息 - */publicvoid readmsg() while(isConnected) try String msg = dis.readUTF(); if(quit&logout.equals(msg)/當(dāng)用戶關(guān)閉客戶端窗口時(shí)，發(fā)送quit字符串 表示用戶已經(jīng)退出 num1

28、-; try this.dis.close(); this.dos.close(); this.user.socket.close(); this.isConnected = false; catch(IOE*ception ioe) ioe.printStackTrace(); finally this.isConnected = false; if(dis!=null) this.dis.close(); if(dos!=null) this.dos.close(); if(this.user.socket!=null) this.user.socket.close(); lists.re

29、move(this.user);/從列表中刪除該用戶 currnum.setTe*t( 當(dāng)前在線人數(shù)： +num1); allmsg.append(new Date().toLocaleString()+ : ++ 退出n); else sendmsg(msg); catch (IOE*ception e) e.printStackTrace(); /* - 將信息進(jìn)展轉(zhuǎn)發(fā) - */publicvoid sendmsg(String msg) user us = new user(); DataOutputStream os = null; if(lists.siz

30、e()0) for(int i=0;ilists.size();i+) us = (user)lists.get(i); try os = new DataOutputStream(us.socket.getOutputStream(); os.writeUTF(msg); catch (IOE*ception e) e.printStackTrace(); else JOptionPane.showMessageDialog(null, 當(dāng)前無用戶在線。發(fā)送消息失敗,失敗,JOptionPane.OK_OPTION); publicvoid destory() try this.ss.clo

31、se(); catch (IOE*ception e) / TODO Auto-generated catch block e.printStackTrace(); this.dispose(); publicstaticvoid main(String args) new server(); package client; import java.awt.*; import java*.swing.*; import java.awt.event.*; import java.io.*; import .*; publicclasscliente*tends JFrame private J

32、Te*tField name; private JTe*tField ip; private utton ok,cancle; public Socket socket; public client() super(登錄框); this.setSize(400,80); this.setLocation(100,100); name = new JTe*tField(昵稱); ip = new JTe*tField(); ok = new utton(登錄); cancle = new utton(取消); ok.addActionListener(new listenEve

33、nt(); cancle.addActionListener(new listenEvent(); addponettocontainer(); this.setDefaultCloseOperation(E*IT_ON_CLOSE); publicvoid addponettocontainer() Container c = this.getContentPane(); c.setLayout(null); name.setBounds(10,10,100,30); ip.setBounds(120,10,100,30); ok.setBounds(230,10,70,30); cancl

34、e.setBounds(310,10,70,30); c.add(name); c.add(ip); c.add(ok); c.add(cancle); this.setVisible(true); this.setResizable(false); publicclass listenEvent implements ActionListener publicvoid actionPerformed(ActionEvent event) / TODO Auto-generated method stub if(event.getSource()=ok) String n = name.get

35、Te*t().trim(); String i = ip.getTe*t().trim(); if(.equals(n)|.equals(i) JOptionPane.showMessageDialog(null,昵稱、IP不能夠?yàn)榭?,錯(cuò)誤,JOptionPane.OK_OPTION); elselogin(n,i); if(event.getSource()=cancle) name.setTe*t(); ip.setTe*t(); publicvoid login(String name,String ip) try socket = new Socket(ip,7777); DataO

36、utputStream out = new DataOutputStream(socket.getOutputStream(); out.writeUTF(name); out.flush();/強(qiáng)制輸出緩存中的容 /out.close(); new ClientFrame(name,socket); destroywindow(); catch (UnknownHostE*ception e) JOptionPane.showMessageDialog(null,找不到主機(jī)地址(IP錯(cuò)誤/網(wǎng)絡(luò)故障)！,錯(cuò)誤,JOptionPane.OK_OPTION); catch (IOE*ception

37、 e) publicvoid destroywindow() this.dispose(); publicstaticvoid main(String args) new client(); package server;import .*; publicclass user String name; Socket socket; package client; import java.awt.Color; import java.awt.Container; import java.awt.event.ActionEvent; import java.awt.event.ActionList

38、ener; import java.awt.event.WindowAdapter; import java.awt.event.WindowEvent; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOE*ception; import .Socket; import java.util.Date; import java*.swing.utton; import java*.swing.JFrame; import java*.swing.JOptionPane; impor

39、t java*.swing.JScrollPane; import java*.swing.JTe*tArea; import java*.swing.JTe*tField; publicclassClientFramee*tends JFrame private JTe*tArea allmsg; private JTe*tField wele,copyright,chatmsg; private utton send; private JScrollPane js; privatebooleanisConnected = true; public DataOutputStream out;

40、 public DataInputStream in; public Socket s = null; String nic; /* - 保存用戶昵稱 -*/* * 初始化客戶端資源 * 1.獲取從LoginFrame傳遞過來的參數(shù) * 2.初始化界面元素 * 3.初始化通信所需要的資源 EG：輸入/輸出流(DataInputStream/DataOutputStream) * */public ClientFrame(String name,Socket socket) this.setSize(310,660); this.setLocation(290,50); this.setTitl

41、e(聊天室客戶端);/* - 指定窗口的標(biāo)題 -*/this.s = socket;/* - 接收從LoginFrame中傳遞過來的Socket -*/this.nic = name+ 說： ; wele = new JTe*tField( 歡送您來到聊天室 ,100); wele.setBackground(Color.blue); wele.setEnabled(false); copyright = new JTe*tField( - all copyright TOP-king -); copyright.setEnabled(false); allmsg = new JTe*tAre

42、a(); allmsg.setEditable(false); allmsg.append( 系統(tǒng)消息: 歡送登錄在線聊天室 n); js = new JScrollPane(allmsg);/為JTe*tArea添加滾動(dòng)條 chatmsg = new JTe*tField(在此輸入聊天信息); chatmsg.addActionListener(new listen(); send = new utton(發(fā)送); send.addActionListener(new listen();/* - 添加事件監(jiān)聽器 -*/try out = new DataOutputStream(s.getO

43、utputStream(); in = new DataInputStream(s.getInputStream(); catch (IOE*ception e) JOptionPane.showMessageDialog(null, 系統(tǒng)異常,錯(cuò)誤,JOptionPane.OK_CANCEL_OPTION); addponettocontainer(); /* - 當(dāng)用戶關(guān)閉窗口時(shí)進(jìn)展相關(guān)的處理 eg:Socket Data(Input/Output)Stream 的關(guān)閉-*/this.addWindowListener(new WindowAdapter() publicvoid windowClosing(WindowEvent we) sendmsg(quit&logout);/* - 向效勞器端發(fā)送關(guān)閉信息 -*/isConnected = false; destory();/* - 銷毀窗口資源 -*/ ); new Thread(new linread().start();/* - 啟動(dòng)讀取信息線程 -*/ publicvoid addponettocontainer() Container c = this.getContentPane(); c.setLayout(null); wel