Java 网络编程（TCP编程和 UDP编程）

张国伟 · 2024-7-18 14:14:34

1. Java 网络编程（TCP编程和 UDP编程）

@
目次

2. 网络编程的概念

什么是网络编程？

网络编程是指利用计算机网络实现程序之间通信的一种编程方式。在网络编程中，程序需要通过网络协议（如 TCP/IP）来进行通信，以实现差异计算机之间的数据传输和共享。

在网络编程中，通常有三个基本要素：

IP 地址：定位网络中某台计算机

端口号 port：定位计算机上的某个历程（某个应用）

通信协议：通过IP地址和端口号定位后，怎样保证数据可靠高效的传输，这就需要依靠通信协议了。

3. IP 地址

IP 地址用于唯一标识网络中的每一台计算机。在 Internet 上，利用 IPv4 或 IPv6 地址来表现 IP 地址。通常 IPv4 地址格式为 xxx.xxx.xxx.xxx，其中每个 xxx 都表现一个 8 位的二进制数（每一个xxx的取值范围是0-255），组合起来可以表现 2^32 个差异的 IP 地址。
IPv4 地址的总数量是4294967296 个，但并不是全部的 IPv4 地址都可以利用。IPv4 地址被分为网络地址和主机地址两部分，前3个字节用于表现网络（省市区），最后1个字节用于表现主机（家门牌）。而一些 IP 地址被保存或者被私有机构利用，不能用于公网的地址分配。另外，一些 IP 地址被用作多播地址，仅用于特定的应用场景。因此实际上可供利用的 IPv4 地址数量要少于总数量，而且随着 IPv4 地址的徐徐枯竭，IPv6 地址已经开始徐徐普及，IPv6 地址数量更是相当巨大。
IPv6利用16个字节表现IP地址(128位)，这样就解决了网络地址资源数量不够的问题。IPv6 地址由 8 组 16 位十六进制数表现，每组之间用冒号分隔，如：3ffe:3201:1401:1280:c8ff:fe4d:db39:1984
本机地址：127.0.0.1，主机名：localhost。
192.168.0.0-192.168.255.255为私有地址，属于非注册地址，专门为构造机构内部利用。
3.1 IP地址相关的：域名与DNS

域名：
IP地址毕竟是数字标识，利用时不好记忆和书写，因此在IP地址的底子上又发展出一种符号化的地址方案，来代替数字型的IP地址。每一个符号化的地址都与特定的IP地址对应。这个与网络上的数字型IP地址相对应的字符型地址，就被称为域名。
目前域名已经成为互联网品牌、网上商标掩护必备的要素之一，除了识别功能外，另有引导、宣传等作用。如：www.baidu.com
DNS：
在Internet上域名与IP地址之间是一对一（或者多对一）的，域名虽然便于人们记忆，但机器之间只能互相认识IP地址，它们之间的转换工作称为域名解析，域名解析需要由专门的域名解析服务器来完成，DNS（Domain Name System域名系统）就是进行域名解析的服务器，域名的最终指向是IP。
4. 端口号（port）

在计算机中，差异的应用程序是通过端口号区分的。
端口号是用两个字节（无符号）表现的，它的取值范围是0~65535，而这些计算机端口可分为3大类：

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

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

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

通常情况下，服务器程序利用固定的端口号来监听客户端的请求，而客户端则利用随机端口连接服务器。
IP地址好比每个人的地址（门牌号），端口好比是房间号。必须同时指定IP地址和端口号才可以或许正确的发送数据。接下来通过一个图例来描述IP地址和端口号的作用。
5. 通信协议

