Java入门-网络基础编程

今日语录：愿以此身，受你之痛

一、网络通信

概念：两台设备之间通过网络实现数据传输
网络通信：将数据通过网络从一台设备传输到另一台设备
java.net包下提供了一系列的类或接口，供程序员使用，完成网络通信

image-20220410174601415

二、网络

概念：两台或多台设备通过一定物理设备连接起来构成了网络
根据网络的覆盖范围不同，对网络进行分类
局域网：覆盖范围小，仅仅覆盖一个教室或一个机房
域域网：覆盖范围较大，可以覆盖一个城市
广域网：覆盖范围最大，可以覆盖全国，甚至全球，万维网是广域网的代表

image-20220410175029738

三、IP地址

概念：用于唯一标识网络中的每台计算机
查看ip地址：ipconfig
ip地址的表示形式：点分十进制 xx.xx.xx.xx
每一个十进制数组的范围：0-255
ip地址的组成：网络地址+主机地址，比如：192.168.16.69
ipv6是互联网工程任务组设计的用于替代IPv4的下一代协议，其他地址数量号称可以为全世界的每一粒沙子编上一个地址

image-20220410182316528
由于IPv4最大问题在于网络地址资源有限，严重制约了互联网的应用和发展。IPv6的使用，不仅能能解决网络地址资源数量的问题，而且也解决了多种设备连入互联网的障碍

四、ipv4地址分类

五、域名

概念：将ip地址映射成域名
好处：为了方便记忆，解决记ip的困难
例如：www.baidu.com

六、端口号

概念：用于标识计算机上某个特定的网络程序
表示形式：以整数形式，范围0~65535
0~1024已经被占用端口，比如 ssh 22,ftp 21, smtp 25, http 80
常用的网络程序端口号

tomcat:8080

mysql:3306

oracle:1521

sqlserver:1433

七、网络通信协议

协议（tcp/ip）

简介

TCP/IP（Transmission Control Protocol/Internet Protocol）的简写，中文译名为：传输控制协议/因特网互联协议，又称为：网络通讯协议。这个协议是Internet最基本的协议，Internet国际互联网络的基础，简单来说，就是由网络层的IP协议和传输层的TCP协议组成的。

OSI模型	TCP/IP	TCP/IP模型各层对应协议
应用层	应用层	HTTP、ftp、telnet、DNS…
表示层	应用层	HTTP、ftp、telnet、DNS…
会话层	应用层	HTTP、ftp、telnet、DNS…
传输层	传输层	TCP、UDP、…
网络层	网络层	IP、ICMP、ARP…
数据链路层	物理+数据链路层	Link
物理层	物理+数据链路层	Link

八、TCP和UDP

TCP协议（传输控制协议）

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

2、传输前，采用“三次握手”方式，是可靠的

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

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

5、传输完毕，需要释放已有的连接，效率低

UDP协议（用户数据协议）

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

2、每个数据包的大小控制在64k内

3、因无需连接，所以是不可靠的

4、发送数据结束时无需释放资源（因为不是面向连接的），因此速度快

5、举例：厕所通知：发短信

九、InetAddress类

相关方法

获取本机InetAddress对象getLocalHost
根据指定主机名/域名获取Ip地址对象 getByName
获取InetAddress对象的主机名 getHostName
获取InetAddress对象的地址：getHostAddress

应用实例

package Internet_;

import java.net.InetAddress;
import java.net.UnknownHostException;

/**
 * @author chenx
 * @date 2022年04月10日
 */
public class InetAddress_ {
 public static void main(String[] args) throws UnknownHostException {
  // 1.获取本机InetAddress对象getLocalHost
  System.out.println(InetAddress.getLocalHost());

  // 2.根据指定主机名/域名获取Ip地址对象 getByName
  System.out.println(InetAddress.getByName("LEGION-CHEN"));

  // 3.获取InetAddress对象的主机名 getHostName
  System.out.println(InetAddress.getByName("www.baidu.com"));

  // 4.获取InetAddress对象的地址：getHostAddress
  System.out.println(InetAddress.getByName("www.baidu.com").getHostAddress());
 }
}

十、Socket

简介

1、套接字（Socket）开发网络应用程序被广泛采用，以至于成为事实上的标准

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

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

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

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

TCP网络通信编程

简介

1、基于客户端-服务端的网络通信

