基于UDP协议的聊天程序设计报告.doc

基于UDP协议的聊天程序设计报告(完整资料）
(可以直接使用，可编辑 优秀版资料，欢迎下载）

编号:

计算机网络课程设计

题　 　目:基于UDP的聊天程序　 　
系 别: 计算机科学与工程学院

摘要
随着网络技术的发展及人们生活的需求，网络聊天已越来越受到人们的青睐 。网络聊天已经成为人们工作生活中传递信息、交流感情的重要工具，给人们带来了很大的方便。　本课题是开发一个基于UDP的局域网聊天系统，运用软件工程的设计流程,综合运用数据库编程技术、Ｗiｎdows程序设计技术、网络通讯技术,此网络聊天工具采用客户端／服务器（C/S)模式,客户端采用UＤP与服务器连接，客户端与客户端之间通过UＤＰ互相通讯。服务器端具有服务器端口设置，此聊天工具能实现多人聊天功能,适用于局域网使用的网络聊天工具，其操作简单,灵活性好，运行也比较稳定。
关键词：网络通讯;客户端/服务器模型；用户数据报协议；套接字

一、需求分析
1．１ 课程设计目的 开发一个专用于实现两台计算机之间即时通讯的软件以方便两台计算机之间信息的交流。在连接并通信时尤其是近程的即时通讯彻底的脱离了远程的服务器避免了和远程服务器连接时过多的浪费网络资源。并且避免了服务器忙或与服务器无法连接时浪费过多时间用于和服务器建立连接因此这个软件是极具适应性和实用性的即时通讯软件本次课程设计的目的是学习基于UDＰ协议实现网络聊天程序已达到学会面向无连接方式的程序设计方法并理解网络编程中面向无连接的概念.
　 1.2 　 课程设计的内容 用户数据报ＵDＰ是一个无连接协议使用这种协议时并不需要在两台计算机之间建立固定的连接也就是说通信双方没有服务器和客户机之分它们之间进行的是对等通信所以它的优势很明显是现代通信不可或缺的一部分。所以利用它的优势设计一个可以聊天的软件实现两台计算机间的即时通讯。
１．３ 课程设计要求 基于UDＰ协议实现的聊天和一对多的聊天提供友好的用户界面便于用户进行操作。
二 ． UDP协议的理解：
UDP协议是英文ＵserDatagramPｒotocｏl的缩写，即用户数据报协议，主要用来支持那些需要在计算机之间传输数据的网络应用.包括网络视频会议系统在内的众多的客户/服务器模式的网络应用都需要使用UDP协议.UＤP协议从问世至今已经被使用了很多年,虽然其最初的光彩已经被一些类似协议所掩盖，但是即使是在今天,UDP仍然不失为一项非常实用和可行的网络传输层协议。ＵＤP协议直接位于IP（网际协议）协议的顶层。ＵDP协议的主要作用是将网络数据流量压缩成数据报的形式。一个典型的数据报就是一个二进制数据的传输单位。每一个数据报的前8个字节用来包含报头信息，剩余字节则用来包含具体的传输数据。UDP协议使用端口号为不同的应用保留其各自的数据传输通道。正是采用这一机制实现对同一时刻内多项应用同时发送和接收数据的支持。数据发送一方(可以是客户端或服务器端）将UＤP数据报通过源端口发送出去，而数据接收一方则通过目标端口接收数据。有的网络应用只能使用预先为其预留或注册的静态端口;而另外一些网络应用则可以使用未被注册的动态端口。因为UＤP报头使用两个字节存放端口号,所以端口号的有效范围是从０到６5535。一般来说，大于4９151的端口号都代表动态端口。数据报的长度是指包括报头和数据部分在内的总的字节数.因为报头的长度是固定的，所以该域主要被用来计算可变长度的数据部分(又称为数据负载).数据报的最大长度根据操作环境的不同而各异。从理论上说，包含报头在内的数据报的最大长度为6５５35字节.不过,一些实际应用往往会限制数据报的大小,有时会降低到81９2字节。UDP协议使用报头中的校验值来保证数据的安全。校验值首先在数据发送方通过特殊的算法计算得出，在传递到接收方之后，还需要再重新计算.如果某个数据报在传输过程中被第三方篡改或者由于线路噪音等原因受到损坏，发送和接收方的校验计算值将不会相符，由此ＵDP协议可以检测是否出错。UDP协议并不提供数据传送的保证机制.如果在从发送方到接收方的传递过程中出现数据报的丢失,协议本身并不能做出任何检测或提示，由于排除了信息可靠传递机制,将安全和排序等功能移交给上层应用来完成,极大降低了执行时间，使速度得到了保证.
三． UDP协议特点
１、UDP传送数据前并不与对方建立连接,即UDＰ是无连接的，在传输数据前，发送方和接收方相互交换信息使双方同步.　
　　2、UＤＰ不对收到的数据进行排序，在UDP报文的首部中并没有关于数据顺序的信息(如TＣP所采用的序号）,而且报文不一定按顺序到达的，所以接收端无从排起.
3、UDＰ对接收到的数据报不发送确认信号，发送端不知道数据是否被正确接收,也不会重发数据.
4、ＵＤＰ传送数据较ＴCP快速,系统开销也少。
5、由于缺乏拥塞控制（cｏngeｓtion conｔrｏl），需要基于网络的机制来减小因失控和高速UDP流量负荷而导致的拥塞崩溃效应。换句话说,因为UＤP发送者不能够检测拥塞，所以像使用包队列和丢弃技术的路由器这样的网络基本设备往往就成为降低UDP过大通信量的有效工具。数据报拥塞控制协议（DＣCＰ）设计成通过在诸如流媒体类型的高速率UDP流中增加主机拥塞控制来减小这个潜在的问题。　从以上特点可知，UDP提供的是无连接的、不可靠的数据传送方式,是一种尽力而为的数据交付服务。

四。　基于C/S的多客服端相互通信原理分析：
在C/S模式中，它是在分散式 ，集中式，以及分布式基础上发展起来的一种新模型，目前大多数网络通信以及应用都属于这种模型,Ｃ/S模式将一个网络事务分为两部分，一部分是客户端（Client)，他为用户提供网络请求服务的接口，另一部分是服务端(Ｓeｒver），它负责接受用户对服务的请求，并将这些服务透明的提供给用户，既适用于实际应用的程序，又实用于真正的计算装置,举例来说,我们到饭店吃饭时,要首先提出请求吃什么，属于客户端，饭店服务员根据请求提供相应的服务,属于服务端,至于相应的饭菜是由哪一个厨师来做，则由饭店的服务员去联系,而客户端只需要和服务器打交道就行了,从程序实现上来说，客户端和服务器打交道实际上是两个进程打交道,服务端启动ｓerver进程,并等待客户端与其联系，而客户端则启动客户进程和服务器打交道.当服务器进程处理完一个客服进程请求的信息之后，由接着等待其他客户的请求。
五． 套接字编程原理分析：

图1.1 套接字编程原理图

注释：ｓｏckeｔ（）,使用前创建一个新的套接字；bｉｎd（），将套接字地址与所创建的套接字号联系起来;sｅnd（)与recv（)，数据的发送与接收；closｅsocｋet（)，关闭套接字。
六、概要设计
服务器
客户机甲
客户机乙
客户机丙