通过计算机网络可以使多台计算机实现连接，位于同一个网络中的计算机在进行连接和通信时需要遵守一定的规则。就像两个人想要顺遂沟通就必须利用同一种语言一样，如果一个人只懂英语而另外一个人只懂中文，这样就会造成没有共同语言而无法沟通。
在计算机网络中，这些连接和通信的规则被称为网络通信协议，它对数据的传输格式、传输速率、传输步调等做了统一规定，通信双方必须同时遵守才气完成数据互换。
在计算机网络中，常用的协议有 TCP、UDP、HTTP、FTP 等。这些协议规定了数据传输的格式、传输方式和传输顺序等细节。其中，TCP（传输控制协议）是一种可靠的面向连接的协议，它提供数据传输的完备性保证；而 UDP（用户数据报协议）则是一种无连接的协议，传输效率高。在网络编程中，需要选取合适的协议范例来实现数据传输。
5.1 通信协议相关的：OSI 参考模子

世界上第一个网络体系布局由IBM公司提出（1974年，SNA），以后其他公司也相继提出自己的网络体系布局如：Digital公司的DNA，美国国防部的TCP/IP等，多种网络体系布局并存，其结果是若采用IBM的布局，只能选用IBM的产物，只能与同种布局的网络互联。
为了促进计算机网络的发展，国际标准化构造ISO（International Organization for Standardization）于1977年建立了一个委员会，在现有网络的底子上，提出了不基于具体机型、操作系统或公司的网络体系布局，称为开放系统互连参考模子，即OSI/RM （Open System Interconnection Reference Model）。OSI模子把网络通信的工作分为7层，分别是物理层、数据链路层、网络层、传输层、会话层、表现层和应用层。
5.2 通信协议相关的：TCP / IP 参考模子

OSI 参考模子的初衷是提供全世界范围的计算机网络都要遵循的统一标准，但是由于存在模子和协议自身的缺陷，迟迟没有成熟的产物推出。TCP/IP协议在实践中不停完善和发展取得成功，作为网络的底子，Internet的语言，可以说没有TCP/IP参考模子就没有互联网的今天。
TCP/IP，即Transmission Control Protocol/Internet Protocol的简写，中译名为传输控制协议/因特网互联协议，是Internet最基本的协议、Internet国际互联网络的底子。
TCP/IP协议是一个开放的网络协议簇，它的名字主要取自最重要的网络层IP协议和传输层TCP协议。TCP/IP协议界说了电子设备怎样连入因特网，以及数据怎样在它们之间传输的标准。TCP/IP参考模子采用4层的层级布局，每一层都呼唤它的下一层所提供的协议来完成自己的需求，这4个层次分别是：网络接口层、互联网层（IP层）、传输层（TCP层）、应用层。
OSI模子与TCP/IP模子的对应关系如图所示：

5.3 补充：OSI 参考模子与 TCP / IP 参考模子区别

OSI 参考模子是理论上的，而 TCP/IP 参考模子是实践上的。TCP/IP 参考模子被许多实际的协议（如 IP、TCP、HTTP 等）所支持和实现，而 OSI 参考模子则主要是作为理论框架和标准进行研究和讨论。
OSI 参考模子是由国际标准化构造提出的网络通信协议框架，其中分为 7 层，各层之间明确了功能的划分，从物理层到应用层，逐层向上升，每层只对自己下一层提供服务，并依次封装息争封数据。OSI 参考模子是一种理论上的协议框架，用于描述计算机系统间的通信原理和规范。
TCP/IP 参考模子（也称互联网参考模子）是实际应用中最广泛的协议框架。它将网络协议划分为 4 层：网络接口层、网络层、传输层和应用层。TCP/IP 参考模子与 OSI 参考模子之间有着相对应的层次布局，但是其中的每一层都是实际存在的协议，而不是纯粹的框架。TCP/IP 参考模子被广泛应用于互联网上，是计算机系统间进行通信的重要底子。

6. 网络编程底子类

6.1 InetAddress类

java.net.IntAddress 类用来封装计算机的IP地址和DNS（没有端口信息），它包括一个主机名和一个IP地址，是j ava对IP地址的高层表现。大多数其它网络类都要用到这个类，包括Socket、ServerSocket、URL、DatagramSocket、DatagramPacket等

常用静态方法：

static InetAddress getLocalHost() 得到本机的InetAddress对象，其中封装了IP地址和主机名

