详解Java网络编程

tangjin

作者

一、网络编程

1.1、概述

1、计算机网络是通过传输介质、通信设施和网络通信协议，把分散在不同地点的计算机设备互连起来，实现资源共享和数据传输的系统。网络编程就就是编写程序使联网的两个(或多个)设备(例如计算机)之间进行数据传输。Java语言对网络编程提供了良好的支持，通过其提供的接口我们可以很方便地进行网络编程。

2、Java是 Internet 上的语言，它从语言级上提供了对网络应用程序的支持，程序员能够很容易开发常见的网络应用程序。

3、Java提供的网络类库，可以实现无痛的网络连接，联网的底层细节被隐藏在 Java 的本机安装系统里，由 JVM 进行控制。并且 Java 实现了一个跨平台的网络库，程序员面对的是一个统一的网络编程环境。

1.2、计算机网络基础

1、概念

把分布在不同地理区域的计算机与专门的外部设备用通信线路互连成一个规模大、功能强的网络系统，从而使众多的计算机可以方便地互相传递信息、共享硬件、软件、数据信息等资源。

计算机网络是计算机专业必修的一门学科！里面涉及到计算机之间的通信、网络安全等方方面面，有时间可以自行去学习，关于更多的网络基础知识这里就不一一介绍了。

2、网络编程的目的

直接或间接地通过网络协议与其它计算机实现数据交换，进行通讯。

3、网络编程中有两个主要的问题

①如何准确地定位网络上一台或多台主机；定位主机上的特定的应用

②找到主机后如何可靠高效地进行数据传输

1.3、网络通信要素概述

1、我们需要知道的是主机间通过网络进行通信是需要遵循网络通信协议，是通过IP地址准确定位主机，通过端口号准确定位主机上的应用。

IP地址和端口号

网络通信协议

2、如何实现网络中的主机互相通信？

① 通信双方地址：IP和端口号

② 一定的规则（即：网络通信协议。有两套参考模型）

OSI参考模型：模型过于理想化，未能在因特网上进行广泛推广。

TCP/IP参考模型(或TCP/IP协议)：事实上的国际标准。

3、网络通信协议(以TCP/IP模型为例)

TCP/IP，即Transmission Control Protocol/Internet Protocol的简写，中译名为传输控制协议/因特网互联协议，是Internet最基本的协议、Internet国际互联网络的基础。

1.4、IP地址和端口号(组合就是网络套接字)

我们知道IP地址和端口号是通信要素之一，它们可以唯一确定某一台主机的某个应用，并为主机之间通信提供了可能！那么什么是IP地址和端口号呢？

1、IP 地址：InetAddress(在Java中使用InetAddress类代表IP)

2、InetAddress类

Internet上的主机有两种方式表示地址：

①域名(hostName)：www.baidu.com

②IP 地址(hostAddress)：14.215.177.38

InetAddress类主要表示IP地址，两个子类：Inet4Address、Inet6Address

InetAddress 类对象含有一个 Internet 主机地址的域名和IP地址：www.baidu.com 和 14.215.177.38

域名容易记忆，当在连接网络时输入一个主机的域名后，域名服务器(DNS) 负责将域名转化成IP地址，这样才能和主机建立连接。 -------域名解析