图２。1 整体框架设计图

服务器端主要实现的功能是启动一个监听的进程，开放自己的端口号为７777，不断的监听是否有新的客服端进程向自己发送连接请求,为每一个主动连接自己的客户端设置一个ＩD号设置一个threadｓ的容器用来管理客户端的线程.与客户端建立连接，实现sockeｔ通信，对于服务器端是先接受数据流然后再发送数据流，客服端发送过来的信息经服务器端然后转发到其他所有的客户端，服务器端相当于中间的桥梁。
客户端要求主要实现的功能是建立一个图形的界面,用于显示聊天信息等，并且建立与服务器端的通信，主动的向服务器端发送连接请求，然后对输入文本框注册事件监听并且发送给客服端，不断的监听服务器端发来的信息，然后显示出来。

七、详细设计
服务器端:
创建服务端接口
建立一个seversocket的类svsocket
创建一个容器用来管理客户端进程
开始监听，监听是否有客户端连接，有的话与其建立连接

分配ID
监听线程
监听端口是否有消息传入
如果有的话接收信息
再将信息发送到其他的所有的客服端
当某客户离开，结束他与其他人的通信
为客户端连接创建线程
从容器vector中删除该线程
表示该线程已经离开聊天室，结束两者之间连接

图7．1 服务器端整体设计流程图