2、底层使用的是TCP/IP协议

3、应用场景举例：客户端发送数据，服务端接受并显示控制台

4、基于Socket的TCP编程

image-20220410195609629

TCP字节流编程

应用实例-01

要求：

1、编写一个服务器端和一个客户端

2、服务器端在9999端口监听

3、客户端连接到服务器端，发送“hello,server”，然后退出

4、服务器端接收到客户端发送的信息，输出，并退出

思路分析

package Internet_;

import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * @author chenx
 * @date 2022年04月10日
 */
public class SocketTCP01Server_ {
 public static void main(String[] args) throws IOException {
  //Socket
  // 1、在本机的9999端口监听，等待连接
  // 细节：要求在本机没有其他服务在监听9999
  // 细节： 这个ServerSocket 可以通过 accept()返回多个Socket[多个客户端连接服务器的并发]
  ServerSocket serverSocket = new ServerSocket(9999);
  System.out.println("服务端，在9999端口监听，等待连接...");
  // 2、当没有客户端连接9999端口时，程序会阻塞，等待连接
  // 如果有客户端连接，则会返回socket对象，程序继续
  Socket socket = serverSocket.accept();
  System.out.println("socket = " + socket.getClass());
  // 3、通过socket.getInputStream()读取客户端写入到数据通道的数据，显示
  InputStream inputStream = socket.getInputStream();
  // 4、IO读取
  byte[] buf = new byte[1024];
  int readLen = 0;
  while((readLen = inputStream.read(buf)) != -1){
   System.out.println(new String(buf,0,readLen));//根据读取到的实际长度，显示内容
  }
  // 5、关闭流和socket
  inputStream.close();
  socket.close();
  serverSocket.close(); // 关闭

 }
}

package Internet_;

import java.io.IOException;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;

/**
 * @author chenx
 * @date 2022年04月10日
 */
public class SocketTCP01Client_ {
 public static void main(String[] args) throws IOException {
  // 1、 连接服务端（ip+端口）
  // 解读：连接本机的9999端口,如果连接成功，返回socket对象
   Socket socket = new Socket(InetAddress.getLocalHost(), 9999);
  System.out.println("服务器端 socket=" + socket.getClass());
  // 2、连接上以后，生成Socket，通过socket.getOutputStream()
  // 得到 和 spcket对象关联的输出流对象
  OutputStream outputStream = socket.getOutputStream();
  // 3、通过输出流，写入数据到 数据通道
  outputStream.write("hello,server".getBytes());
  // 4、关闭流对象和socket，必须关闭
  socket.close();
  System.out.println("客户端已关闭....");
 }
}

TCP字节流编程

应用示例-02

要求

1、编写一个服务器端，和一个客户端

2、服务器端在9999端口监听

3、客户端连接到服务器端，发送“hello,server”，并接收服务器端发的“hello,client”，再退出

4、服务器端接收到客户端发送的信息，输出，并发送“hello，client”，再退出

package Internet_;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * @author chenx
 * @date 2022年04月10日
 */
public class SocketTCP01Server_ {
 public static void main(String[] args) throws IOException {
  //Socket
  // 1、在本机的9999端口监听，等待连接
  // 细节：要求在本机没有其他服务在监听9999
  // 细节： 这个ServerSocket 可以通过 accept()返回多个Socket[多个客户端连接服务器的并发]
  ServerSocket serverSocket = new ServerSocket(9999);
  System.out.println("服务端，在9999端口监听，等待连接...");
  // 2、当没有客户端连接9999端口时，程序会阻塞，等待连接
  // 如果有客户端连接，则会返回socket对象，程序继续
  Socket socket = serverSocket.accept();
  System.out.println("socket = " + socket.getClass());
  // 3、通过socket.getInputStream()读取客户端写入到数据通道的数据，显示
  InputStream inputStream = socket.getInputStream();
  // 4、IO读取
  byte[] buf = new byte[1024];
  int readLen = 0;
  while((readLen = inputStream.read(buf)) != -1){
   System.out.println(new String(buf,0,readLen));//根据读取到的实际长度，显示内容
  }
  // 5、获取socket相关联的输出流
  OutputStream outputStream = socket.getOutputStream();
  outputStream.write("hello,client".getBytes());
  // 设置一个结束标记
  socket.shutdownOutput();
  // 6、关闭流和socket
  outputStream.close();
  inputStream.close();
  socket.close();
  serverSocket.close(); // 关闭

 }
}

