Java网络程序设计 课件 单元9-04Socket编程

Socket编程单元九基于TCP的Socket编程目录CONTENTS1基于UDP的Socket编程29.4.1基于TCP的Socket编程

根据ServerSocket用于服务器端，而Socket是建立网络连接时使用的。在连接成功时，应用程序两端都会产生一个Socket实例，操作这个实例，完成所需的会话。对于一个网络连接来说，套接字是平等的，不因为在服务器端或在客户端而产生不同级别。不管是Socket还是ServerSocket,它们的工作都是通过Socketlmp1类及其子类完成的。关于Socket、ServerSocket及Socketlmp1类的具体方法，这里不再一一介绍，需要这些类时，请大家自行查阅JDKAPI文档。9.4.1基于TCP的Socket编程

图9.7展示了基于TCP的Socket编程的示意图。图9.7基于TCP的Socket编程

在服务器端,创建一个ServerSocket对象，并指定一个端口号，使用ServerSocket类的accept()服务器处于阻塞状态，等待用户请求。

在客户端，通过指定一个InetAddress对象和一个端口号，创建一个Socket对象，通过这个Socket对象，连接到服务器。9.4.1基于TCP的Socket编程

首先我们来看服务器端程序，具体代码如下：import.*;importjava.io.*;publicclassTestServer{publicsaticvoidmain(Stringargs[]){try{//创建一个ServerSocket对象，并端口号8888ServerSockets=newServerSocket(8888);while(true){//侦听并接受到此套接字的连接Sockets1=s.accept();OutputStreamos=s1.getOutputStream();DataOutputStreamdos=newDataOutputStream(os);dos.writeUTF("客户端IP:"+s1.getInetAddress().getHostAddress()+"客户端端口号："+s1.getPort());dos.close();sl.close();}}catch(IOExceptione){e.printStackTrace();System.out.println("程序运行出错！");}}}9.4.1基于TCP的Socket编程

该服务器端程序的作用就是监听8888端口，当有发送到本机8888端口的Socket请求时,建立输出流，将通过accept()方法创建的Socket对象的IP地址和端口号输出到客户端。编译、运行程序，使服务器启动并处于监听状态。下面编写客户端程序9.4.1基于TCP的Socket编程

import.*;importjava.io.*;publicclassTestClient{publicstaticvoidmain(Stringargs[]){try{//通过IP地址和端口号，创建一个Socket对象Sockets1=newSocket("127.0,0.1",8888);//建立输入数据流InputStreamis=s1.getInputStream();DataInputStreamdis=newDataInputStream(is);System.out.println(dis.readUTF());dis.close();s1.close();}catch(ConnectExceptione){e.printStackTrace();System.err.println("服务器连接失败！");}catch(IOExceptione){e.printStackTrace();}}}9.4.1基于TCP的Socket编程

该客户端程序通过IP地址和端口号8888，创建一个客户端Socket对象，建立输入数据流，通过输入数据流读取指定1P地址和端口号上服务器端程序的输出，并在控制台将服务器的输出显示出来。编译、运行程序，结果如图9.8所示。图9.8使用JavaSocket编程9.4.1基于TCP的Socket编程

在这个通过JavaSocket编程实现的客户端、服务器端程序中，客户端没有请求的具体内容，只要有请求，服务器就将指定的内容发送给客户端，客户端将接收的内容显示出来。接下来对上面的案例进行调整，服务器端可以接收客户端请求的内容，并显示在服务器端控制台上。具体服务器端程序代码如下：importjava.io.*;import.*;publicclassTestSockServer{publicstaticvoidmain(String[]args){InputStreamin=null;OutputStreamout==null;try{ServerSockets=newServerSocket(8888);Sockets1=s.accept();in=s1.getInputStream();out=s1.getOutputStream();DataOutputStreamdos=newDataOutputStream(out);DataInputStreamdis=newDataInputStream(in);Stringstr=null;if((str=dis.readUTF())!=null){System.out.println("客户端输入内容："+str);System.out.println("客户端IP:"+s1.getInetA,ddress().getHostAddress());System.out.println("客户端端口号："u+s1.getPort());}dos.writeUTF("服务器端反馈客户端！");dis.close();dos.close();s1.olose();}catch(IOExceptione){e.printStackTrace();}}}9.4.1基于TCP的Socket编程

客户端代码如下：import.*;importjava.io.*;publicclassTestSockClient{publicstaticvoidmain(String[]args){InputStreamis=null;OutputStreamos=null;Strings=null;try{Socketsocket=newSocket("localhost",8888);is=socket.getInputStream();os=socket.getOutputStream();DataInputStreamdis=newDataInputStream(is);DataOutputStxeamdos=newDataOutputStream(os);//客户端向服务器端发送请求的内容dos.writeUTF("客户端提交服务器");if((s=dis.readUTF())!=null)System.out.println(s);dos.close();dis.close();socket.close();}catch(UnknownHostExceptione){e.printStackTrace();}catch(IOExceptione){e.printStackTrace();}}}9.4.1基于TCP的Socket编程

编译、运行服务器端、客户端程序，运行结果如图9.9和图9.10所示。图9.9Socket编程服务器端图9.10Socket编程客户端9.4.2基于UDP的Socket编程

UDP是用户数据报协议，它提供的是无连接、不可靠信息传送服务。Java主要提供了两个类来实现基于UDP的Socket编程。 DatagramSocket：此类表示用来发送和接收数据报包的套接字。数据报套接字是包投递服务的发送或接收点，每个在数据报套接字上发送或接收的包都是单独编址和路由的。从一台机器发送到另一台机器的多个包可能选择不同的路由，也可能按不同的顺序到达。在DatagramSocket上总是启用UDP广播发送。 DatagramPacket：此类表示数据报包。数据报包用来实现无连接包投递服务，每条报文仅根据该包中包含的信息从一台机器路由到另一台机器。9.4.2基于UDP的Socket编程

图9.11展示了基于UDP的Socket编程的示意图。图9.11基于UDP的Socket编程9.4.2基于UDP的Socket编程

DatagramPacket类主要有两个构造函数。

一个用来接收数据DatagramPacket(byte[]recyBuf,intreadLength),用一个字节数组接收UDP包，recyBuf数组在传递给构造函数时是空的，而readLength值用来设定要读取的字节数。

一个用来发送数据DatagramPacket(byte[]sendBuf，intsendLength,InetAddressiaddr,intport),建立将要传输的UDP包，并指定IP地址和端口号。

接下来通过一个案例，演示Java如何实现基于UDP的Socket编程9.4.2基于UDP的Socket编程import.*;importjava.io.*;publicclassTestUDPServer{publicstaticvoidmain(Stringargs[])throwsException{//创建数据报包的套接字，端口号8888DatagramSocketds=newDatagramSocket(8888);bytebuf[]=newbyte[1024];//创建接收的数据报包DatagramPacketdp=newDatagramPacket(buf,buf.length);System.out,println("务器端：");while(true){//从此套接字接收数据报包ds.receive(dp);ByteArrayInputStreambais=newByteAirayInputStream(buf);DataInputStreamdis=newDataInputStream(bais);System.out.println(dis.readLong());}}}import.*;importjava.io.*;publicclassTestUDPClient{publicstaticvoidmain(Stringargs[])throwsException{longn=10000L;ByeArrayOutputStreambaos=newByteArrayOutputStream();DataOutputStreamdos=newDataOutputStream(baos);dos.writeLong(n);byte[]buf=baos.toByteArray();System.cmt.println("客户端:");System.out.println(buf.length);//创建数据报包的套接字，端口号9999DatagramSocketds=newDatagramSocket(9999);//创建发送的数据报包DatagramPacketdp=newDatagramPacket(buf,buf.length,newInetSock