客户端建立一个seveｒsocｋet的类，并且创建一个veｃtｏr用来管理客户端的线程,然后就开始检测,如果有客户端请求与服务器连接就与其建立sｏcｋet连接,创建进程设置ＩD，告诉其他的客户端有新的客户端接入,然后开始监听所有的客户端线程如果有信息通过端口进入就接受然后再发送给其他客户端，如果有客户端退出,就会告诉其他的客户端并且关闭与该客户端的ｓocket连接，然后在vectoｒ里面删除相应的线程。
主界面
服务器界面，当运行服务器端则出现

运行客服端登录

心得体会:
经过两个星期的学习和实践，我也算是顺利的完成了计算机网络课程设计,同时对计算机网络有一个大致的了解,在实践过程中遇到了很多的困难，感觉自己很难将理论与实践相结合，觉得我们学习的那些知识也派不上用场，通过这次课设，我深刻的认识到实践与理论必须 要想结合才能使所学的知识变成可用的,通过自己的努力和老师同学们的帮助,多了一种看待问题的角度；我也发现了我所学知识不扎实，只是走马观花的应付考试，在以后的学习中需要时刻的告诫自己,踏踏实实做好每一步。
本次课程设计是利用ｊaｖa语言编写的,虽说自己以前接触过这种语言，但是经过这两周的学习，我受益匪浅。首先，我进一步弄懂了ＪAVA语言的编程方法和原则，并学会了编写ｊava程序。其次,使我更深层次的理解到JAVA语言是一种面向对象的语言，具有可视化编程的特点且代码具有可移植等特点。本次课程设计是实现一个ＵDＰ即时通讯程序。经过编写程序和运行，调试程序,我对java语言有了更深的了解。另外，使我对UDＰ协议的特点和工作过程有了更深的了解。UDP协议提供无连接的、不可靠的服务。它工作于传输层,是传输层的重要协议之一。最后，UＤP协议是利用客户端和服务器端模型来实现传输的. 本次课程设计使我明白了知识的重要性,同时也更加懂得实践更不可少。我们要经常把所学的知识运用到实践，这样，才能充分的融会贯通。同时，也使我认识到自己动手能力太差，为我以后的学习和发展提供了一个警钟!本次课程设计的过程中，虽然遇到了不少问题，但最后还是成功的完成了.
这次课设对于我而言是有很大的收获,懂得独立寻找资料学习，这是最大的收获，在以后的工作中肯定会面临不懂得问题，有了这次课设的经验，就能够去独立学习并解决困难。

主要代码
pacｋage　server; 　

import ｊａva.aｗt.Ｃｏnｔａinｅr；　
impoｒｔ javａ．awｔ.event．ActionEveｎｔ； 　
import jａva．ａwt。ｅvｅnｔ.AｃtioｎListeｎer;　
import ｊava．awt.evｅnt.WindowAdapter;
imｐｏｒｔ javａ。awt。ｅｖeｎt．WiｎｄowEｖeｎｔ；
impoｒｔ jaｖa．io。ＤａtaInpuｔSｔream; 　
impoｒt java。ｉo。DataOutｐutStｒeaｍ;
impoｒt ｊａva．io。ＩOExcepｔion; 　
iｍｐorｔjava.iｏ。ObｊeｃｔIｎputStream；
iｍporｔｊava。io。ObjｅctOutputＳｔrｅam;　
ｉｍｐｏrｔ .SerｖerSockeｔ; 　　
iｍｐorｔ ｊavａ．nｅt。Ｓocket;
ｉmpｏrｔ java．utiｌ。AｒraｙList;
ｉｍport java。uｔil。Date；

import　jaｖax.swiｎg。ＪBuｔton；　 　
imporｔ ｊaｖax.ｓwｉng．JFrａme；　
importjａvax.swｉng。ＪLaｂel；　
import ｊavax。swing.JOptionＰane; 　
iｍportｊavax.sｗiｎg．JＳcrollBａr； 　
import javax。ｓwing.JScｒollＰaｎｅ；　
import　jaｖax．ｓwiｎg.JＴeｘｔArea；
import javａx.sｗｉng.ＪＴeｘtFｉelｄ;

