前言
我们如果想让应用程序进行网络通信的话，就需要调用传输层为应用层提供的API。传输层提供的协议主要有两个：UDP和TCP，这两个协议提供了两套不同的API。操作系统给这些应用程序提供的这些用于网络通信的API起了一个名字，即socket api。
目录
一、UDP和TCP特点对比
UDP特点：无连接、不可靠传输、面向数据报，全双工。
TCP特点：有连接、可靠传输、面向字节流，全双工。
连接：我们知道JDBC编程中先创建DataSource，然后再通过DataSource创建Connection。对于TCP编程的话来存在像JDBC类似的连接方式。可靠传输/不可靠传输：可靠传输就是主机A尽可能的将消息传给zhujiB，并且当消息传输失败的时候主机A可以感知到，当然当消息传输成功的时候主机A可以得知自己发送的消息传输完毕。TCP是可靠传输但是与此同时TCP付出的代价就是TCP在进行信息传输的时候传输效率有所降低、UDP是不可靠传输但是UDP在进行信息传输的时候，传输效率得到了提供。
- - 面向字节流：TCP和文件操作是类似的，都是流式的操作。这里传输的单位是字节，我们称之为字节流。TCP协议的数据传输可以传输任意长度的字节流数据，但是，一次读写的数据数量通常是由发送方和接收方的缓冲区大小决定的（比如我们可以一次性读写50字节的数据，可以一次性读写100字节的数据。）。
- 面向数据报：UDP是面向数据报读写的基本单位，单位是一个UDP数据包。在UDP协议中，数据被封装在UDP数据报中，每个UDP数据报包含一些列的数据和属性。
- 全双工：全双工即一个通道可以双向通信，而半双工意思就是一个通道只能偶单向通信。我们家里使用的网线就是全双工的。
二、UDP数据报套接字编程
UDP数据报套接字编程是使用UDP协议进行网络通信的一种编程方式。
在Java中，UDP是通过java.net.DatagramSocket类和java.net.DatagramPacket类来提供API的。
java.net.DatagramSocket类代表一个UDP套接字对象（Socket对象）
在java中，java.net.DatagramPacket用来表示UDP数据报。
以上java.net.DatagramSocket类和java.net.DatagramPacket类是我们进行UDP编程中必不可少了两个类。
三、DatagramSocket
DatagramSocket是UDP Socket，用于发送和接收UDP数据报。
DatagramSocket构造方法（分为有参和无参）如下：
DatagramSocket类方法：
我们可以看到前两个方法的参数都是DatagramPacket，UDP是一种面向数据报的传输层协议，传输数据的基本单位就是数据报，即DatagramPacket对象。
四、DatagramPacket
DatagramPacket构造方法：
DatagramPacket 方法：
五、通过UDP数据报实现回显服务器（echo server）
Udp的回显服务器:客户端发送的请求是什么服务器返回的响应就是什么
5.1服务器端
对于一个服务器来说要做的工作主要有三个主要环节：
- 1.读取请求，并对请求进行解析
- 2.根据请求计算出响应
- 3.把相应返回给客户端
上述的三个环节对于第一步和第三步来说一般都是固定的流程和套路
第一步：读取请求并对请求进行解析：
服务器端代码
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
// Udp的回显服务器:客户端发送的请求是什么服务器返回的响应就是什么
public class UdpEchoServer {
private DatagramSocket socket = null;
// 构造方法
public UdpEchoServer(int port) throws SocketException {
socket = new DatagramSocket(port);
}
public void start() throws IOException {
System.out.println("服务器启动!!!");
while(true) {
// 服务器需要长期反复的执行针对客户端请求处理的逻辑
// 对于一个服务器来说要做的工作主要有三个主要环节"
// 1.读取请求，并对请求进行解析
DatagramPacket requestPacket = new DatagramPacket(new byte[4096],4096);
socket.receive(requestPacket);
// 可以将DatagramPacket对象中的字节数组转换成字符串,这样的转字符串的前提时后续客户端发送的数据是一个文本字符串
// 如果客户端发送的数据是一个二进制,这里就不合适了
// 大体梳理一下:通过DatagramSocket类中的receive方法来读取到requestPacket（数据报对象）中的内容,
// 然后再进一步的将数据报中的载荷提取并转换为字符串
String request = new String(requestPacket.getData(),0, requestPacket.getLength());
// 2.根据请求计算出响应
String response = process(request);
// 3.把相应返回给客户端
// 此时要告知网卡要发送的内容以及，要发给谁两部分内容
DatagramPacket responsePacket = new DatagramPacket(response.getBytes(),response.getBytes().length,
requestPacket.getSocketAddress());
socket.send(responsePacket);
// 而对于这里的回显服务器来说不需要关心具体的流程，因为回显服务器请求是什么返回的响应就是什么
// 但是对于一个商业级的服务器来说，最主要的代码就是完成第二步的代码编写
// 记录日志，方便观察
System.out.printf("[%s:%d] req: %s, resp : %s\n",requestPacket.getSocketAddress().toString(),requestPacket.getPort(),
request,response);
}
}
// 第二步:根据请求计算响应,由于我们写的程序是一个回显服务器,所以响应内容和请求是一致的,即请求是什么响应就是什么
public String process(String request) {
return request;
}
public static void main(String[] args) throws IOException {
UdpEchoServer server = new UdpEchoServer(9090);
server.start();
}
}
5.2客户端
客户端代码
import java.io.IOException;
import java.net.*;
import java.util.Scanner;
public class UdpEchoClient {
private DatagramSocket socket = null;
private String serverIp;
private int serverPort;
// 服务器的ip和服务器的端口
public UdpEchoClient(String ip,int port) throws SocketException {
serverIp = ip;
serverPort = port;
// 下面的new操作就不需要再指定端口了,而是让系统随机分配一个空闲端口
socket = new DatagramSocket();
}
// 让客户端反复的从控制台中读取用户输入的信息
// 然后把这个内容构造成UDP请求发送给服务器，再读取服务器返回的UDP响应
// 最终显示再客户端的屏幕上
public void start() throws IOException {
Scanner scanner = new Scanner(System.in);
System.out.println("客户端启动!!!");
while(true) {
// 1.从控制台读取用户输入的用户输入的内容。
System.out.printf("-->"); // 命令提示符来提示用户输入字符串
String request = scanner.next();
// 2.构造请求对象并发送给服务器
DatagramPacket requestPacket = new DatagramPacket(request.getBytes(),request.getBytes().length,
InetAddress.getByName(serverIp),serverPort);
socket.send(requestPacket);
// 3.读取服务器的响应,并解析出响应内容
DatagramPacket responsePacket = new DatagramPacket(new byte[4096],4096);
socket.receive(responsePacket);
String response = new String(responsePacket.getData(),0,responsePacket.getLength());
// 4.将结果打印到屏幕上
System.out.println(response);
}
}
public static void main(String[] args) {
}
}
以上就是回显服务器程序的所有代码。
本文到这里就结束了，希望友友们可以支持一下一键三连哈。嗯，就到这里吧，再见啦！！！