第四章 事件处理

第9章Socket编程本章提要◆客户/服务器模型◆Java编写客户应用程序◆Java编写服务器应用程序本章知识要点客户/服务器模型TCP/IP协议族套接字（Socket）Java编写客户应用程序Java编写服务器应用程序9.1客户/服务器模型客户/服务器模型客户/服务器模型的主要思想是要将应用程序的数据表示与数据处理和数据存储分开。客户方主要是向服务器发出数据处理请求。服务器方则是对数据处理请求进行接收，然后做出相应处理。TCP/IP协议族国际标准化组织(ISO)制订了开放系统互连(OpenSystemsInterconnection)参考模型应用层表示层会话层传输层网络层数据链路层物理层OSI参考模型协议协议就是约定，就是双方为了协调地做一件事情而共同遵循的规则。Telnet、SMTP、HTTP、FTP…….套接字（Socket）TCP/UDPIP/ICMP数据链路层和物理层TCP/IP协议族套接字（Socket）套接字包含主机地址与服务端口号。在Internet中，主机地址就是客户程序或服务器程序所在的主机的IP地址。端口与则是主机彼此通信时所有的通口服务器套接字客户机套接字客户/服务器通信模式著名端口所对应的应用端口号应用21FTP，传输文件23Telnet，远程登录25SMTP，邮件服务67BOOTP，提供引导时配置80HTTP，web服务109POP，远程访问邮件Socket类Socket是支持TCP协议的基本类。Socket类提供了一些进行流输入/输出的方法。ServerSocket类ServerSocket是一个用于监听客户请求的Internet服务器程序的类。作为服务器方程序必须使用ServerSocket类。ServerSocket实际上并不执行数据通信工作，它仅仅接收客户请求，然后为客户创建一个相对应的Socket对象。9.2创建服务器应用程序案例——用户注册模块之服务器端提出问题我们要开发用户注册模块中的服务器端应用，以实现远程用户通过Applet将信息保存到中心数据中。服务器程序需要用Java来开发，以下是服务器功能：（1）服务器应能够接收远程客户机上发来的用户资料。（2）服务器应能够将用户资料保存在customer.dat文件中。（3）服务器是多线程的，能够同时满足多个客户机的访问。（4）服务器在端口2001上运行。分析问题确定创建服务器所要使用的类创建服务器确定监听机制确定数据通信机制监听请求二线程一线程二线程三请求一请求三服务器程序设计模型图解决问题1.创建服务器所要使用的类2.创建服务器类3.确定监听机制4.确定数据通信机制5.完成服务器程序6.验证程序创建服务器所要使用的类ServerSocket类ServerSocket请求Socket数据通信通道建立客户创建Socketocket通信过程方法目的ServerSocket(intport)在指定端口建立一个服务器套接字。有多个请求时，来不及处理的请求存入队列。本构造函数构造的套接字存放连接请求的了列长为50。如果队列已满，到达的请求将被拒绝。ServerSocket(intport,intbacklog)在指定端口建立一个服务器套接字。backlog是存放连接请求的队列长。ServerSocket(intport,intbacklog,InetAddressbindAddr)在指定端口建立一个服务器套接字。backlog是存放连接请求队列长。本构造函数适用于有多个IP地址的主机，bindAddr指定仅接受对某一地址的连接。Socketaccept()使服务器套接字监听客户连接并接收它。并创建一新的套接字与客户建立连接。InetAddressgetInetAddress()返回服务器套接字的本地主机地址。intgetLocalPort()返回正在监听的端口。voidclose()关闭服务器套接字。StringtoString()返回服务器套接字的IP地址和端口号。synchronizedintgetSoTimeout()返回SO_TIMEOUT的值。该变量用于设定超时限制。当其值大于0时，accept()方法阻塞时仅阻塞设定的时间。如其值为0，阻塞将是无限期的。synchronizedvoidsetSoTimeout(inttimeout)throwsSocketException设定SO_TIMEOUT的值。ServerSocket类中提供的方法列表accept（）方法accept（）方法是阻塞方式，当有连接请求过来时才执行返回。它将创建一个新的套接字与客户套接字建立通信。当有很多请求发往服务器时，服务器套接字（ServerSocket）将创建多个新的套接字与不同的客户进行通信。创建服务器类classMyServerextendsThread{publicMyServer(){try{//创建ServerSocket对象，监听端口为2001serverSocket=newServerSocket(2001);}catch(IOExceptione){System.out.println(“serverisnotstart”+e);}System.out.println(“Serverislistening…”);this.start();//引发监听线程}}确定监听机制服务器的run()方法主要是进行监听工作。publicvoidrun(){try{//无限循环while(true){//调用了阻塞方式的accept()方法Socketclient=serverSocket.accept();//accept()接收到客户请求返回，创建DataCommutation对象DataCommutationcom=newDataCommutation(client);com.start();}}catch(IOExceptione){System.out.println(“listeningiserror”+e);}}确定数据通信机制DataCommutation线程类主要是在服务器套接字建立好连接之后，负责与客户端的一切通信工作。//DataCommutation线程类代码ClassDataCommutationextendsThread{Customercustomer=null;//定义对象输入流类ObjectInputStreamstreamFromClient=null;PublicDataCommutation(SocketinFromClient){try{//将套接字对象输入流创建为对象输入流streamFromClient=newObjectInputStream(inFromClient.getInputStream());try{//从输入流读取对象customer=(Customer)streamFromClient.readObject();}//捕捉异常……}//捕捉异常……}publicvoidrun(){try{//创建文件输出流对象，customer.dat是存放资料的文件FileOutputStreamfp=newFileOutputStream(“customer.dat”);//将文件输出流创建为对象输出流ObjectOutputStreamstreamOutputFile=newObjectOutputStream(fp);//输出customer对象到文件streamOutputFile.writeObject(customer);//关闭流对象streamOutputFile.close();fp.close();}//捕捉异常……}}//DataCommutation线程类结束知识点ObjectInputStream类ObjectOutputStream类InvalidClassException异常类NotSerializableException异常类单元练习我们要开发航班资料录入模块中的服务器端应用，以实现公司工作人员将航班信息保存到中心数据中。服务器程序需要用Java来开发，以下是服务器功能：（1）服务器应能够接收前台客户机上发来的航班资料。（2）服务器应能够将航班资料保存在flightInfor.dat文件中。（3）服务器是多线程的，能够同时满足多个客户机的访问。（4）服务器在端口2001上运行。9.3编写客户端应用程序案例---用户注册模块之客户端提出问题用户注册界面已经生成，现在需要确定按钮触发处理程序。即当用户填写完注册资料后，点击确定，注册信息应该发送到远程服务器端应用程序，由服务器程序将注册信息保存。分析问题打包数据将注册信息打包成一个类对象，即实现面向对象中的封装特性。连接服务器程序通过Socket向服务器发送连接请求发送数据连接一旦建立成功，马上发送注册信息给服务器。解决问题确定创建客户机所要使用的类确定要提交的数据何时向服务器提交数据确定创建客户机所要使用的类创建客户机的过程就是创建一Socket对象。语法示例：SocketclientSocket=newSocket(“172.16.10.1”,1001);方法描述publicSocket(InetAddressaddress,intport)建立一个流套接字并把它连接到地址为address的主机的指定端口。port为端口号。publicInetAddressgetInetAddress()返回套接字所连接的远程主机地址。publicInputStreamgetInputStream()返回该套接字的输入流。publicInetAddressgetLocalAddress()返回套接字连接的本地主机地址。publicintgetLocalPort()返回套接字所连接的本地主机端口。publicOutputStreamgetOutputStream()返回该套接字的输出流。publicintgetPort()返回套接字所连接的远程主机端口。Socket类包含的构造函数和基本方法打包数据客户资料是以对象的形式发送，所以数据必须被写入到Customer对象中，然后发送给服务器。classCustomerimplementsjava.io.Serializable{StringcustomID;Stringname;Stringsex;Stringage;Stringaddress;Stringphone;Stringe_mail;}//网络上传输的对象必须实现java.io.Serializable接口确定向服务器提交数据的机制当用户点击submit按钮时，连接服务器，向服务器发送数据。publicvoidactionPerformed(ActionEventevt){Objectobj=evt.getSource();if(obj==buttonSubmit){//创建一Customer对象，将客户资料写入Customer对象try{//创建一客户套接字，连接服务器SockettoServer=newSocket(127.0.0.1,2001);//创建对象输出流，将数据写入套接字ObjectOutputStreamstreamToServer=NewObjectOutputStream(toServer.getOutputStream());streamToServer.writeObject(customer);//关闭对象输出流streamToServer.close();}}}单元练习我们要开发航班资料录入模块中的客户端应用，以实现公司工作人员将航班信息保存到中心数据中。航班资料录入界面已经生成，请加入事件处理代码。小结java.net包的ServerSocket类用于创建一个套接字以让服务器监听客户的请求。ServerSocket类的accept（）方法返回对客户的套接字的引用，它是So