package Internet_;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;

/**
 * @author chenx
 * @date 2022年04月10日
 */
public class SocketTCP01Client_ {
 public static void main(String[] args) throws IOException {
  // 1、 连接服务端（ip+端口）
  // 解读：连接本机的9999端口,如果连接成功，返回socket对象
   Socket socket = new Socket(InetAddress.getLocalHost(), 9999);
  System.out.println("服务器端 socket=" + socket.getClass());
  // 2、连接上以后，生成Socket，通过socket.getOutputStream()
  // 得到 和 spcket对象关联的输出流对象
  OutputStream outputStream = socket.getOutputStream();
  // 3、通过输出流，写入数据到 数据通道
  outputStream.write("hello,server".getBytes());
  // 设置一个结束标记
  socket.shutdownOutput();
  // 4、得到socket相关的输入流的对象
  InputStream inputStream = socket.getInputStream();
  byte[] buf = new byte[1024];
  int readLen = 0;
  while((readLen = inputStream.read(buf)) != -1){
   System.out.println(new String(buf,0,readLen));//根据读取到的实际长度，显示内容
  }
  // 5、关闭流对象和socket，必须关闭
  inputStream.close();
  outputStream.close();
  socket.close();
  System.out.println("客户端已关闭....");
 }
}

TCP字符流编程

应用实例-03（使用字符流）

要求：

1、编写一个服务端和一个客户端

2、服务器端在9999端口监听

3、客户端连接到服务器端，发送“hello,server”，并接收服务器端发的“hello,client”，再退出

4、服务器端接收到客户端发送的信息，输出，并发送“hello，client”，再退出

package Internet_;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * @author chenx
 * @date 2022年04月10日
 */
public class SocketTCP01Server_ {
 public static void main(String[] args) throws IOException {
  //Socket
  // 1、在本机的9999端口监听，等待连接
  // 细节：要求在本机没有其他服务在监听9999
  // 细节： 这个ServerSocket 可以通过 accept()返回多个Socket[多个客户端连接服务器的并发]
  ServerSocket serverSocket = new ServerSocket(9999);
  System.out.println("服务端，在9999端口监听，等待连接...");
  // 2、当没有客户端连接9999端口时，程序会阻塞，等待连接
  // 如果有客户端连接，则会返回socket对象，程序继续
  Socket socket = serverSocket.accept();
  System.out.println("socket = " + socket.getClass());
  // 3、通过socket.getInputStream()读取客户端写入到数据通道的数据，显示
  InputStream inputStream = socket.getInputStream();
  // 4、IO读取，使用字符流，老师使用InputStreamReader将inputStream转成字符流
  BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
  System.out.println("收到客户端发送内容："+bufferedReader.readLine());
  // 5、获取socket相关联的输出流
  OutputStream outputStream = socket.getOutputStream();
  BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(outputStream));
  bufferedWriter.write("hello,client,字符流");
  System.out.println("服务器端发送内容：hello,client,字符流");
  bufferedWriter.newLine();
  bufferedWriter.flush();
  // 设置一个结束标记
  socket.shutdownOutput();
  // 6、关闭流和socket
  outputStream.close();
  inputStream.close();
  socket.close();
  serverSocket.close(); // 关闭

 }
}

package Internet_;

import java.io.*;
import java.net.InetAddress;
import java.net.Socket;

/**
 * @author chenx
 * @date 2022年04月10日
 */
public class SocketTCP01Client_ {
 public static void main(String[] args) throws IOException {
  // 1、 连接服务端（ip+端口）
  // 解读：连接本机的9999端口,如果连接成功，返回socket对象
   Socket socket = new Socket(InetAddress.getLocalHost(), 9999);
  System.out.println("服务器端 socket=" + socket.getClass());
  // 2、连接上以后，生成Socket，通过socket.getOutputStream()
  // 得到 和 spcket对象关联的输出流对象
  OutputStream outputStream = socket.getOutputStream();
  // 3、通过输出流，写入数据到 数据通道
  BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(outputStream));
  bufferedWriter.write("hello，server,字符流");
  System.out.println("客户端发送内容：hello，server,字符流");
  bufferedWriter.newLine(); //插入一个换行符，表示写入的内容结束
  bufferedWriter.flush(); // 如果使用的字符流，需要手动刷新，否则数据不会写入到数据通道
  // 设置一个结束标记
  socket.shutdownOutput();
  // 4、得到socket相关的输入流的对象
  InputStream inputStream = socket.getInputStream();
  BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
  System.out.println("收到服务器端内容："+bufferedReader.readLine());

