资源描述
. .目录 系统分析与设计02.1 需求分析102.2系统总体框架122.2.1总体设计122.2.2功能模块132.3系统详细设计242.3.1多线程设计242.3.2数据库设计252.3.3效劳器的设计252.3.4客户端的设计262.3.5消息通信的设计26. v . .绪论1.1选题背景1.1.1 即时消息系统的研究现状即时消息系统1(Instant Messenger,IM)是一种在后 PC 时代兴起的,以 Internet 网络为根底的,允许交互双方即时地传送文字、语音、视频等信息,能够跟踪网络用户在线状态的网络应用软件。即时消息系统产生有着深刻的社会原因:人们都有渴望社交,获得社会尊重、实现自我的需求,这正是即时消息软件风行的原动力,而物质文明的日益兴旺所带来副作用,又使得人们习惯与周围的人保持距离,以致人们更愿意对陌生人敞开心扉,在网络中可以跨越年龄、身份、行业、地域的限制,到达人与人、人与信息之间的零距离交流。从这点上讲,即时消息系统的出现改变了人们的沟通方式和交友文化,大大拓展了个人生活交流的空间。国内最为流行的即时消息软件是 OICQ简称 QQ 。它以良好的中文界面和不断增强的功能形成了一定的 QQ 网络文化。该软件是由腾讯公司于 1999 年 2 月自主开发的基于Internet的即时消息系统。腾讯QQ 目前已成为中国最主要的即时消息效劳网络软件。作为一种即时消息工具,QQ 支持显示好友在线、即时传送文字、语音和文件等功能。 QQ 还与无线寻呼、GSM 短信息、IP 网互联,为用户提供互联网短信及信息增值效劳。腾讯 QQ 开发和拓展统一、高速、丰富的互联网应用平台、在线广告业务、移动通信业务、ISP及IP合作业务、企业商用即时消息效劳、在线客户支持及在线呼叫业务。 1.1.2 即时消息系统的开展趋势21世纪将是网络化、信息化的世纪,信息的融合已经成为社会开展的主流方向2。即时消息系统将不断与信息交流领域的系统相互集成和渗透,扩展其自己的功能和应用范围,满足未来话音,数据和视频的多媒体应用需要,使即时消息以更丰富的接入方法,更高的效劳质量,更友好的面貌呈现在世人的面前。 从功能角度来看,即时消息系统向支持全媒体方向开展,随着多媒体技术在网络应用中的开展,即时消息系统承载的媒体,不再局限于原来的文字、语音和文件的信息交换,信息载体扩展到图形、图像和流媒体等多媒体业务上。目前ICQ 和 QQ预设了局部简单的表情图像, 通过传输图像代码来传递表情图像,可以被视为即时消息开发商开发支持图形、图像为载体的即时消息软件的开端。 从应用范围角度来看,即时消息系统集中在 Internet 个人用户之间的信息交流应用,随着网络技术应用的开展,即时消息系统应用范围向园区化、集团化拓展,应用领域突破个人,而用于远程教学、远程医疗、远程演示、网络会议等领域。1.1.3论文研究的主要内容本论文的主要工作是利用编程技术建立一基于 J2SE 的即时消息系统,主要实现网络即时聊天功能。在建立这个系统的过程中,我将会研究JAVA语言,多线程编程、网络编程以及数据据等方面的知识。 在我的论文中,我将会研究即时消息的开展,并针对不同即时消息工具之间不能互通的弊端,介绍即时消息系统中的应用。为了更好地实现系统,我们还要研究J2SE 技术。在论文中介绍了 J2SE 的体系构造、系统设计以及 J2SE 的开发环境。熟悉了开发平台,我们还要了解 基于TCP/IP 的 Socket 网络连接的根底知识,包括网络通信系统架构及 Socket 通信在该系统中的应用等内容。在论文中将着重介绍网络即时消息系统的设计和实现,包括界面及各个功能模块的设计,给出了相应的流程图并对其功能做了详细描述,最终实现了客户端之间的即时聊天通信功能。最后是结尾局部,对本文做了总结并针对该系统提出了一些缺乏和今后需要改良的地方。1.2 技术背景1.2.1 C/S 模型在网络连接模式中,除对等网外,还有另一种形式的网络,即客户机/效劳器网3,Client/Server。在客户机/效劳器网络中,效劳器是网络的核心,而客户机是网络的根底,客户机依靠效劳器获得所需要的网络资源,而效劳器为客户机提供网络必须的资源。这里客户和效劳器都是指通信中所涉及的两个应用进程软件。使用计算机的人是计算机的“用户user而不是“客户client。但在许多国外文献中,也经常把运行客户程序的机器称为client这种情况下也可把client译为“客户机,把运行效劳器程序的机器称为server。所以有时要根据上下文判断client与server是指软件还是硬件。它是软件系统体系构造,通过它可以充分利用两端硬件环境的优势,将任务合理分配到 Client端和Server端来实现,降低了系统的通讯开销。目前大多数应用软件系统都是Client/Server形式的两层构造,由于现在的软件应用系统正在向分布式的Web应用开展,Web和Client/Server 应用都可以进展同样的业务处理,应用不同的模块共享逻辑组件;因此,内部的和外部的用户都可以新的和现有的应用系统,通过现有应用系统中的逻辑可以扩展出新的应用系统。这也就是目前应用系统的开展方向。1.2.2 TCP/IP 协议1. IP网际协议IP是TCP/IP的心脏,也是网络层中最重要的协议4。 IP层接收由更低层网络接口层例如以太网设备驱动程序发来的数据包,并把该数据包发送到更高层-TCP或UDP层;相反,IP层也把从TCP或UDP层接收来的数据包传送到更低层。IP数据包是不可靠的,因为IP并没有做任何事情来确认数据包是按顺序发送的或者没有被破坏。IP数据包中含有发送它的主机的地址源地址和接收它的主机的地址目的地址。 高层的TCP和UDP效劳在接收数据包时,通常假设包中的源地址是有效的。也可以这样说,IP地址形成了许多效劳的认证根底,这些效劳相信数据包是从一个有效的主机发送来的。IP确认包含一个选项,叫作IP source routing,可以用来指定一条源地址和目的地址之间的直接路径。对于一些TCP和UDP的效劳来说,使用了该选项的IP包好似是从路径上的最后一个系统传递过来的,而不是来自于它的真实地点。这个选项是为了测试而存在的,说明了它可以被用来欺骗系统来进展平常是被制止的连接。那么,许多依靠IP源地址做确认的效劳将产生问题并且会被非法入侵。 2. TCP如果IP数据包中有已经封好的TCP数据包5,那么IP将把它们向上传送到TCP层。TCP将包排序并进展错误检查,同时实现虚电路间的连接。TCP数据包中包括序号和确认,所以未按照顺序收到的包可以被排序,而损坏的包可以被重传。 TCP将它的信息送到更高层的应用程序,例如Telnet的效劳程序和客户程序。应用程序轮流将信息送回TCP层,TCP层便将它们向下传送到IP层,设备驱动程序和物理介质,最后到接收方。 面向连接的效劳例如Telnet、FTP、rlogin、X Windows和SMTP需要高度的可靠性,所以它们使用了TCP。DNS在某些情况下使用TCP发送和接收域名数据库,但使用UDP传送有关单个主机的信息。 3. UDPUDP与TCP位于同一层,但它不管数据包的顺序、错误或重发。因此,UDP不被应用于那些使用虚电路的面向连接的效劳,UDP主要用于那些面向查询-应答的效劳,例如NFS。相对于FTP或Telnet,这些效劳需要交换的信息量较小。使用UDP的效劳包括NTP网络时间协议和DNSDNS也使用TCP。 欺骗UDP包比欺骗TCP包更容易,因为UDP没有建立初始化连接也可以称为握手因为在两个系统间没有虚电路,也就是说,与UDP相关的效劳面临着更大的危险。 4. TCP与UDP的端口构造TCP和UDP效劳通常有一个客户/效劳器的关系,例如,一个Telnet效劳进程开场在系统上处于空闲状态,等待着连接。用户使用Telnet客户程序与效劳进程建立一个连接。客户程序向效劳进程写入信息,效劳进程读出信息并发出响应,客户程序读出响应并向用户报告。因而,这个连接是双工的,可以用来进展读写。 两个系统间的多重Telnet连接是如何相互确认并协调一致呢?TCP或UDP连接唯一地使用每个信息中的如下四项进展确认: l 源IP地址: 发送包的IP地址; l 目的IP地址: 接收包的IP地址; l 源端口: 源系统上的连接的端口; l 目的端口: 目的系统上的连接的端口。 端口是一个软件构造,被客户程序或效劳进程用来发送和接收信息。一个端口对应一个16比特的数。效劳进程通常使用一个固定的端口,例如,SMTP使用25、Xwindows使用6000。这些端口号是广为人知的,因为在建立与特定的主机或效劳的连接时,需要这些地址和目的地址进展通讯1.2.3编程技术1.JAVA语言Java6是由Sun Microsystems公司于1995年5月推出的Java程序设计语言以下简称Java语言和Java平台的总称。用Java实现的HotJava浏览器支持Java applet显示了Java的魅力:跨平台、动态的Web、Internet计算。从此,Java被广泛承受并推动了Web的迅速开展,常用的浏览器现在均支持Java applet。另一方面,Java技术也不断更新。Java语言的优良特性使得Java应用具有无比的强健性和可靠性,这也减少了应用系统的维护费用。Java对对象技术的全面支持和Java平台内嵌的API7能缩短应用系统的开发时间并降低本钱。Java的编译一次,到处可运行的特性使得它能够提供一个随处可用的开放构造和在多平台之间传递信息的低本钱方式。特别是Java企业应用编程接口Java Enterprise APIs为企业计算及电子商务应用系统提供了有关技术和丰富的类库。2. Winsock Windows下网络编程的标准Windows Sockets是Windows下得到广泛应用的、开放的、支持多种协议的网络编程接口。 通信的根底是套接口Socket,一个套接口是通讯的一端。在这一端上你可以找到与其对应的一个名字。一个正在被使用的套接口都有它的类型和与其相关的进程。套接口存在于通讯域中。通讯域是为了处理一般的线程通过套接口通讯而引进的一种抽象概念。在一次网络通信/连接中有以下几个参数需要被设置:本地IP地址 - 本地端口号 - 对方端口号 - 对方IP地址。左边两局部称为一个半关联,当与右边两局部建立连接后就称为一个全关联。在这个全关联的套接口上可以双向的交换数据。如果是使用无连接的通信那么只需要建立一个半关联,在发送和接收时指明另一半的参数就可以了,所以可以说无连接的通信是将数据发送到另一台主机的指定端口。此外不管是有连接还是无连接的通信都不需要双方的端口号一样。Socket 接口是 Internet 使用得最广泛的方法。3.多线程编程多线程8是为了使得多个线程并行的工作以完成多项任务,以提高系统的效率。线程是在同一时间需要完成多项任务的时候被实现的。使用线程的好处有以下几点:使用线程可以把占据长时间的程序中的任务放到后台去处理用户界面可以更加吸引人,这样比方用户点击了一个按钮去触发某些事件的处理,可以弹出一个进度条来显示处理的进度程序的运行速度可能加快在一些等待的任务实现上如用户输入、文件读写和网络收发数据等,线程就比拟有用了。在这种情况下我们可以释放一些珍贵的资源如内存占用等等。多线程在JAVA里面的应用也是很广泛。Java对多线程的支持是非常强大的,他屏蔽掉了许多的技术细节,让我们可以轻松的开发多线程的应用程序。1.2.4开发平台1. J2SE平台Java2平台包括:标准版J2SE、企业版J2EE和微缩版J2ME三个版本。J2SE,J2ME和J2EE,这也就是SunONE(Open NetEnvironment)体系。J2SE就是Java2的标准版,主要用于桌面应用软件的编程;J2ME主要应用于嵌入是系统开发,如手机和PDA的编程;J2EE是Java2的企业版,主要用于分布式的网络程序的开发,如电子商务和ERP系统。Standard Edition(标准版) J2SE 包含那些构成Java语言核心的类。比方:数据库连接、接口定义、输入/输出、网络编程定位在客户端,主要用于桌面应用软件的编程。J2SE 包含那些构成Java语言核心的类。 比方:数据库连接、接口定义、输入/输出、网络编程2. MYSQL数据库MYSQL9的特性MYSQL 的特性包括: Internet 集成。 SQL Server 2000 数据库引擎提供完整的 XML 支持。它还具有构成最大的 Web 站点的数据存储组件所需的可伸缩性、可用性和平安功能。MYSQL 程序设计模型与 Windows DNA 构架集成,用以开发 Web 应用程序,并且 MYSQL 支持 English Query 和 Microsoft 搜索效劳等功能,在 Web 应用程序中包含了用户友好的查询和强大的搜索功能。可伸缩性和可用性。 同一个数据库引擎可以在不同的平台上使用,从运行 Microsoft Windows 98 的便携式电脑,到运行 MYSQL 数据中心版的大型多处理器效劳器。MYSQL 企业版支持联合效劳器、索引视图和大型内存支持等功能,使其得以升级到最大 Web 站点所需的性能级别。企业级数据库功能。 MYSQL 关系数据库引擎支持当今苛刻的数据处理环境所需的功能。数据库引擎充分保护数据完整性,同时将管理上千个并发修改数据库的用户的开销减到最小。MYSQL 分布式查询使您得以引用来自不同数据源的数据,就好象这些数据是 MYSQL 数据库的一局部,同时分布式事务支持充分保护任何分布式数据更新的完整性。复制同样使您得以维护多个数据复本,同时确保单独的数据复本保持同步。可将一组数据复制到多个移动的脱接用户,使这些用户自主地工作,然后将他们所做的修改合并回发布效劳器。易于安装、部署和使用。 MYSQL 中包括一系列管理和开发工具,这些工具可改良在多个站点上安装、部署、管理和使用 SQL Server 的过程。MYSQL 还支持基于标准的、与 Windows DNA 集成的程序设计模型,使 MYSQL 数据库和数据仓库的使用成为生成强大的可伸缩系统的无缝局部。这些功能使您得以快速交付 MYSQL 应用程序,使客户只需最少的安装和管理开销即可实现这些应用程序。. v . .系统分析与设计2.1 需求分析此次开发的网络聊天工具可作为个人的交流工具使用,通信的平安性不是很高,但要求信息的响应速度要较快,让用户充分享受到网络即时消息的方便和快捷。本聊天工具由效劳器端程序和客户端程序两局部组成,整体采用JAVA平台开发,并使用MYSQL管理数据库数据。效劳器是可以监听和查看用户的根本操作;客户端程序面向实际用户,它有必要的界面的按钮,向用户提供网络即时消息的功能:本聊天需包含如下根本功能:1.客户端:(1)新用户注册;(2)用户登录验证;(3)获取好友列表并显示好友状态在线/不在线;(4)添加用户好友;(5)删除用户好友;(6)用户与好友聊天可查看聊天记录;(7)接收系统信息。2.效劳端:(1)启动和关闭后台效劳器;(2)查看客户端登录的相关信息客户端登陆时间/登陆IP;(3) 向所有在线用户发送系统消息。2.2系统总体框架2.2.1总体设计网络即时通讯系统采用客户机/效劳器C/S的模式来设计,是一个3层的C/S构造:数据库效劳器应用程序效劳器端应用程序客户端。系统采用C/S构造,可以将任务合理分配到客户机端和效劳器端,从而降低了系统的通信开销,如图3.1所示:图3.1 C/S体系构造1. 客户层客户层也叫应用层,是应用程序的用户接口局部。给聊天工具设计一个客户层具有很多优点,这是因为客户层担负着用户与应用间的对话功能。它用于检查用户的输入数据,显示应用的输出数据。为了使用户能直观地进展操作,客户层需要合作图形用户接口。假设聊天用户变更,系统只需要改写显示控制和数据检查程序即可,而不影响其他两层。数据检查的内容限于数据的形式和值的范围,不包括有关业务本身的处理逻辑。2效劳层效劳层也叫功能层,相当于应用的本体,它是将具体的业务处理逻辑编入程序中。例如,用户需要检索数据,系统设法将有关检索要求的信息一次性地传送给功能层;而用户登录后,聊天登录信息是由功能层处理过的检索结果数据,它也是一次性传送给表示层的。在应用设计中,必须防止表示层和功能层之间进展屡次的数据交换,这就需要尽可能进展一次性的业务处理,到达优化整体设计的目的。3. 数据层据层就是DBMS,本系统使用了Microsoft公司的SQL Server 2000数据库效劳器来管理数据。MYSQL能迅速执行大量数据的更新和检索。因此,从功能层传送到数据层的“要求一般都使用SQL语言。2.2.2功能模块聊天工具按如下过程完成通信:l 客户向效劳器注册,告知效劳器它在监听某主题;l 客户注册之后,向效劳器发送消息;l 效劳器再把消息发送给所有监听些主题的客户。聊天工具由效劳器端和客户端组成,要分析清楚两方面所要完成的任务,对设计来说,等于完成了一半。根据聊天的通信步骤,系统的功能模块如图3.2所示:即时消息系统效劳器端客户端后台操作建立连接.监听客户请求用户登录消息用户管理好友管理聊天功能用户登录用户注册查找好友添加好友删除好友发送消息接收消息聊天记录数据库操作发送系统消息消息管理图3.2 功能模块1.效劳器端效劳器完成5大功能:建立连接、监听客户请求、操作数据库、查看用户登录消息和发送系统消息这5大功能的具体含义如下:l 建立连接:系统启动时建立一个ServerSocket连接,绑定本地计算机的一个端口,不断侦听是否有客户端连接或者断开连接。l 监听客户请求:效劳器端是一个信息的枢纽,所有客户端的信息都要传到效劳器端,再由效劳器根据要求分发出去,客户端在向效劳器发送各种请求,如:上线、隐身、获取我的好友、查找好友等等。l 数据库操作:当客户机向效劳器发送请求时,效劳器需要通过数据库管理软件对数据库的数据进展增、删和查询。如录入用户信息、修改用户信息、查找好友数据库的资料以及添加好友数据到数据库等。l 用户登录消息:在效劳器端的界面上,我们可以看到用户的登录消息,包括IP地址、端口号,登录时间等。l 发送系统消息:在客户端管理界面上,可以输入消息,并发送给所有的在线用户。2.客户端客户端完成3大功能:用户管理、好友管理和聊天功能,这些功能的含义如下:l 用户管理:此功能又包括2个子功能,用户登录和用户注册。客户端与效劳器端建立通信通道,向效劳器发送新建用户的信息,接收来自效劳器听信息进展注册。注册完毕后,可以通过系统的登录界面,输入账号和密码,然后发送到效劳器进展验证。如果验证通过,那么翻开程序的主界面。l 好友管理:此功能又包括3个子功能,查找好友、添加好友和删除好友。在程序的主界面,提供查找好友的功能。查找好友时,客户端向效劳器发送查找好友请求,效劳器端返回在线用户的信息,此时我们可以通过此来进展添加好友,并跟好友通过通信连接。l 聊天功能:客户端在与好友端建立通信连接后,便可以与好友进展聊天,聊天时发送的是文本信息,好友端在接收到聊天消息后,会提示收到消息,并由好友端自主翻开消息接收界面。所有的聊天消息都会被保存起来,可以查看与每个好友的聊天记录。聊天记录包括内容和时间。2.3系统详细设计2.3.1多线程设计1.效劳器端的多线程效劳器需要和多个客户端同时进展通信,这就是效劳器端的多线程。一旦效劳器发现一个新的客户端与之建立了连接,就马上新建一个线程与客户端进展通信。用多线程的好处在于可以同时处理多个通信连接,不会出于由于数据排队而发生的延迟或者丧失,可以很好利用系统的性能。效劳器为每个连接着的客户建立一个线程,为了同时响应多个客户端,需设计一个主线程来启动效劳器端的多线程。主线程与进程构造类似,它在获得新连接时生成一个线程来处理这个这个连接。线程调度速度快,占用资源少,可共享进程空间中的数据,因此效劳器的响应速度较快,且I/O吞吐量较大。在程序的代码里面,效劳器端的多线程类定义为:Class ServerThread extends Thread/略;2.客户端的多线程客户端能够完成信息的接收和发送操作,这与效劳器的多线程概念不同,可以采用循环等待的方法来实现客户端。利用循环等待的方式,客户端首先接收用户输入的内容并将它们发送到效劳器端,然后接收来自效劳器端的信息,将其返回给客户端的用户。在程序的代码里面,客户端的多线程定义为:class MainWin extends JFrame implements Runnable/略;2.3.2数据库设计数据库表主要用来存放用户的注册信息和用户的好友资料,可利用两X数据表用来存放用户信息和用户好友资料。在MYSQL 上新建名为javaicq的数据库,并建立两X数据库表:用户的根本信息表表名icq和用户好友数据库表表名friend.1.icq表icq表存放用户信息,信息。利用MYSQL 2000建立数据表,如表3.1所示:表3.1 用户信息表字段数据类型说明Ipint用户IpIdchar用户的账号namechar用户的昵称Ipbit用户ip2.frind 表friend 表的设计比拟简单,本系统设计了用户的和好友的两个字段。利用SQL Server 2000建立如下数据表:表 3.2 好友信息表字段数据类型说明ipchar用户Ipidchar好友的账号2.3.3效劳器的设计1.主效劳器类的设计主效劳器实现了效劳器的多线程,效劳器端有一个进程或多个进程在指定的端口等待客户的连接信息。一时连接成功,就可以按设计的数据交换方法和格式进展数据传输。客户端只在需要的时候向效劳端发出连接请求。主效劳器类调用ServerThread类,而每个ServerThread实体就是一个单独的线程,即对应于客户端连接请求响应的线程。它的执行过程如下:l 使用ServerSocket s=new ServerSocket(8000)语句 绑定8000端口创立套接口l 使用Socket=s.accept()来监听用户的请求l 使用new ServerThread(socket)语句创立新的线程。2.ServerThread类的设计客户端发送连接请求的时候,效劳器端创立一个ServerThread(socket)线程。ServerThread类的函数执行过程可描述如下:l 执行ServerThreadz(Socket s)线程构造函数l 执行socket=s取得传递参数;l BufferedReader(new InputStreamReader(socket.getInputStream()创立输入流;l 使用PrintWriter(new BufferedWriter( new OutputStreamWriter( socket.getOoutputStream)创立输出流;l 使用start()函数启动线程;l 最后使用run()线程监听函数。3.登录验证1登录线程 如果客户端输入的字符串“login,表示需要登录,那么效劳器在接收到该信息后连接数据库,准备从数据库选择昵称和密码。效劳器接收到客户端发送过来的和密码信息后,设定数据库查寻条件,并执行数据库查寻,通过比拟输入的用户名和密码和数据库信息来确定用户的登录是否成功,如果成功就,发送“ok给客户端,通知其进入聊天主界面.反之发送“false,提示用户登录失败,如图3.3所示:客户端效劳器端Socket读取数据库,并验证账号与密码发送:“login接收:账号和密码接收:“login监听用户请求发送:账号和密码ServeSocket接收:“ok发送:“ok翻开程序主界面把IP地址和在线状态录入数据库数据库完毕通知好友图3.3 登录流程2通知好友通知好友也是在ServerThread类的run()函数里面,当某一用户成功登录后,发送“getwhoaddme到效劳器端,效劳器端查找数据库中的“friend数据表,并把用户的所有好友消息及在线状态发送回客户端,客户端通过这些好友的消息,向在线的好友发送上线通知。4.新建用户用户新建过程也在线程监听函数run()中。当效劳器端收到客户端发送的“new请求时,效劳器端开场进展新建用户操作。新建用户的过程是这样的:首先要使用权Class.forName方法加载数据库驱动类,该类的描述是sun.jdbc.odbc.JdbcOdbcDriver;然后使用DriverManager.getConnection方法连接数据,数据库名为jdbc:odbc:javaicq;最后效劳器接收客户端用户发送的昵称、密码、用户,个人资料、籍贯和头像等信息,执行数据库添加操作完成用户的创立。效劳器为新建的用户指定唯一的注册,将以即时消息的方法发送给用户。5.好友处理(1)查找好友当客户端向效劳器查找好友的请求后,效劳器立即响应并调Class.forName方法加载数据库驱动类sun.jdbc.odbc.JdbcOdbcDriver,然后调用方法DriverManager.getConnection完成数据库的连接,得到用户好友查询的结果。查询结果包括:好友的昵称、性别、性别、籍贯、个人资料等信息。效劳器对数据库听查询结果进展筛选,只向客户端的用户返回好友的注册、头像信息号以及是否在线信息。客户端接收到查询结果后,利用相应的函数将其显示出来。(2)添加好友读取资料功能是在查找好友功能根底上建立的。用户得到好友列表后,可根据需要读取好友的详细资料,也可读取用户自己的详细资料。效劳器使用Vector矢量保存客户端用户的好友,并返回好友的昵称、IP地址、状态、头像和个人资料等信息。(3)添加好友效劳器响应客户端用户的请求后,首先连接数据库,并根据接收的用户及好友向好友表添加记录。效劳器使用r6保存查询结果。假设r6为1,那么说明添加好友成功,效劳器将给客户端发出“ok addfriend的消息;否那么添加好友失败,效劳器将给客户端发出“falseaddfriend的消息。(4)添加好友应答如果效劳器收到其它用户添加我为好友的请求后,连接数据库,根据接收用户及好友向好友表添加记录。假设添加成功,那么向用户传递好友的根本信息,比方昵称。效劳器利用r5保存处理结果,并向客户端输出结果。(5)删除好友当效劳器承受到客户端删除好友请求后,它连接数据库,并根据接收的用户及好友表记录删除。效劳器利用r7保存删除结果,假设r7为1,那么删除成功,效劳器给客户端发出“ok delfriend的消息;否那么删除好友失败,效劳器给客户端发出“false delfriend的消息。接收好友处理请求addnewfrienddelfriendAddfriendfriendfind查找好友读取好友资料添加好友添加好友应答删除好友YesNoYesYesYesYesNoNoNo返回图3.4 处理好友请求6.退出下线用户在线时,数据库表的IP地址字段为此时用户计算机的真实IP地址;状态字段为1。假设用户退出下线,客户端向效劳器端发送“logout,效劳器接收到下线请求时,需完成修改IP字段和状态字段。效劳器首先利用Class.forName方法加载数据库驱动类sun.jdbc.odbc.JdbcOdbcDriver;然后通过方法DriverManager.getConnection连接数据库存;最后根据用户,将其状态字段设为0,IP地址字段设为空。2.3.4客户端的设计客户通过Socket与效劳器建立连接。效劳器与客户都通过构造BufferedReader、PrintWriter来建立输入/输出流,双方通过该输入/输出流来相互传递信息。一旦收到客户方的连接请求,效劳器利用accept()函数返回一个新建的Socket对象,随后客户端向效劳器发送消息,诸如注册、登录和查找好友等请求,效劳器收到请求后,针对不同的消息处理请求。在这一过程中,效劳器端与客户端采用UDP协议通信。虽然UDP协议不可靠,但对于聊天工具而言,其可靠性并不太重要。1.用户注册当效劳器收到用户的注册请求后,开场接收客户传递的消息,诸如客户的昵称、性别、籍贯、头像和个人资料等信息。接收完毕后,效劳器便通过JdbcOdbc与后台数据库连接,向数据库添加记录。假设新用户注册,那么向客户返回,并在数据库中注册用户的IP地址,设定Status值告知用户在线。客户收到效劳器返回的消息后,翻开主程序窗口,同时创立UDP以便在用户之间建立联系。注册通信过程如图3.5所示:Socket接收完毕发送:“new发送完毕接收:注册信息接收:“new监听用户请求发送:注册信息ServeSocket接收:账号输出:账号翻开登录界面完毕数据库操作客户端正效劳器端图3.5 注册流程2.用户登录用户在客户端程序中输入用户与密码,与效劳器建立连接,向效劳器发送登录请求。效劳器收到该请求后,通过JdbcOdbc读取数据库,与用户输入的消息做比拟:假设用户输入的信息与数据库信息一样,那么效劳器向客户返回成功消息,将其Status字段设为1,并注册用户当前的IP地址;否那么效劳器向客户返回失败消息。客户端收到效劳器的成功确认后,翻开聊天主窗口;否那么弹出失败信息。客户端事件驱动与效劳器端的事件监听相对应。3.效劳器连接效劳器连接是在ConnectServer()函数中实现的。本函数用到了具有连接性、有序性特点的流,根据效劳器的IP地址和端口来完成客户端与效劳器的连接。IP地址是网络中唯一地址的标识。效劳器连接过程分效劳器端与客户端两局部,执行流程如下:1效劳器程序流程l 程序初始化;l 填写本机地址信息;l 绑定并监听一个固定的端口;l 收到Client的连接后建立一个Socket连接;l 产生一个新的进程与Client进展通信和信息处理;l 子通信完毕后中断与Client的连接。2客户端程序流程:l 程序初始化;l 填写效劳器地址消息;l 连接效劳器;l 与效劳器通信和信息处理;l 通信完毕后断开连接。4.主程序设计用户完成登录后, 客户端与效劳器端建立连接。连接建立成功后,客户向效劳器请求读取好友;效劳器收到该请求,开场读取数据库中的friend表并得到好友的,再通过jcq表读取好友资料,向客户端发送这些信息;客户收到效劳器消息后,在主窗口显示好友。客户端还建立矢量来存储好友的昵称、,头像编号和IP地址等信息。5好友管理1查找好友好友查找可利用FindFriend2 类完成,FindFriend2类继承自JFrame类。FindFriend2中定义的界面控件包括:好友的昵称、性别、住址、Jicq、IP地址、在线状态、头像、电子和个人留言等信息。查找好友所需的网络变量定义如下:Socket socket: 连接socketBufferedReader in;读入缓冲区PrintWriter out;输入缓冲区int myid;用户的String serverhost:发送端的主机地址int servport:效劳端的主机地址DatagramPacket sendPacket:存储发送信息的发送数据报DatagramSocket sendSocket:存储接收信息的接收数据报int sendPort:发送的端口号2添加好友用户添加好友是聊天工具的根本功能之一。添加好友的根本步骤如下:用户A登录后,向效劳器发送查找请求,效劳器响应并读取数据库表icq,将结果返回给用户;用户在收到查询结果后选择用户B,向效劳器发送添加好友请求,效劳器收到请求响应,更新数据表frriend,并从icq表中读取好友根本信息,将信息返回给用户A;用户A的客户端主窗口显示用户B,并通过UDP通知用户B;用户B收到效劳器确实认消息,可决定是否添加用户A为好友。3删除好友用户可以删除好友列表中指定的好友,客户端确认用户操作后向效劳器发送删除请求,效劳器收到该请求,连接数据库表friend并删除用户及该好友的记录。假设删除成功,那么向客户端返回成功消息,通知用户。2.3.5消息通信的设计消息的发送主要是通过数据报效劳来实现的。JAVA实现数据报通信的过程除面向连接的Socket外,还有无连接的数据报Socket。数据报是网络层数据单元在介质上传输信息的逻辑分组格式,它是是一种在网络中传播的、独立的自身包含地址信息的消息,它能否到过目的地,到过的时间,到过内容是否变化是不能准确知道的。数据报的通信双方不需要建立连接,对于像聊天通信这些不需要很高质量的应用程序来说,数据报通信是一个非常好的选择。1、使用数据报在java的包中有两个类DatagramSocket和DatagramPacket,它们为应用程序采用数据报通信方式进展网络通信提供了支持。其定义定义如下:DatagramPacket sendPacket,receivePacket;DatagramSocket sendSocket,receiveSocket;int udpPORT=5001;int sendPort=5000;sendSocket=new DatagramSocket();receiveSocket=new DatagramSocket(udpPORT);2、发送消息用户通过好友列表中好友的IP地址,利用UDP协议与其他用户进展信息交流。消息发送之前先创立一个数据报文包,用来实现无连接的包传送效劳。每个数据报文包是用DatagramPacket类来创立的,DatagramPacket对象封装了数据报包数据、包长度、目标地址和目标端口。假设客户端发送数据包,那么构造函数创立DatagramPacket对象,将需要发送的数据和包文目的地址信息放入对象之中。在发送的过程中利用构造函数DatagramPacketbyte bufferedarray,int length,InetAddressaddress,int port构造一个包长度为length的包,它是将数据传送到指定端口号上的数据包,参数length必须小于等于bufferedarry.length.消息发送是通过调用DatagramPacket对象中有send方法实现的,它需要以DatagramPacket对象为参数,将刚刚封装进DatagramPacket对象中的数据组成数据报发出。发送数据报文包的局部代码如下:sendPacket=newDatagramPacket(data,data.length,InetAddress.getByName(theip.trim(),sendPort);sendSocket.send(sendPacket);/*data为数据报文包,data.length为数据报文包的长度InetAddress.getByName(theip.trim()为获取接收者的IP地址;sendPort为数据报文包接收者的接收端口。*/发送消息流程如下列图所示:从输入消息对话框读取信息获取好友的IP地址在线不?发送消息完毕是否保存聊天记录图3.6 发送消息3.监听好友的消息为了监听好友的消息,系统首先定义一个数组,该数组用于接收用户消息中的数据;然后创立数据报,使用receiveSocket.recerive(receivePacket)函数等待并接收数据报,取得数据报中的数据。接收数据报文包的局部代码如下:receivePacket=new DatagramPacket(array,array.length);receiveSocket.receive(receivePacket);byte data=receivePacket.getData(); String infofromip= receivePacket.getAddress().getHostAddress(). toString().trim();received=new String(data,0,data.length);/*其中receivePacket用来接收其它客户端发送过来的数据报文包;data用来储存数据报文包的数据;infofromip用来获取数据报文包的发送地址;received用于储存二进制类型数据转换为字符串类型后数据。*/监听好友消息的流程如图3.7所示:接收数据报信息addnewfriendsystemoneaddyouofflineoneline好友上线好友下线添加好友应答添加好友应答接收系统消息YesNoYesYesYesYesNoNoNo查找对应好友及其登记IPIP存在接收好友消息接收陌生人消息else图3.7 监听好友消息1当接收好友消息时,主程序弹出一个对话框,由用户自行选择接收信息与否,用户可根据消息提示,翻开相应好友的接收消息对话框来接收消息。l DatagramPacket类提供了4个函数来获得消息:l Public bye getDate(): 返回一个字节数组,包含收到或要发送的数据报中的数据;l Public int getLength(): 返回发送或收到的数据的长度;l Public InetAddress getAddress(); 返回一个发送或接收此数据报报文的机器的IP地址;l Public int getPort(): 返回发送或接收数据报的远程主机的端口号。接收消息的流程图3.8所示:监听到好友发送过来的消息翻开接收消息对话框,接收消息。接收不?保存聊天记录完毕是否图3.8 接收消息2上线和隐身当用户想处于非聊天状态的时候,可以切换至隐身状态。这时候,用户的客户端会查找所有在线的好友,并发制作数据包,发送“隐身要求给所有好友的客户端。在好友的程序界面上,用户的头像由彩色变成黑白。此时,所有好友都无法发送消息给此用户。当用户想点击程序界面的“上线按钮时,既可通知所有的好友此用户上线了。. v .
展开阅读全文