ｐubliｃclassserｖｅrexｔenｄs　JＦrａｍe{ 　

pｒiｖate　JTexｔArea allｍsg；
ｐrivate　JTextFｉｅｌｄ　ｃurrnum，tｏｔalnum,copyriｇht,chａtmｓg； 　
pｒivate JButtｏn　seｎｄ; 　
privaｔｅ JScｒolｌPane jｓ;　
ｉｎｔｎum１，ｎｕm2，pｏrt；/*　　-—　ｎuｍ1：当前在线人数 　nｕｍ2：总上线人数 ｐｏｒt:服务端口号 -－＊/

privａte SeｒverSoｃket　ss;　

ArrayＬiｓｔlistｓ；//存放所有在线用户 　

pｕｂlｉｃ serｖｅr()
{ 　
ｓｕpeｒ(”聊天室服务器端");　　　
this。seｔSiｚe(３10，660）；　 　
ｔｈis。setLｏcation（200，50）;

lists = neｗArｒayList（）; 　　

num1 =　ｎum2 =0;　　　
ｐoｒt =　7777;

ｃｕrrnum　= ｎｅw JＴeｘtField(" 当前在线人数： ＂+nｕｍ1）；　　
cuｒｒnuｍ．setEｎablｅd（faｌse）；

ｔoｔalnuｍ ＝　nｅｗ JTextＦiｅｌｄ（” 上线总人数： ”+num2)； 　
tｏtalnｕｍ。setEnaｂled（ｆalse); 　

allmｓg = nｅw ＪＴexｔAreａ（)； 　
ａllmｓｇ.apｐｅnd（” 　 　 　 —-—-－-－－-—－-—－— 系统消息 ——-－—-－—-－———-\n”);
allmsg．ｓｅtEdiｔable（fａlｓｅ);
allmｓg.sｅtLinｅWrap(ｔrｕｅ）； /／允许自动换行 　

ｊs ＝ nｅw JScｒollPane（aｌlｍｓg）；/／为JTexｔArea添加滚动条　

cｈatmsg　＝ ｎｅw JTeｘtFielｄ(”在此输入系统信息”）;　 　
ｃｈatｍｓg。addＡctiｏｎListenｅr（nｅw AｃｔionLiｓtenｅr(）｛　　

publicｖoid actｉonPerfｏｒmed(AｃtiｏnＥvｅnt aｒg0） ｛ 　
Strｉng str = ｃｈatmｓg。getTｅxｔ（）。tｒｉm（）； 　
ｉf（!""。equals（stｒ）) 　
　 　　｛seｎｄｍsg（(nｅw Ｄａte())。toＬoｃaleＳｔriｎg（）＋" —- 系统消息: ＂＋ｓtｒ);ｃhatｍsg。setＴext(””）;｝ 　
eｌｓｅ
　 JOptionPane。ｓｈｏwＭessageDiａｌog(null， ＂消息不能为空"，"错误＂,JＯptiｏnＰane。OK_OＰＴＩON）； 　
cｈatｍsg.ｓｅｔTｅｘt("＂）；/＊ —— 发送信息后，将输入栏中的信息清空 —- ＊／
}
});

send =　ｎew JButｔon（＂发送＂);
senｄ。ａdｄＡctｉｏnＬｉsｔeneｒ(new ＡctionListener(）｛ 　 　

pｕblicvoｉd actiｏnPerfoｒmｅd（ActionEvent ａrｇ0) {
　Sｔriｎg str = cｈatmsg.getTeｘt(）．trｉm（）； 　
ｉf（！＂"．ｅquａls(stｒ）)　 　
　　 　 ｛senｄｍsg((new Daｔｅ（）)。toLocaｌeSｔrｉｎg()+” —－ 系统消息: "+str);chatmsg.sｅtＴeｘt（"")；}
elｓe
　　 　JOptionPane.showMessageＤialog（nuｌl， "消息不能为空","错误”，ＪOpｔｉonＰane。OK_OPＴION）；
ｃhａtmsｇ.sｅtText（””）；/＊　 －— 发送信息后,将输入栏中的信息清空 -— 　＊/
} 　
}）;

　addcompｏｎettｏcontaｉnｅｒ(）; 　
thiｓ.aｄdWiｎｄowLiｓtener（ｎeｗ　ＷindowＡdapter（)｛　 　
publicvoiｄ wｉndowCｌosinｇ(ＷindoｗEｖent we）
　　　{
　　 sendmsg(”SYSＴＥM_CLＯSED”）;/＊ -－　向客户端发送服务器关闭信息 -- 　＊/
　destｏrｙ(）；　
｝　
｝); 　
　start（)； /＊ —－ 启动连接服务 --　 ＊/

　} 　

pｕｂlicvoｉｄ addcｏｍｐｏnettocontaineｒ（)
｛ 　
　Cｏｎtａiner c ＝ ｔhis。geｔCoｎtｅntPane（）;　
c．ｓetLayout（null)；

currnｕm.ｓｅtＢｏunds（2０，15,１３0，20)；
tｏtalnum.setBouｎds(155,1５，125，20)； 　　
js．seｔBoｕndｓ(10，５0，280，50０）;
ｃｈatmsg.setBoundｓ（１０，５60,180,３0）;
send.ｓetBouｎds(2２0，５6０,70，30)； 　
cｏpyriｇhｔ。ｓetBounds(１0,600，280,20）；　

　 c。add(currnum）；
c。add（totalnum）；
c．aｄd(js）；　　
　c。add(chａtmsg);
　c。aｄｄ(ｓend）；
c.ａdd（ｃopｙright)；　

tｈis。ｓetＶiｓibｌe（true); 　
this．setＲｅｓｉzａblｅ（ｆaｌse)； 　
}
puｂｌiｃｖoid stａrt() 　
{
ｂｏｏlean isStａｒteｄ　= fａlse;/* 　—- 用于标记服务器是否已经正常启动 －- ＊／
try ｛ 　
tｈis.ss ＝ nｅw SerｖerＳoｃkeｔ(poｒｔ);
　 isStartｅｄ　＝ true；
this.ａllｍsｇ。ａppend((new Date()）。tｏLｏcaleStｒiｎｇ（)+”　 服务器启动　＠ 端口： ”+port＋”\n”);
wｈiｌe(isSｔaｒtｅd） 　
{　　
Sｏcｋet　cｌient = ｔhis.ｓs.aｃcepｔ（)； ／＊ —— 监听客户端的连接　－－　 ＊/
ＤataＩnpuｔStreａm in　= ｎeｗ　ＤaｔａＩｎｐutStｒeａｍ（ｃlｉeｎt.gｅtInｐutStrｅam（））；
　 Ｓtrｉng name = iｎ。readUＴF（）;　 　
　user u ＝ neｗ uｓer（);　
　 u。ｎame = name；　
　 u．sockｅｔ ＝ client;
lｉｓｔｓ。add（u）; /／将该用户加到列表中去
num1++； 　
nuｍ2+＋;
currnuｍ.seｔText（＂ 当前在线人数: ＂＋ｎum1）；
totaｌnum.seｔText（” 上线总人数：　＂+num2）;　
this.ａllmsg.appenｄ（（ｎeｗ　Daｔｅ（）)．ｔoＬｏcaｌeStｒing(）＋" ：　"+u.name＋" 登录 \ｎ＂);
new　Ｔｈread(new ClｉentＴhread（u）)。sｔart（);／* -- 为该用户启动一个通信线程 --　 ＊/
} 　

　 ｝ cａｔch （IOEｘcepｔioｎ　e) {　
Ｓysｔem.oｕt。pｒinｔｌn（"服务器已经启动.。。..．＂）; 　
　 Ｓyｓtｅｍ。ｅｘit（0）；
} 　
｝ 　
ｃlaｓs ClｉeｎtTｈｒeａｄ implｅments Runnａble 　　
{ 　
ｕｓeｒ user = nuｌl;　　
bｏoleaniｓCoｎnｅctｅd =　ｔruｅ；
DatａＩnputSｔreaｍ dis　＝ null； 　
DaｔaOｕtｐutSｔｒeam doｓ = null;

ｐublic ClienｔＴhrｅad（usｅｒ u）
　｛
this。usｅr = u; 　
try ｛
ｔhis。dis ＝ neｗ DａｔaInpｕtStreａm(ｔhis。user。sｏcket。ｇetInputSｔrｅam()）; 　
this。doｓ =　ｎｅw DａtａOuｔｐutStｒeａm（this.ｕser.ｓｏckeｔ.getＯutpｕtＳｔrｅａm（））;　　　
　　｝ caｔch （ＩOExcｅｐtioｎ e) {
// TODO Aｕｔｏ－generaｔed caｔch ｂloｃｋ　　
　 e.priｎtStackTrace（)；　
　 }
　 }

ｐublicvoid　ruｎ（） 　
{
ｒeadmsｇ（）; 　
｝

/＊ —— 读取客户的聊天信息 -—　 ＊／
publicｖoｉd reａｄmsg()
　{
whｉｌe（iｓＣonｎeｃted)
　 　{ 　
try { 　　 　 　
　Sｔring msg ＝　dｉs。readUTF（）; 　　
ｉf（”qｕiｔ＆logout"。ｅquａls（ｍsｇ)）//当用户关闭客户端窗口时，发送ｑuiｔ字符串 表示用户已经退出 　
　 ｛
num１—－; 　 　 　 　
ｔry{
this.dis.clｏse（）；　
tｈis.doｓ．ｃlｏｓe(）；　
ｔｈis.useｒ。socｋｅｔ.cloｓe（); 　
tｈis.ｉsＣｏnｎeｃteｄ = false；
　 　 }caｔcｈ（IOExcｅpｔion ioe)
｛ 　
　ｉｏe。prinｔSｔａckＴrａcｅ()； 　
　　 　 }finally｛
this.isＣｏnnｅcｔｅd = fａｌse;
iｆ(dｉs！＝nuｌl） tｈis．ｄｉs.cｌｏｓe（)；
if（dos！＝ｎuｌl）　tｈis．dos。ｃlose（)；　
if(this.user．socｋet!=null） thiｓ。ｕｓｅr.soｃket．cｌｏse（）； 　
　　　 　 ｝
liｓts。remoｖe（tｈis．ｕｓｅr)；/／从列表中删除该用户
ｃuｒrnｕm。seｔTeｘｔ（＂ 当前在线人数： ”+ｎｕm１）； 　
ａllmsｇ．appenｄ(（ｎｅｗ　Daｔe（)）.toLoｃalｅStriｎg（)+”　 :　"+this.uｓer.name+＂ 退出\n"）;
　 ｝ 　
else
　ｓendmsg(msg）；
　　 ｝ ｃａｔcｈ　(IOExcｅｐtioｎ e） {
　 e.printＳｔａckTrａｃe（)； 　
　　 　 ｝
｝　
　｝ 　 　　

｝　

/* ——　将信息进行转发 -— ＊／
ｐｕblicvoiｄ ｓｅndｍｓg（Sｔring msg)
{　 　
　 uｓeｒ us ＝　nｅw uｓer(); 　
　 　　ＤataOｕtpuｔStｒeａｍ ｏｓ　＝　null;　
if（lists。sizｅ（)＞0) 　
｛　
ｆor（int　i=0;i<ｌiｓts。ｓｉzｅ(）；i++）
　 　{
　 　　 　　 us　=　(usｅｒ）lists.get(ｉ）; 　
tｒy　{ 　
　 　 　 os = new DataＯuｔｐutStreａm（us.ｓocｋｅt。gｅtOｕtputStream（））；
os.wriｔｅUＴF(msg);
　 ｝ ｃatch （IＯＥxcｅptiｏｎ　ｅ) {
　 　　　　 e．prｉntSｔaｃｋTｒacｅ(）;　
　 }　
　 }
　　 　｝
else
　 ＪOpｔioｎPanｅ.sｈowＭeｓsageＤialog（null， ”当前无用户在线.发送消息失败”,"失败”,JOptiｏnＰane。OK_OＰTＩＯN);
｝ 　

pｕｂｌiｃvｏｉｄ destｏry（）
　 {
trｙ { 　
thｉs。ss．close(）；
　 ｝ catch （IOＥｘcepｔｉon　e) ｛
// TＯDO Auto－gｅnerated ｃatcｈ block
e．pｒiｎtSｔacｋTraｃe（)；
　}
ｔｈis。dispoｓｅ（）;　
　 　} 　

ｐublicstaticvoｉd main（Sｔｒｉng［］ arｇs） 　 　｛　
ｎｅｗ serｖｅr（)；　
}

｝

packagｅ　ｃlｉenｔ;

ｉｍｐｏrt jａva.awｔ.＊;
impｏrt　jａvax。swing。*；　　
imｐort ｊava.awt。ｅｖｅｎt.＊;
iｍｐort jａva。iｏ。*;
imporｔ jaｖa．ｎｅt。＊； 　

ｐuｂlｉcｃｌasscｌｉeｎteｘtends　JFrａmｅ｛
private ＪＴexｔFｉｅld namｅ;
privaｔe JTextFieｌd ip;
priｖatｅ JＢuｔton　ok，cａncle；

puｂｌic Ｓocｋet soｃkｅｔ；

ｐublｉc cｌient（） 　
　｛
super(＂登录框")；　
thｉs.setSize（4００，８0）；
thｉs.setLｏcation(100,１00)；

name = new　JTeｘｔＦｉｅld(”昵称＂）；　　　
ip =　neｗ JTextFiｅld(”1２7.0.０.1”）; 　
ok　= ｎew JButｔon(”登录”）; 　
canｃle = neｗ JButton（”取消＂)； 　
oｋ.addＡcｔiｏnＬｉsｔeｎｅr(ｎew listeｎEvent(）)；　 　
cａncle．addActionListenｅr（ｎｅw lｉｓteｎEvent（）)；

addｃｏmpoｎeｔtocｏntainｅr（）；　
thiｓ。setＤｅfａｕlｔClｏseOｐerａtiｏn（EＸＩT_ＯN_CＬOSＥ）；　 　

｝

ｐuｂｌiｃvoid ａｄdcｏmｐoｎettｏｃontaｉneｒ(）
{
Contaiｎer　c　= thｉs．ｇｅtConｔentPanｅ(）；
　c。setＬayoｕt(nuｌl)； 　

ｎaｍe。ｓｅtBoundｓ（10，１0，100，30）；　 　
ｉｐ．setＢounds(12０,１0,100，30）； 　
oｋ.sｅｔBounds(230，10，７0，30)； 　
cancle。sｅtBｏuｎdｓ（３10，１0，70，30）；

c.aｄd（name);
　 c.ａｄd(ip)；　 　
c。ａdd(ok）；
c.add（ｃancle);

ｔhｉs。seｔVisｉｂle(tｒue）; 　
thiｓ。setＲeｓｉzabｌe（falｓe)；　 　
｝ 　

publicclaｓs　listenEｖeｎt　iｍｐｌeｍents ＡcｔiｏnＬisｔener　
｛

pｕblｉcvoid ａｃtionPerfｏｒmed（ＡctionEvｅnt event）　｛
// TODO Auｔｏ—gｅnerａted meｔhod sｔｕｂ
iｆ(event。ｇｅtSoｕｒce（）==ok） 　
　{
　　　 String ｎ = name。getTeｘt().trim()；　
Striｎg ｉ　＝ ip.getText(）。ｔｒim（)；
ｉｆ（"＂。equalｓ（n)｜|”＂.eqｕals（ｉ)）
　　｛
　 　 ＪOｐtｉonＰaｎe．shoｗＭessａｇeDｉaｌｏg（nｕlｌ,＂昵称、IＰ不能够为空！”，”错误＂，JOptionPaｎｅ。OK_OPＴIOＮ）;　
｝
else｛loｇｉｎ（ｎ,ｉ)；｝
｝
ｉｆ(eveｎt。getSource()==ｃａnｃle） 　
　 　{　　
ｎamｅ．ｓetＴeｘt（"”)； 　
ip.setTexｔ（＂”）;
｝ 　
　 ｝　　

　｝

pｕblｉcｖoid　ｌogｉn(Sｔring name,Stｒinｇ ip） 　
｛

trｙ　｛ 　　
ｓocket　= new Socｋeｔ（ip，7７７７)；　 　
　 　DａtａOutputStream　out　= new DataＯuｔputＳtream（sockｅt．getOutｐｕtＳｔｒeam(））;
　 out．wriｔｅUTF（name)； 　
ｏut．ｆlush（);//强制输出缓存中的内容　
//ｏut.closｅ（)；　 　
new ＣｌientFrame(name,ｓocket)；
　 deｓtｒoｙwinｄow(）;
｝　ｃatｃh　(ＵnknoｗnＨｏｓｔEｘceptioｎ e）　｛
　 　　JOptionPane.shoｗＭeｓsａgeＤialog(ｎｕlｌ，”找不到主机地址（IP错误/网络故障）!”，"错误＂,JＯptｉonＰaｎe.OK_OPTION);

　　} ｃaｔcｈ　(IOExcｅptｉoｎ e） {

　 ｝ 　 　　　　 　
｝

ｐuｂlｉcｖｏiｄ dｅｓtｒoywiｎdｏw（)
{ 　　　
ｔｈis.dispose（)；
　｝　

pｕｂlicｓｔatiｃvｏiｄ ｍaｉn(Striｎg［］ args)
｛
nｅｗ　client（）; 　　
　｝
}

pａckage ｓervｅr；
import jａva.ｎet．*；　

ｐublｉcｃlaｓs　user ｛

Strinｇ　nａmｅ; 　
　Sｏcｋet sｏcket；
｝ 　

packaｇe clｉeｎt;　
ｉmpoｒt ｊａva.awt.Coｌor；　
imｐoｒｔ　javａ。ａｗt.Conｔａineｒ； 　　
iｍpoｒt　jaｖa。awt．eｖent．ActionＥｖｅｎt； 　
imｐoｒt　jaｖa．awｔ。event．AｃtioｎLiｓteｎer;
iｍporｔ ｊavａ.awt。evenｔ。WindｏwＡｄaｐter；
ｉｍｐort ｊava．ａwt.eveｎt.ＷindｏwEveｎt；　
ｉｍport jaｖa．ｉo.DａtａInputSｔｒeaｍ;
ｉmport java。io。DatａOutputＳｔrｅaｍ;　
ｉmｐoｒｔ java．io。IOException;
import java.neｔ.Ｓocket;　　
import ｊavａ．utiｌ．Date；

imporｔ jaｖaｘ．swinｇ。JＢutton;
impoｒt ｊavax。ｓwiｎg．JFrａｍｅ；
imporｔ jａvａx。swｉng．ＪＯptionＰaｎe;　
import ｊaｖaｘ。ｓｗing。JScrｏllPane; 　
ｉmport jａvａx。swing.JTextArea;　 　
iｍpｏrt ｊaｖax。swinｇ。ＪTextＦｉｅld；

ｐｕbｌicclａsｓCｌiｅｎｔFramｅｅxtｅnds　JFramｅ｛　
private JＴｅｘtＡreａ allｍsg;
ｐrｉvatｅ JTextＦield welcoｍe，cｏpyｒｉghｔ，ｃhatｍsg；　　
priｖaｔe JBuｔｔｏn seｎd;
ｐriｖate JScｒollPaｎe js;
privatebooleａniｓCoｎｎecｔed = true;

publｉc ＤaｔaOutｐuｔＳtream　ｏｕｔ； 　
publiｃ　DatａInpｕtStrｅam in；

public　Ｓoｃket s = ｎｕll; 　 　

String nic;　　/* —－　保存用户昵称 --＊/

/*＊
*　初始化客户端资源
＊　１．获取从ＬogｉnFrａme传递过来的参数
＊ 2。初始化界面元素
　 ＊ 3．初始化通信所需要的资源 EＧ:输入/输出流（DataInputStream／DataOutpuｔStream） 　
　　＊ ＊/
pｕblic ClienｔＦraｍe(String ｎamｅ,Ｓｏｃket　socket)
{　　 　
ｔｈis.setSize(310，６60）； 　
ｔhiｓ.setLｏcatｉon（29０,5０)； 　
ｔｈis。setTitｌe("聊天室客户端＜"＋nａme＋＂＞”)；/＊ -— 指定窗口的标题 -—＊/

thi