  // 5、关闭流对象和socket，必须关闭
  bufferedWriter.close();
  outputStream.close();
  socket.close();
  System.out.println("客户端已关闭....");
 }
}

网络上传文件

应用示例-04

要求：使用BufferedInputStream和BufferedOutputStream字节流

1、编写一个服务端和一个客户端

2、服务器端在9999端口监听

3、客户端连接到服务端，发送一张图片e:qie.png

4、服务器端接收到客户端发送的图片，保存到src下，发送“收到图片”再退出

5、客户端接收到服务器端发送的“收到图片”，再退出

6、该程序要求使用StreamUtils.java

题解分析：

package Internet_.upload;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * @author chenx
 * @date 2022年04月11日
 */
public class TCPFileUploadServer_ {
 public static void main(String[] args) throws Exception {
  // 1、服务器端在本机监听8888端口
  ServerSocket serverSocket = new ServerSocket(8888);
  System.out.println("服务器端在8888端口监听...");
  // 2、等待连接
  Socket socket = serverSocket.accept();

  // 3、读取客户端发送的数据，通过socket得到输入流
  BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());
  byte[] bytes = StreamUtils.streamToByteArray(bis);

  // 4、将bytes字节数组写入指定路径
  String destFilePath = "src\tk.png";
  BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(destFilePath));
  bos.write(bytes);
  bos.close();
  socket.shutdownInput();

  // 5、发送“收到图片”给客户端
  BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
  bw.write("收到图片");
  bw.flush();
  socket.shutdownOutput();

  // 关闭流
  bw.close();
  bis.close();
  socket.close();
  serverSocket.close();

 }
}

package Internet_.upload;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.FileInputStream;
import java.io.InputStream;
import java.net.InetAddress;
import java.net.Socket;

/**
 * @author chenx
 * @date 2022年04月11日
 */
public class YCPFileUploadClient_ {
 public static void main(String[] args) throws Exception {
  // 1、客户端连接服务器 8888，得到socket对象
  Socket socket = new Socket(InetAddress.getLocalHost(),8888);
  // 2、创建读取磁盘文件的输入流
  String filePath = "e:\tk.png";
  BufferedInputStream bis = new BufferedInputStream(new FileInputStream(filePath));

  byte[] bytes = StreamUtils.streamToByteArray(bis);

  // 3、通过socket获取到输出流，将bytes数据发送到数据通道
  BufferedOutputStream bos = new BufferedOutputStream(socket.getOutputStream());
  bos.write(bytes); // 文件的字节数组写入到数据通道
  bis.close();
  socket.shutdownOutput();// 设置写入数据的结束标记

  // 4、通过BufferedInputStream获得服务器端的数据，并展示
  InputStream inputStream = socket.getInputStream();
  String s  = StreamUtils.streamToString(inputStream);
  System.out.println("服务器端返回接收结果：" + s);

  // 关闭相关流
  bos.close();
  socket.close();

 }
}

网络下载文件

要求：

1、编写客户端程序和服务器端程序

2、客户端可以输入一个音乐文件名，比如高山流水，从服务端收到音乐名后，可以给客户端返回这个音乐文件，如果服务器没有这个文件，返回一个默认的音乐即可

3、客户端收到文件后，保存到本地e:

4、提示：该程序可以使用StreamUtils.java

图解：

package Internet_.download;

import Internet_.upload.StreamUtils;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * @author chenx
 * @date 2022年04月12日
 */