static InetAddress getByName(String host) 传入目标主机的名字或IP地址得到对应的InetAddress对象，其中封装了IP地址和主机名（底层会自动连接DNS服务器进行域名解析）

常用实例方法：

public String getHostAddress() 获取IP地址

public String getHostName() 获取主机名/域名

编写运行测试：

package day34.com.rainbowsea.javase.net;
import java.net.InetAddress;
import java.net.UnknownHostException;
/**
* java.net.IntAddress类用来封装设计计算机IP地址和DNS（没有端口信息）
* 它包括一个主机名和一个地址，是Java对IP地址的高层表示，大多数其它
* 网络类都要用到这个类，包括 Socket，ServerSocket，URL.DatagramSocket，DatagramPacket等
*/
public class InetAddressTest {
public static void main(String[] args) throws UnknownHostException {
// 获取本机的IP地址和主机名的封装对象: InetAddress
InetAddress inetAddress = InetAddress.getLocalHost();
// 获取本机的IP地址
String hostAddress = inetAddress.getHostAddress();
System.out.println("本机IP地址: " + hostAddress);
// 获取本机的主机名
String hostName = inetAddress.getHostName();
System.out.println("本机的主机名: " + hostName);
// 通过域名来获取InetAddress 对象
InetAddress inetAddress2 = InetAddress.getByName("www.baidu.com");
System.out.println(inetAddress2.getHostName()); // www.baidu.com
System.out.println(inetAddress2.getHostAddress()); // 36.155.132.3
}
}

复制代码

6.2 URL 类

