认识达内从这里开始

昆明达内培训的老师这一期给大家讲Java Socket实现基于TCP和UDP多线程通信。

一.通过Socket实现TCP编程

1.1 TCP编程

TCP协议是面向连接，可靠的，有序的，以字节流的方式发送数据。基于TCP协议实现网络通信的类有客户端的Socket类和服务器端的ServerSocket类。

1.2服务器端套路

1.创建ServerSocket对象，绑定监听端口。

2.通过accept（）方法监听客户端请求。

3.连接建立后，通过输入流读取客户端发送的请求信息。

4.通过输出流向客户端发送响应信息。

5.关闭响应的资源。

1.3客户端套路

1.创建Socket对象，指明需要连接的服务器的地址和端口号。

2.连接建立后，通过输出流向服务器发送请求信息。

3.通过输入流获取服务器响应的信息。

4.关闭相应资源。

1.4多线程实现服务器与多客户端之间通信步骤

1.服务器端创建ServerSocket，循环调用accept（）等待客户端连接。

2.客户端创建一个socket并请求和服务器端连接。

3.服务器端接受客户端请求，创建socket与该客户建立专线连接。

4.建立连接的两个socket在一个单独的线程上对话。

5.服务器端继续等待新的连接。

1.5创建处理线程类ServerThread

这里选择实现runnable接口而不是继承Thread是因为一个类只能继承一个父类，当我需要继承其他类的时，父类就就不好处理了。

1.6创建服务器端类

使用while以达到可以循环侦听不同客户端的连接请求。因为这是一个死循环，所以不用关闭也没有机会去关闭serverSocket。设置count值，用于记录服务器端被连接过的次数并显示客户端所在ip值。如果线程处理类是继承Thread类，那么创建新线程代码可以改为ServerThread serverThread = new ServerThread(socket);serverThread.start();

1.7创建客户端类

在后面的关闭资源中，我把输入输出相关的流关闭注释了，是因为对于同一个Socket，关闭socket的时候也会把输入输出流关闭，直接关闭socket就行，当然保留也是可以的。

1.8先运行服务器端，在运行客户端

此时在看服务器控制台：服务器端一直在循环侦听客户端的连接

1.9进行第二个客户端的连接

修改相应信息将用户名zzh改为admin。运行客户端，打开服务端控制台

输出客户端的ip都为127.0.0.1，是因为服务器和客户端都是本机，在真实的环境中会显示客户端的ip地址信息。

二.通过Socket实现UDP编程

2.1 UDP编程

UDP协议又叫用户数据报协议，是无连接，不可靠的，无序的。特点是传输速度相对要快，UDP协议以数据报作为数据传输的载体。当进行数据传输时，首先需要将要传输的数据定义成数据报（Datagram），在数据报中指明数据所要达到的Socket（主机地址和端口号），然后再将数据报发送出去。相关操作类有：DatagramPacket数据报包，DatagramSocket进行端到端通信的类。

2.2服务器端实现套路

1.创建DatagramSocket，指定端口号。2.创建DatagramPacket。3.接收客户端发送的数据信息。4.读取数据。

2.3客户端实现套路

1.定义发送信息，比如发送地址，端口号和内容。2.创建DatagramPacket，包含将要发送的信息。3.创建DatagramSocket。4.发送数据。

2.4多线程实现服务器与多客户端之间通信步骤

1.服务器端创建DatagramSocket的实例socket，循环调用receive（）方法，此方法在接收到数据报之前会一直阻塞。

2.客户端创建DatagramSocket，将含有地址，端口号和内容的数据报包发送出去。

3.服务器端收到数据报包packet，通过DatagramSocket和packet与客户端建立一个线程

4.服务器端继续等待新的数据报包。

5.发送方的DatagramPacket构造方法传递四个参数包含数据内容，数据大小，地址和端口号。接收方的DatagramPacket构造方法有两个参数接收数据和数据大小。

2.5创建服务器线程处理类UDPThread

注意，DatagramSocket的实例socket不能关闭，会出现SocketException。读取数据用到的new String(packet.getData(), 0, packet.getLength())，参数表示数据报中的字节数组，位置和长度。

2.6创建服务器端类

之前我将new DatagramSocket放入了while循环中，报了java.net.BindException: Address already in use: Cannot bind，才知道不能在while中连续创建新的DatagramSocket对象。

2.7创建客户端类2.8先运行服务器端，在运行客户端

2.9修改客户端信息，再次运行客户端

服务器控制台：服务器端一直在循环等待接收客户端的数据。

三.总结

对于同一个socket，如果关闭了输出流比如（pw.close()），则与该输出流关联的socket也会关闭，所以一般不需要关闭输出流，当关闭socket的时候，输出流也会关闭，直接关闭socket就行。

在使用TCP通信传输信息时，更多是使用对象的形式来传输，可以使用ObjectOutputStream对象序列化流来传递对象，比如ObjectOutputStream os = new ObjectOutputStream（socket.getOutputStream()）;User user = ew User("admin","123"); os.writeObject(user);