public class DownloadServer_ {
 public static void main(String[] args) throws Exception {
  // 1 监听9999端口
  ServerSocket serverSocket = new ServerSocket(9999);
  System.out.println("服务端在端口9999监听，等待连接下载文件...");
  // 2.等待客户端连接
  Socket socket = serverSocket.accept();
  // 3.读取 客户端发送要下载的文件名
  InputStream inputStream = socket.getInputStream();
  byte[] bytes = new byte[1024];
  int len = 0;
  String downLoadFileName = "";
  while((len = inputStream.read(bytes)) != -1){
   downLoadFileName += new String(bytes, 0, len);
  }
  System.out.println("客户端希望下载文件："+downLoadFileName);

  // 服务器上存在多个文件，需要判断
  String resFileName = "";
  if("高山流水".equals(downLoadFileName)){
   resFileName = "src\高山流水.mp3";
  }else{
   resFileName = "src\无名.mp3";
  }
  // 4.创建一个输入流，读取文件到内存中
  BufferedInputStream bis =
    new BufferedInputStream(new FileInputStream(resFileName));
  byte[] data = StreamUtils.streamToByteArray(bis);
  // 创建输出流，向数据通道写入数据
  BufferedOutputStream bos = new BufferedOutputStream(socket.getOutputStream());
  bos.write(data);
  socket.shutdownOutput();

  bis.close();
  bos.close();
  socket.close();
  serverSocket.close();

  System.out.println("服务端退出...");

 }
}

package Internet_.download;

import Internet_.upload.StreamUtils;

import java.io.*;
import java.net.InetAddress;
import java.net.Socket;
import java.util.Scanner;

/**
 * @author chenx
 * @date 2022年04月12日
 */
public class DownloadClient_ {
 public static void main(String[] args) throws Exception {
  // 1.接收用户输入，指定下载文件名
  Scanner scanner = new Scanner(System.in);
  System.out.println("请输入下载的文件名...");
  String downloadFileName = scanner.nextLine();
  // 2.客户端连接服务器，准备发送
  Socket socket = new Socket(InetAddress.getLocalHost(),9999);
  // 3.获取和socket关联的输出流
  OutputStream outputStream = socket.getOutputStream();
  outputStream.write(downloadFileName.getBytes());
  // 设置写入结束的标志
  socket.shutdownOutput();

  // 读取服务端返回的文件，字节数组
  BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());
  byte[] data = StreamUtils.streamToByteArray(bis);
  // 5.得到一个输出流，准备将data写入到磁盘文件
  String filePath = "e:\" + downloadFileName +".mp3";
  BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(filePath));
  bos.write(data);

  bis.close();
  bos.close();
  outputStream.close();
  socket.close();

  System.out.println("客户端下载完成，退出...");


 }
}

netstat指令

netstat -an 可以查看当前主机网络情况，包括端口监听情况和网络连接情况
netstat -an | more 可以分页显示
要求在dos控制台下执行 win+r

说明：

(1) Listening 表示某个端口在监听

(2) 如果有一个外部程序（客户端）连接到该端口，就会显示一条连接信息

(3) 可以输入ctrl+c 退出指令

TCP网络通讯不为人知的秘密

1、当客户端连接到服务端后，实际上客户端也是通过一个端口和服务端进行通讯的，这个端口是TCP/IP来分配的，是不确定的，随机的

2、示意图

3、程序验证+netstat

package Internet_.upload;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * @author chenx
 * @date 2022年04月11日
 */
public class TCPFileUploadServer_ {
 public static void main(String[] args) throws Exception {
  // 1、服务器端在本机监听8888端口
  ServerSocket serverSocket = new ServerSocket(8888);
  System.out.println("服务器端在8888端口监听...");
  // 2、等待连接
  Socket socket = serverSocket.accept();

  // 3、读取客户端发送的数据，通过socket得到输入流
  BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());
  byte[] bytes = StreamUtils.streamToByteArray(bis);

  // 4、将bytes字节数组写入指定路径
  String destFilePath = "src\高山流水.mp3";
  BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(destFilePath));
  bos.write(bytes);
  bos.close();
  socket.shutdownInput();

  // 5、发送“收到图片”给客户端
  BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
  bw.write("收到图片");
  bw.flush();
  socket.shutdownOutput();

  // 关闭流
  bw.close();
  bis.close();
  socket.close();
  serverSocket.close();

 }
}

package Internet_.upload;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.FileInputStream;
import java.io.InputStream;
import java.net.InetAddress;
import java.net.Socket;

/**
 * @author chenx
 * @date 2022年04月11日
 */