URL 是统一资源定位符 ，对可以从互联网上得到的资源的位置和访问方法的一种简便的表现，是互联网上标准资源的地址。互联网上的每个文件都有一个唯一的URL，它包含的信息指出文件的位置以及欣赏器应该怎么处置惩罚它。
URL由4部分组成：协议、存放资源的主机域名、端口号、资源文件名。如果未指定该端口号，则利用协议默认的端口。比方HTTP协议的默认端口为80。在欣赏器中访问网页时，地址栏显示的地址就是URL。
URL标准格式为：://:/ 。其中，://是必需的，/有时可省略。如：https://www.baidu.com。
为了方便程序员编程，JDK中提供了URL类，该类的全名是java.net.URL，该类封装了大量复杂的涉及从长途站点获取信息的细节，可以利用它的各种方法来对URL对象进行分割、合并等处置惩罚。
URL类的构造方法：URL url = new URL(“http://127.0.0.1:8080/oa/index.html?name=zhangsan#tip”);
URL类的常用方法：

获取协议：url.getProtocol()

获取域名：url.getHost()

获取默认端口：url.getDefaultPort()

获取端口：url.getPort()

获取路径：url.getPath()

获取资源：url.getFile()

获取数据：url.getQuery()

获取锚点：url.getRef()

编写运行测试：

package day34.com.rainbowsea.javase.net;
import java.net.MalformedURLException;
import java.net.URL;
/**
* URL包括四部分：协议:IP地址:端口:资源名称
* URL是网络中某个资源的地址，某个资源的唯一地址
* 通过URL是可以真实的定位到资源的
* 在Java中，Java类库提供了一个URL类，来提供对URL的支持
* URL的类的构造方法:
* URL url = new URL("url");
* URL类的常用方法
*/
public class URLTest {
public static void main(String[] args) throws MalformedURLException {
URL url = new URL("http://www.baidu.com/oa/index.html?name=lihua&passwrod=123#tip");
// 获取URL中的信息
String protocol = url.getProtocol();
System.out.println("协议: " + protocol);
// 获取资源路径
String path = url.getPath();
System.out.println("资源路径: " + path);
// 获取默认端口(HTTP协议的默认端口是80,HTTPS的协议端口是:443)
int defaultPort = url.getDefaultPort();
System.out.println("默认端口: " + defaultPort);
// 获取当前的端口
int port = url.getPort();
System.out.println("当前端口号: " + port);
// 获取URL中的IP地址
String host = url.getHost();
System.out.println("主机地址: " + host);
// 获取URL准备传送的数据
String query = url.getQuery();
System.out.println("需要提交给服务器的数据: " + query);
String ref = url.getRef();
System.out.println("获取锚点: " + ref);
// 获取资源路径 + 数据
String file = url.getFile();
System.out.println("获取数据资源文件路径: " + file);
}
}

复制代码

利用URL类的 openStream()方法可以打开到此URL的连接并返回一个用于从该连接读入的InputStream，实现最简单的网络爬虫。
编写运行测试：

package day34.com.rainbowsea.javase.net;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.MalformedURLException;
import java.net.URL;
public class URLTest2 {
public static void main(String[] args) throws IOException {
// 使用URL类的openStream()方法可以打开到此URL的连接并返回一个用于从该连接读入的InputStream，实现最简单的网络爬虫
URL url = new URL("https://tianqi.qq.com/");
InputStream inputStream = url.openStream();
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
String s = null;
while ((s = bufferedReader.readLine()) != null) {
System.out.println(s);
}
bufferedReader.close();
}
}

复制代码

7. TCP 与 UDP协议

7.1 Socket 套接字概述

我们开辟的网络应用程序位于应用层，TCP和UDP属于传输层协议，在应用层怎样利用传输层的服务呢？在应用层和传输层之间，则是利用套接Socket来进行分离。
套接字就像是传输层为应用层开的一个小口，应用程序通过这个小口向长途发送数据，或者接收长途发来的数据。而这个小口以内，也就是数据进入这个口之后，或者数据从这个口出来之前，是不知道也不需要知道的，也不会关心它怎样传输，这属于网络其它层次工作。
Socket实际是传输层供给应用层的编程接口。Socket就是应用层与传输层之间的桥梁。利用Socket编程可以开辟客户机和服务器应用程序，可以在当地网络上进行通信，也可通过Internet在全球范围内通信。
TCP协议和UDP协议是传输层的两种协议。Socket是传输层供给应用层的编程接口，以是Socket编程就分为TCP编程和UDP编程两类。
7.2 TCP 与 UDP协议的区别

TCP协议：

利用TCP协议，须先创建TCP连接，形成传输数据通道，似于拨打电话

传输前，采用“三次握手”方式，属于点对点通信，是面向连接的，效率低。

仅支持单播传输，每条TCP传输连接只能有两个端点（客户端、服务端）。

两个端点的数据传输，采用的是“字节流”来传输，属于可靠的数据传输。

传输完毕，需释放已创建的连接，开销大，速率慢，适用于文件传输、邮件等。

UDP协议：

采用数据报（数据、源、目的）的方式来传输，无需创建连接，类似于发短信。

每个数据报的大小限定在64K内，超出64k可以分为多个数据报来发送。

发送不管对方是否准备好，接收方即使收到也不确认，因此属于不可靠的。

可以广播发送，也就是属于一对一、一对多和多对一连接的通信协议。

发送数据结束时无需释放资源，开销小，速率快，适用于视频会议、直播等。

7.3 补充：TCP协议的三次握手（通道创建）

TCP（传输控制协议）是一种面向连接的、可靠的传输层协议。它利用三次握手来创建连接，以确保数据在两个设备之间可靠地传输。
三次握手的过程如下：

客户端发送 SYN（同步）数据包。这个数据包包含客户端的初始序列号（ISN）。

服务器收到 SYN 数据包后，发送 SYN-ACK（同步确认）数据包。这个数据包包含服务器的初始序列号（ISN）和对客户端 ISN 的确认号（ACK）。

客户端收到 SYN-ACK 数据包后，发送 ACK（确认）数据包。这个数据包包含对服务器 ISN 的确认号（ACK）。三次握手完成后，客户端和服务器就可以开始互换数据了。

可以四次，五次握手都可以，握手的目的就是为了，确保连接的创建。至于为什么是三次，因为三次握手就足够可以确保连接的成功创建了。多握频频，也是可以，但是会增加时间，效率上的开销。

三次握手的意义：

三次握手可以确保数据在两个设备之间可靠地传输。它可以防止以下情况的发生：

不会丢失：如果没有三次握手，客户端和服务器大概会同时发送数据，导致数据丢失。

不会重复：如果没有三次握手，客户端和服务器大概会重复发送数据，导致数据重复。

不会乱序：如果没有三次握手，客户端和服务器大概会乱序发送数据，导致数据乱序。

7.4 补充：TCP协议的四次挥手（通道关闭）

利用四次挥手来关闭连接，以确保数据在两个设备之间可靠地传输。
四次挥手的过程如下：

客户端发送 FIN（结束）数据包。这个数据包表现客户端已经完成数据传输，并希望关闭连接。

服务器收到 FIN 数据包后，发送 ACK（确认）数据包。这个数据包表现服务器已经收到客户端的 FIN 数据包，并同意关闭连接。

服务器发送 FIN 数据包。这个数据包表现服务器已经完成数据传输，并希望关闭连接。

客户端收到 FIN 数据包后，发送 ACK（确认）数据包。这个数据包表现客户端已经收到服务器的 FIN 数据包，并同意关闭连接。四次挥手完成后，客户端和服务器之间的连接就关闭了。

同理，五次，六次...等等挥手都可以，挥手的：目的就是为了，确保连接的关闭，不丢失数据。至于为什么是四次，因为四次挥手就足够可以确保全部的连接关闭了，数据不丢失。多挥频频，也是可以，但是会增加时间，效率上的开销。

四次挥手的意义：

四次挥手可以确保数据在两个设备之间可靠地传输。它可以防止以下情况的发生：

如果没有四次挥手，客户端和服务器大概会同时关闭连接，导致数据丢失。

如果没有四次挥手，客户端和服务器大概会重复发送数据，导致数据重复。

如果没有四次挥手，客户端和服务器大概会乱序发送数据，导致数据乱序。

8. TCP协议编程

套接字是一种历程间的数据互换机制，利用套接字(Socket)开辟网络应用程序早已被广泛的采用，以至于成为毕竟上的标准。
在网络通讯中，第一次主动发起通讯的程序被称作客户端(Client)，而在第一次通讯中等候连接的程序被称作服务端(Server)。一旦通讯创建，则客户端和服务器端完全一样，没有本质的区别。
套接字与主机地址和端口号相关联，主机地址就是客户端或服务器程序地点的主机的IP地址，端口地址是指客户端或服务器程序利用的主机的通信端口。在客户端和服务器中，分别创建独立的Socket，并通过Socket的属性，将两个Socket进行连接，这样客户端和服务器通过套接字所创建连接并利用IO流进行通信。
8.1 Socket类概述

Socket类实现客户端套接字(Client），套接字是两台机器间通信的端点
Socket类构造方法：

public Socket(InetAddress a, int p) // 创建套接字并连接到指定IP地址的指定端口号

复制代码

Socket类实例方法：

public InetAddress getInetAddress() // 返回此套接字连接到的远程 IP 地址。
public InputStream getInputStream() // 返回此套接字的输入流（接收网络消息）。
public OutputStream getOutputStream() // 返回此套接字的输出流（发送网络消息）。
public void shutdownInput() // 禁用此套接字的输入流
public void shutdownOutput() // 禁用此套接字的输出流。
public synchronized void close() // 关闭此套接字（默认会关闭IO流）。

复制代码

8.2 ServerSocket 类概述

ServerSocket 类用于实现服务器套接字(Server服务端)。服务器套接字等候请求通过网络传入。它基于该请求执行某些操作，然后大概向请求者返回结果。
ServerSocket构造方法：

public ServerSocket(int port)

复制代码

ServerSocket实例方法：

public Socket accept() // 侦听要连接到此套接字并接受它。
public InetAddress getInetAddress() // 返回此服务器套接字的本地地址。
public void close() // 关闭此套接字。

复制代码

9. 基于TCP协议的编程

9.1基于 TCP协议的单向通讯的实现

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

服务器端实现步调：

创建ServerSocket对象，绑定并监听端口；

通过accept监听客户端的请求；

创建连接后，通过输出输入流进行读写操作；

调用close()方法关闭资源。

服务器端的代码编写如下：

package day34.com.rainbowsea.javase.net.onewaycommunication;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
public static void main(String[] args) {
ServerSocket serverSocket = null;
Socket clientSocket = null;
BufferedReader bufferedReader = null;
try {
// 先启动服务端，启动服务器端后，这个应用肯定要对应一个端口
// 创建服务器端套接字对象
int port = 8888; // 指明端口
serverSocket = new ServerSocket(port);
System.out.println("服务器端正在启动,请稍后...");
System.out.println("服务器端启动成功,端口号: " + port + "，等待客户端的请求");
// 开始接收客户端的请求
clientSocket = serverSocket.accept();
// 后续代码怎么写一会再说？
// 服务端接收消息，所以服务端应该获取输入流
bufferedReader = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
// 开始读
String s = null;
while ((s = bufferedReader.readLine()) != null) {
System.out.println(s);
}
} catch (IOException e) {
throw new RuntimeException(e);
} finally {
// 关闭服务端套接字
try {
serverSocket.close();
} catch (IOException e) {
throw new RuntimeException(e);
}
try {
clientSocket.close();
} catch (IOException e) {
throw new RuntimeException(e);
}
try {
bufferedReader.close();
} catch (IOException e) {
throw new RuntimeException(e);
}
}
}
}

复制代码

客户端实现步调：

创建Socket对象，指定服务端的地址和端口号；

创建连接后，通过输入输出流进行读写操作；

通过输出输入流获取服务器返回信息；

调用close()方法关闭资源。

客户端的代码编写如下：

package day34.com.rainbowsea.javase.net.onewaycommunication;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.OutputStreamWriter;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;
/**
* 现在使用Java中的 Socket实现单向通信，基于 TCP协议，属于TCP编程
*/
public class Client {
public static void main(String[] args) {
Socket clientSocket = null;
BufferedWriter bufferedWriter = null;
Scanner scanner = new Scanner(System.in);
// 创建客户端套接字对象
// 需要指定服务器的IP地址，和端口号
try {
InetAddress localHost = InetAddress.getLocalHost();
int port = 8888;
clientSocket = new Socket(localHost, port);
// 客户端给服务器端发送信息
// 客户端你是输出流
bufferedWriter = new BufferedWriter(new OutputStreamWriter(clientSocket.getOutputStream()));
// 发送信息
/* bufferedWriter.write("你好，最近怎么样");
bufferedWriter.write("\n");
bufferedWriter.write("你收到消息了吗");*/
// 循环发送信息
/* while (true) {
bufferedWriter.write("你好，最近怎么样");
bufferedWriter.write("\n");
bufferedWriter.write("你收到消息了吗");
// 因为使用了缓存机制，需要记得刷新
bufferedWriter.flush();
// 延迟效果
Thread.sleep(1000);
}*/
// 键盘中输入信息，发送给服务器端
while (true) {
System.out.println("请输入您要发送的信息: ");
// 从键盘上接收的消息
String msg = scanner.next();
// 把消息发送给服务器端
bufferedWriter.write(msg);
bufferedWriter.write("\n"); // 换行
// 刷新
bufferedWriter.flush();
}
// 因为使用了缓存机制，需要记得刷新
//bufferedWriter.flush();
} catch (UnknownHostException e) {
throw new RuntimeException(e);
} catch (IOException e) {
throw new RuntimeException(e);
} finally {
try {
clientSocket.close();
} catch (IOException e) {
throw new RuntimeException(e);
}
try {
bufferedWriter.close();
} catch (IOException e) {
throw new RuntimeException(e);
}
scanner.close();
}
}
}

复制代码

运行测试：
注意：一定是先启动服务器程序，然后再启动客户端程序，先后顺序千万别弄混了！

9.2 基于 TCP协议的双向通讯的实现

在双向通讯的案例中，客户端需要向服务端发送一张图片，服务端收到客户端发送的图片后，则需要向客户端复兴收到图片的反馈。在客户端给服务端发送图片的时候，图片发送完毕必须调用shutdownOutput()方法来关闭socket输出流，否则服务端读取数据就会一直壅闭。
服务器端实现步调：

创建ServerSocket对象，绑定监听端口；

通过accept()方法监听客户端请求；

利用输入流接收客户端发送的图片，然后通过输出流生存图片

通过输出流返回客户端图片收到。

调用close()方法关闭资源

服务端的代码编写：

package day34.com.rainbowsea.javase.net.twowaycommunication;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.BufferedWriter;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
/**
* 双向通信
*/
public class TwoWayServer {
public static void main(String[] args) {
ServerSocket serverSocket = null;
Socket clientSocket = null;
BufferedInputStream bufferedInputStream = null;
BufferedOutputStream bufferedOutputStream = null;
BufferedWriter bufferedWriter = null;
try {
// 创建服务器套接字对象
int port = 8888; // 端口号
serverSocket = new ServerSocket(port);
System.out.println("服务器启动成功，正在接收客户端的请求");
// 开始接收客户端的请求
clientSocket = serverSocket.accept();
// 获取输入流
bufferedInputStream = new BufferedInputStream(clientSocket.getInputStream());
// 新建输出流，输出读取到的信息，到硬盘当中
//new BufferedOutputStream(new FileOutputStream("本地服务器硬盘地址"))
bufferedOutputStream = new BufferedOutputStream(new FileOutputStream("./test.jpg"));
// 开始读
byte[] bytes = new byte[1024];
int readCount = 0;
while ((readCount = bufferedInputStream.read(bytes)) != -1) {
// 把客户端发送过来的图片，保存到本地服务器中
bufferedOutputStream.write(bytes, 0, readCount);
}
// 刷新
bufferedOutputStream.flush();
// 服务器接收完图片之后给客户端回个话
bufferedWriter = new BufferedWriter(new OutputStreamWriter(clientSocket.getOutputStream()));
bufferedWriter.write("你发的图片我已经收到了");
// 刷新
bufferedWriter.flush();
} catch (IOException e) {
throw new RuntimeException(e);
} finally {
try {
serverSocket.close();
} catch (IOException e) {
throw new RuntimeException(e);
}
try {
clientSocket.close();
} catch (IOException e) {
throw new RuntimeException(e);
}
try {
bufferedInputStream.close();
} catch (IOException e) {
throw new RuntimeException(e);
}
try {
bufferedOutputStream.close();
} catch (IOException e) {
throw new RuntimeException(e);
}
try {
bufferedWriter.close();
} catch (IOException e) {
throw new RuntimeException(e);
}
}
}
}

复制代码

客户端实现步调：

创建socket对象，指明需要连接的服务器地址和端口号；

创建连接后，通过输出流向服务器端发送图片；

通过输入流获取服务器的响应信息；

调用close()方法关闭资源

客户端的代码编写：

地点图片的路径如下：

运行测试：
同样注意：注意：一定是先启动服务器程序，然后再启动客户端程序，先后顺序千万别弄混了！

10. 基于 UDP 协议的编程

10.1 UDP 协议编程概述

在UDP通信协议下，两台计算机之间进行数据交互，并不需要先创建连接，发送端直接往指定的IP和端口号上发送数据即可，但是它并不能保证数据一定能让对方收到，也不能确定什么时候可以送达。
java.net.DatagramSocket类和 java.net.DatagramPacket类是利用UDP编程中需要利用的两个类，并且发送端和接收端都需要利用这个俩类，并且发送端与接收端是两个独立的运行程序。

DatagramSocket：负责接收和发送数据，创建接收端时需要指定端口号。

DatagramPacket：负责把数据打包，创建发送端时需指定接收端的IP地址和端口。

10.2 DatagramSocket 类的概述

DatagramSocket类作为基于UDP协议的Socket，利用DatagramSocket类可以用于接收和发送数据，同时创建接收端时还需指定端口号。
DatagramSocket的构造方法：

public DatagramSocket() // 创建发送端的数据报套接字
public DatagramSocket(int port) // 创建接收端的数据报套接字，并指定端口号

复制代码

DatagramSocket的实例方法：

public void send(DatagramPacket p) // 发送数据报。
public void receive(DatagramPacket p) // 接收数据报。
public void close() // 关闭数据报套接字。

复制代码

10.3 DatagramPacket 类的概述

DatagramPacket类负责把发送的数据打包（打包的数据为byte范例的数组），并且创建发送端时需指定接收端的IP地址和端口。
DatagramPacket的构造方法：

public DatagramPacket(byte buf[], int offset, int length) // 创建接收端的数据报。
public DatagramPacket(byte buf[], int offset, int length, InetAddress address, int port) // 创建发送端的数据报，并指定接收端的IP地址和端口号。

复制代码

DatagramPacket的实例方法：

public synchronized byte[] getData() // 返回数据报中存储的数据
public synchronized int getLength() // 获得发送或接收数据报中的长度

复制代码

11. 基于UDP协议的编程通信实现

接收端实现步调：

创建DatagramSocket对象（接收端），并指定端口号；

创建DatagramPacket对象（数据报）；

调用receive()方法，用于接收数据报；

调用close()方法关闭资源

接收端的代码编写：

package day34.com.rainbowsea.javase.net.udpcommunication;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
/**
* UDP编程，接收端
*/
public class Receive {
public static void main(String[] args) throws Exception {
// 创建 UDP的 Socket 套接字
DatagramSocket datagramSocket = new DatagramSocket(8888);
byte[] bytes = new byte[1024 * 64];
// 准备一个包，这个包接收发送方的信息
DatagramPacket datagramPacket = new DatagramPacket(bytes, bytes.length);
// 程序执行到这里，停下来，等待发送方的发送
datagramSocket.receive(datagramPacket);
// 程序执行到这里说明，已经完全将发送方发送的数据接收到了
// 从包中取出来数据
String msg = new String(bytes, 0, datagramPacket.getLength());
System.out.println("接收到发送方发过来的消息: " + msg);
datagramSocket.close();
}
}

复制代码

发送端的代码编写：

package day34.com.rainbowsea.javase.net.udpcommunication;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
/**
* UDP编程，发送端
*/
public class Send {
public static void main(String[] args) throws Exception {
// 创建一个 UDP的Socket 套接字
DatagramSocket datagramSocket = new DatagramSocket();
// 创建包
byte[] bytes = "RainbowSea".getBytes();
DatagramPacket datagramPacket = new DatagramPacket(bytes, 0, bytes.length, InetAddress.getLocalHost(), 8888);
// 发送消息,将封装到包(datagramPacket) 中的信息发送过去
datagramSocket.send(datagramPacket);
datagramSocket.close();
}
}

复制代码

运行测试：注意：先启动接收端，再启动发送端 。

12. 总结：

Java SE 中的网络编程主要照旧理解：网络协议：TCP协议和UDP协议，特殊是 TCP协议的三次握手，和四次挥手。
而Java SE 的网络编程，这些我们后续的 Tomcat Web 框架当中都是封装好了的，并不需要我们真的自己重写这些底层的方法。我们只需要调用就好了。以是关于这部分的内容大家了解即可。

13. 最后：

限于自身水平，其中存在的错误，希望大家给予指教，韩信点兵——多多益善，谢谢大家，江湖再见，后会有期！！！

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

		自动登录	找回密码
密码			立即注册

Java 网络编程（TCP编程和 UDP编程）

本帖子中包含更多资源

0 个回复

快速回复

楼主热帖

标签云

Java 网络编程（TCP编程 和 UDP编程）

本帖子中包含更多资源

0 个回复

快速回复

楼主热帖

标签云

Java 网络编程（TCP编程和 UDP编程）