/* 1 java中使用InetAddress代表IP 2 IP的分类：IPV4和IPV6 万维网和局域网 3 域名：www.baidu.com www.cnblogs.com 4 本地回路地址：127.0.0.1 对应着：localhost 5 如何实例化InetAddress类的对象，两个静态方法： InetAddress getByName(String host) InetAddress getLocalHost() 6 两个常用方法 getHostName() getHostAddress() 7 端口号：正在计算机上运行的进程 */ public class InetAddressTest { public static void main(String[] args){ try { // File file = new File("test.txt"); InetAddress IP1 = InetAddress.getByName("192.168.3.2"); System.out.println(IP1); InetAddress IP2 = InetAddress.getByName("www.baidu.com"); System.out.println(IP2); // 获取本地IP InetAddress localHost = InetAddress.getLocalHost(); System.out.println(localHost); // getHostName() System.out.println(IP2.getHostName()); // getHostAddress() System.out.println(IP2.getHostAddress()); } catch(UnknownHostException e){ e.printStackTrace(); } } }

3、端口号

端口分类：

① 公认端口：0~1023。被预先定义的服务通信占用（如：HTTP占用端口 80，FTP占用端口21，Telnet占用端口23）

② 注册端口：1024~49151。分配给用户进程或应用程序。（如：Tomcat占用端口8080，MySQL占用端口3306，Oracle占用端口1521等）。

③ 动态/私有端口：49152~65535

4、端口号与IP地址的组合得出一个网络套接字：Socket

1.5、网络协议

1、网络通信协议

计算机网络中实现通信必须有一些约定，即通信协议，对速率、传输代码、代码结构、传输控制步骤、出错控制等制定标准。

2、问题：网络协议太复杂

计算机网络通信涉及内容很多，比如指定源地址和目标地址，加密解密，压缩解压缩，差错控制，流量控制，路由控制，如何实现如此复杂的网络协议呢？

3、通信协议分层的思想

在制定协议时，把复杂成份分解成一些简单的成份，再将它们复合起来。最常用的复合方式是层次方式，即同层间可以通信、上一层可以调用下一层，而与再下一层不发生关系。各层互不影响，利于系统的开发和扩展。

4、TCP/IP协议簇

传输层协议中有两个非常重要的协议：

TCP/IP 以其两个主要协议：传输控制协议(TCP)和网络互联协议(IP)而得名，实际上是一组协议，包括多个具有不同功能且互为关联的协议。

IP(Internet Protocol)协议是网络层的主要协议，支持网间互连的数据通信。

TCP/IP协议模型从更实用的角度出发，形成了高效的四层体系结构，即物理链路层、IP层、传输层和应用层。

5、TCP 和 UDP

TCP协议：

✔ 使用TCP协议前，须先建立TCP连接，形成传输数据通道

✔ 传输前，采用“三次握手”方式，点对点通信，是可靠的

✔ TCP协议进行通信的两个应用进程：客户端、服务端。

✔ 在连接中可进行大数据量的传输

✔ 传输完毕，需释放已建立的连接，效率低

UDP协议：

✔ 将数据、源、目的封装成数据包，不需要建立连接

✔ 每个数据报的大小限制在64K内

✔ 发送不管对方是否准备好，接收方收到也不确认，故是不可靠的

✔ 可以广播发送

✔ 发送数据结束时无需释放资源，开销小，速度快

1.6、三次握手与四次挥手

1、三次握手

第一步，请求端（客户端）发送一个包含SYN标志的TCP报文，SYN即同步（Synchronize），同步报文会指明客户端使用的端口以及TCP连接的初始序号；

第二步，服务器在收到客户端的SYN报文后，将返回一个SYN+ACK的报文，表示客户端的请求被接受，同时TCP序号被加一，ACK即确认（Acknowledgment）。

第三步，客户端也返回一个确认报文ACK给服务器端，同样TCP序列号被加一，到此一个TCP连接完成。

2、四次挥手

由于TCP连接是全双工的，因此每个方向都必须单独进行关闭。这原则是当一方完成它的数据发送任务后就能发送一个FIN来终止这个方向的连接。收到一个 FIN只意味着这一方向上没有数据流动，一个TCP连接在收到一个FIN后仍能发送数据。首先进行关闭的一方将执行主动关闭，而另一方执行被动关闭。

1.TCP客户端发送一个FIN，用来关闭客户到服务器的数据传送。

2.服务器收到这个FIN，它发回一个ACK，确认序号为收到的序号加1。和SYN一样，一个FIN将占用一个序号。

3.服务器关闭客户端的连接，发送一个FIN给客户端。

4.客户端发回ACK报文确认，并将确认序号设置为收到序号加1。

二、TCP网络编程

2.1、Socket介绍

1、利用套接字(Socket)开发网络应用程序早已被广泛的采用，以至于成为事实上的标准。

2、网络上具有唯一标识的IP地址和端口号组合在一起才能构成唯一能识别的标识符套接字。

3、通信的两端都要有Socket，是两台机器间通信的端点。

4、网络通信其实就是Socket间的通信。

5、Socket允许程序把网络连接当成一个流，数据在两个Socket间通过IO传输。

6、一般主动发起通信的应用程序属客户端，等待通信请求的为服务端。

7、Socket分类：

2.2、基于Socket的TCP编程

1、Java语言的基于套接字编程分为服务端编程和客户端编程，其通信模型如图所示

2、客户端Socket的工作过程包含以下四个基本的步骤：

3、客户端创建Socket对象:

客户端程序可以使用Socket类创建对象，创建的同时会自动向服务器方发起连接。Socket的构造器是：

// 构造器一 Socket(String host,int port)throws UnknownHostException,IOException /* 向服务器(域名是 host。端口号为port)发起TCP连接，若成功，则创建Socket对象，否则抛出异常。*/ // 构造器二 Socket(InetAddress address,int port)throws IOException /* 根据InetAddress对象所表示的 IP地址以及端口号port发起连接。*/

客户端建立socketAtClient对象的过程就是向服务器发出套接字连接请，简要步骤如下

Socket s = new Socket("192.168.40.165",9999); // 1、创建Socket对象，指明服务端的IP和端口号 OutputStream out = s.getOutputStream(); // 2、获取一个输出流，用于输出数据 out.write("hello".getBytes()); // 3、写出数据 s.close(); // 4、回收资源

4、服务器(服务端)程序的工作过程包含以下四个基本的步骤：

5、服务器建立 ServerSocket 对象

ServerSocket 对象负责等待客户端请求建立套接字连接，类似邮局某个窗口中的业务员。也就是说，服务器必须事先建立一个等待客户请求建立套接字连接的ServerSocket对象。

所谓“接收”客户的套接字请求，就是accept()方法会返回一个 Socket 对象

ServerSocket ss = new ServerSocket(9999); // 1、创建服务端的ServerSocket，指明自己的端口号 Socket s = ss.accept (); // 2、调用accept()监听来自客户端的连接 InputStream in = s.getInputStream(); // 3、获取输入流，读取输入流的数据 byte[] buf = new byte[1024]; int num = in.read(buf); String str = new String(buf,0,num); System.out.println(s.getInetAddress().toString()+":"+str); s.close(); // 4、回收资源 ss.close();

2.3、TCP编程简单C/S通信示例

/** * @description: TCP编程，模拟基于C/S架构客户端与服务端间的通信 */ public class SocketTest { /* 客户端 */ @Test public void client(){ OutputStream output = null; Socket socket = null; try { InetAddress localHost = InetAddress.getByName("127.0.0.1"); socket = new Socket(localHost,8848); output = socket.getOutputStream(); output.write("hello I'm the client".getBytes()); } catch (IOException e) { e.printStackTrace(); } finally { if(output != null){ try { output.close(); } catch (IOException e) { e.printStackTrace(); } } if(socket != null){ try { socket.close(); } catch (IOException e) { e.printStackTrace(); } } } } /* 服务端 */ @Test public void server() { ServerSocket serverSocket = null; Socket socket = null; InputStream input = null; ByteArrayOutputStream out = null; try { serverSocket = new ServerSocket(8848); socket = serverSocket.accept(); System.out.println("client IP: " + socket.getInetAddress()); input = socket.getInputStream(); /* 一般不建议这样书写，数据传输时可能会出现乱码！！ byte[] buffer = new byte[1024]; int len; while((len = input.read(buffer)) != -1){ String data = new String(buffer,0,len); System.out.println(data); }*/ out = new ByteArrayOutputStream(); byte[] buffer = new byte[10]; int len; while((len = input.read(buffer)) != -1){ out.write(buffer,0,len); } System.out.println(out.toString()); } catch (IOException e) { e.printStackTrace(); } finally { if(out != null){ try { out.close(); } catch (IOException e) { e.printStackTrace(); } } if(input != null){ try { input.close(); } catch (IOException e) { e.printStackTrace(); } } if(socket != null){ try { socket.close(); } catch (IOException e) { e.printStackTrace(); } } if(serverSocket != null){ try { serverSocket.close(); } catch (IOException e) { e.printStackTrace(); } } } } }

2.4、TCP编程实现C/S文件传输

实现功能：客户端发送文件给服务端，服务端将文件保存在本地。

/** * @description: TCP编程，客户端发送文件给服务端，服务端将文件保存在本地。 */ public class TCPSocketTest { /* 客户端 */ @Test public void client() { Socket socket = null; OutputStream writer = null; BufferedInputStream bis = null; try { socket = new Socket(InetAddress.getByName("127.0.0.1"),8089); writer = socket.getOutputStream(); bis = new BufferedInputStream(new FileInputStream(new File("me.jpg"))); byte[] buffer = new byte[1024]; int len; while((len = bis.read(buffer)) != -1){ writer.write(buffer,0,len); } } catch (IOException e) { e.printStackTrace(); } finally { if(socket != null){ try { socket.close(); } catch (IOException e) { e.printStackTrace(); } } if(writer != null){ try { writer.close(); } catch (IOException e) { e.printStackTrace(); } } if(bis != null){ try { bis.close(); System.out.println("发送成功！"); } catch (IOException e) { e.printStackTrace(); } } } } /* 服务端 */ @Test public void server() throws IOException { // 这里异常应该使用try-catch-finally ServerSocket socket = new ServerSocket(8089); System.out.println("正在等待客户端连接..."); Socket clientSocket = socket.accept(); System.out.println("客户端已连接IP地址为："+clientSocket.getInetAddress().getHostName()); InputStream is = clientSocket.getInputStream(); BufferedOutputStream reader = new BufferedOutputStream(new FileOutputStream(new File("new_me.jpg"))); byte[] buffer = new byte[1024]; int len; while((len = is.read(buffer)) != -1){ reader.write(buffer,0,len); } System.out.println("接收成功"); socket.close(); clientSocket.close(); is.close(); reader.close(); } }

2.5、TCP编程实现C/S信息反馈

实现功能：从客户端发送文件给服务端，服务端保存到本地。并返回“发送成功”给客户端。并关闭相应的连接。

/** * @description: TCP编程，从客户端发送文件给服务端，服务端保存到本地。并返回“发送成功”给客户端。并关闭相应的连接。 */ public class TCPSocketTest2 { /* 客户端 */ @Test public void client() { Socket socket = null; OutputStream writer = null; BufferedInputStream bis = null; try { socket = new Socket(InetAddress.getByName("127.0.0.1"),8089); writer = socket.getOutputStream(); bis = new BufferedInputStream(new FileInputStream(new File("me.jpg"))); byte[] buffer = new byte[1024]; int len; while((len = bis.read(buffer)) != -1){ writer.write(buffer,0,len); } // 关闭数据的输出 socket.shutdownOutput(); // 接收服务端反馈的信息并输出到控制台 InputStream is = socket.getInputStream(); ByteArrayOutputStream byteArray = new ByteArrayOutputStream(); byte[] buf = new byte[10]; int l; while((l = is.read(buf)) != -1){ byteArray.write(buf,0,l); } System.out.println(byteArray.toString()); is.close(); byteArray.close(); } catch (IOException e) { e.printStackTrace(); } finally { if(socket != null){ try { socket.close(); } catch (IOException e) { e.printStackTrace(); } } if(writer != null){ try { writer.close(); } catch (IOException e) { e.printStackTrace(); } } if(bis != null){ try { bis.close(); System.out.println("发送成功！"); } catch (IOException e) { e.printStackTrace(); } } } } /* 服务端 */ @Test public void server() throws IOException { // 这里异常应该使用try-catch-finally ServerSocket socket = new ServerSocket(8089); System.out.println("正在等待客户端连接..."); Socket clientSocket = socket.accept(); System.out.println("客户端已连接IP地址为："+clientSocket.getInetAddress().getHostName()); InputStream is = clientSocket.getInputStream(); BufferedOutputStream reader = new BufferedOutputStream(new FileOutputStream(new File("new_me.jpg"))); byte[] buffer = new byte[1024]; int len; while((len = is.read(buffer)) != -1){ reader.write(buffer,0,len); } System.out.println("接收成功"); // 服务端给客户端反馈信息 OutputStream os = clientSocket.getOutputStream(); os.write("你好客户端，照片已经收到".getBytes()); socket.close(); clientSocket.close(); is.close(); reader.close(); os.close(); } }

三、UDP网络编程

3.1、UDP网络通信

1、类 DatagramSocket 和 DatagramPacket 实现了基于 UDP 协议网络程序。

2、UDP数据报通过数据报套接字 DatagramSocket 发送和接收，系统不保证 UDP数据报一定能够安全送到目的地，也不能确定什么时候可以抵达。

3、DatagramPacket 对象封装了UDP数据报，在数据报中包含了发送端的IP地址和端口号以及接收端的IP地址和端口号。

4、UDP协议中每个数据报都给出了完整的地址信息，因此无须建立发送方和接收方的连接。如同发快递包裹一样。

3.2、UDP网络通信流程

1、DatagramSocket与DatagramPacket

2、建立发送端，接收端

3、建立数据包

4、调用Socket的发送、接收方法

5、关闭Socket

注意：发送端与接收端是两个独立的运行程序

3.3、UDP网络通信代码实现

/* UDP网络编程： ✔ 将数据、源、目的封装成数据包，不需要建立连接 ✔ 每个数据报的大小限制在64K内 ✔ 发送不管对方是否准备好，接收方收到也不确认，故是不可靠的 ✔ 可以广播发送 ✔ 发送数据结束时无需释放资源，开销小，速度快 */ public class UDPSocketTest { @Test // 发送端 public void send() throws IOException { DatagramSocket socket = new DatagramSocket(); byte[] data = "hello world".getBytes(); DatagramPacket packet = new DatagramPacket(data,0,data.length, InetAddress.getLocalHost(),8080); socket.send(packet); socket.close(); } @Test // 接收端 public void receiver() throws IOException { DatagramSocket socket = new DatagramSocket(8080); byte[] buffer = new byte[100]; DatagramPacket packet = new DatagramPacket(buffer,0,buffer.length); socket.receive(packet); System.out.println(new String(packet.getData(),0,packet.getLength())); socket.close(); } }