public class YCPFileUploadClient_ {
 public static void main(String[] args) throws Exception {
  // 1、客户端连接服务器 8888，得到socket对象
  Socket socket = new Socket(InetAddress.getLocalHost(),8888);
  // 2、创建读取磁盘文件的输入流
  String filePath = "e:\高山流水.mp3";
  BufferedInputStream bis = new BufferedInputStream(new FileInputStream(filePath));

  byte[] bytes = StreamUtils.streamToByteArray(bis);

  // 3、通过socket获取到输出流，将bytes数据发送到数据通道
  BufferedOutputStream bos = new BufferedOutputStream(socket.getOutputStream());
  bos.write(bytes); // 文件的字节数组写入到数据通道
  bis.close();
  socket.shutdownOutput();// 设置写入数据的结束标记

  // 4、通过BufferedInputStream获得服务器端的数据，并展示
  InputStream inputStream = socket.getInputStream();
  String s  = StreamUtils.streamToString(inputStream);
  System.out.println("服务器端返回接收结果：" + s);

  // 关闭相关流
  bos.close();
  socket.close();

 }
}

UDP网络通信编程

基本介绍

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

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

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

4、UDP协议中每个数据报都给出了完整的地址信息，因此无需建立发送方和接收方的连接
基本流程

1、核心的两个类/对象：DatagramSocket与DatagramPacket

2、建立发送端，接收端（没有固定的服务端和客户端概念）

3、发送数据前，建立数据包/报 DatagramPacket对象

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

5、关闭DatagramSocket
类图

image-20220412140252987
原理示意图

image-20220412142523698

应用示例-01

要求

1、编写一个接收端A，和一个发送端B

2、接收端A在9999端口等待接收数据（receive）

3、发送端A向接收端B发送数据“hello，明天吃火锅~”

4、接收端B接收到发送端A发送的数据，回复“好的，明天见”，再退出

5、发送端接收到回复的数据，再退出

图解：

package Internet_.UDP_;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

/**
 * @author chenx
 * @date 2022年04月12日
 */
public class UDPReceiverA {
 public static void main(String[] args) throws IOException {
  // 1.编写一个接收端A,接收端A在9999端口等待接收数据（receive）
  DatagramSocket socket = new DatagramSocket(9999);
  System.out.println("接收A端，监听9999端口中，等待连接...");
  // 2.构建一个DataramPacket对象，准备接收数据
  // 在前面讲解UDP协议时，老师说过一个数据包最大，64k
  byte[] bytes = new byte[1024];
  DatagramPacket datagramPacket = new DatagramPacket(bytes, bytes.length);
  // 3.调用接收方法,将通过网络传输的DatagramPacket对象填充到packet对象
  // 提示：当有数据包发送到本机的9999端口时，就会接收到数据
  // 如果没有数据包发送到 本机的9999端口，就会阻塞等待
  socket.receive(datagramPacket);

  // 4.可以把packet 进行拆包，取出数据，并显示
  int length = datagramPacket.getLength();// 实际接收到的数据字节长度
  byte[] data = datagramPacket.getData(); // 接收到的数据
  String s = new String(data, 0, length);
  System.out.println("B端发送消息："+s);

  // 5.发送消息给发送端：好的，明天见
  byte[] sendData = "好的，明天见，晚安".getBytes();
  datagramPacket =
    new DatagramPacket(sendData,sendData.length, InetAddress.getByName("192.168.31.18"),9998);
  socket.send(datagramPacket);
  System.out.println("回复消息~~");

  //关闭
  socket.close();
 }
}

package Internet_.UDP_;

import java.io.IOException;
import java.net.*;

/**
 * @author chenx
 * @date 2022年04月12日
 */
public class UDPSenderB_ {
 public static void main(String[] args) throws IOException {
  // 1.创建DatagramSocket对象，准备在9998端口，接收数据
  DatagramSocket socket = new DatagramSocket(9998);

  // 2.需要将发送的数据，封装到DatagramPacket对象，发送到主机+端口
  byte[] data = "hello,明天吃火锅~".getBytes();
  DatagramPacket packet =
    new DatagramPacket(data,data.length, InetAddress.getByName("192.168.31.18"),9999);
  socket.send(packet);

  //
  byte[] bytes = new byte[1024];
  packet = new DatagramPacket(bytes, bytes.length);
  socket.receive(packet);
  int length = packet.getLength();// 实际接收到的数据字节长度
  byte[] receiveData = packet.getData(); // 接收到的数据
  String s = new String(receiveData, 0, length);
  System.out.println("A端回复消息："+s);

  socket.close();
  System.out.println("接收B端退出...");
 }
}