DatagramSocket
使用DatagramSocket(数据套接字)可以进行UDP程序的开发，此类可以建立单向地、不可靠地、快速地通信。
在UDP编程中，混淆了服务端和客户端的概念。因为通信是单向的，所以身份可以随时切换。
(也有人把TCP称作服务端客户端，UDP称作发送端和接收端)
DatagramSocket类常用方法如下：
| 方法 | 类型 | 描述 |
|---|---|---|
| public DatagramSocket(int port) throws SocketException | 构造方法 | 监听指定端口 |
| public void send(DatagramPacket p) throws IOException | 普通方法 | 发送数据报 |
| public synchronized void receive(DatagramPacket p) throws IOException | 同步方法 | 等待客户端请求并接收数据报(没有会一直阻塞) |
DatagramPacket
在Java中，使用DatagramPacket类操作数据报。
常用方法如下：
| 方法 | 类型 | 描述 |
|---|---|---|
| public DatagramPacket(byte buf[], int length) | 构造方法 | 构建数据报的数据、数据长度 |
| public DatagramPacket(byte buf[], int length, InetAddress address, int port) | 构造方法 | 构建数据报的数据、数据长度、目标地址和端口 |
| public synchronized byte[] getData() | 同步方法 | 拆开数据报，获取数据 |
| public synchronized int getLength() | 普通方法 | 获取数据长度 |
栗子：编写一个本机的接收端，端口为9999
接收端，Test25receive类：
//接收端，Test25receive类
public static void main(String[] args) {
try {
DatagramSocket datagramSocket = new DatagramSocket(9999);
byte[] bytes = new byte[1024];//创建容器，留作数据
System.out.println("成功创建容器，监听9999端口");
DatagramPacket datagramPacket = new DatagramPacket(bytes, bytes.length);
datagramSocket.receive(datagramPacket);
//若无客户端访问9999端口，程序就会阻塞在此;若有客户端访问9999端口，程序继续向下执行。
System.out.println("1");//若执行到此证明不会阻塞
datagramSocket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
程序运行结果：
成功创建容器，监听9999端口
//阻塞中....
栗子：发送端给本机9999端口的接收端发送hello，world!
发送端，Test25send类：
//发送端，Test25send类
public class Test25send {
public static void main(String[] args) {
try {
DatagramSocket datagramSocket = new DatagramSocket();//因为接收端不打算回消息，所以不监听端口
byte[] bytes = "hello，world！".getBytes();
DatagramPacket datagramPacket = new DatagramPacket(bytes, bytes.length, InetAddress.getByName("localhost"),9999);
//构建一个数据报，其目的地址是本机的9999端口。
datagramSocket.send(datagramPacket);
System.out.println("成功发送数据报");
datagramSocket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
接收端，Test25receive类：
//接收端，Test25receive类
public class Test25receive {
public static void main(String[] args) {
try {
DatagramSocket datagramSocket = new DatagramSocket(9999);
byte[] bytes = new byte[1024];//创建容器，留作数据
System.out.println("成功创建容器，监听9999端口");
DatagramPacket datagramPacket = new DatagramPacket(bytes, bytes.length);
datagramSocket.receive(datagramPacket);
//若无发送端访问9999端口，程序就会阻塞在此;若有发送端访问9999端口，程序继续向下执行。
byte[] data = datagramPacket.getData();//拆包后的数据
System.out.println(new String(data,0, datagramPacket.length));//长度一定是数据报获取的长度，否则带有bytes后的很多00000
System.out.println("1");//若执行到此证明不会阻塞
datagramSocket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
先运行接收端，再运行发送端，程序运行结果：
栗子：发送端发送信息"四大名著是哪些？"
接收端接收问题后回复""四大名著有。。。。
否则回复what？
客户端，Test25send类：
//客户端，Test25send类
public class Test25send {
public static void main(String[] args) {
try {
DatagramSocket datagramSocket = new DatagramSocket(9988);//因为接收端要回消息，监听端口9988
byte[] bytes = "四大名著11哪些？".getBytes();
DatagramPacket datagramPacket = new DatagramPacket(bytes, bytes.length, InetAddress.getByName("localhost"),9999);
//构建数据报，其目的地址是本机的9999端口。
datagramSocket.send(datagramPacket);
System.out.println("成功发送数据报");
//构建数据报，其目的地址是本机的9999端口。
byte[] b = new byte[1024];
DatagramPacket datagramPacket2 = new DatagramPacket(b, b.length, InetAddress.getByName("localhost"),9999);
datagramSocket.receive(datagramPacket2);
System.out.println(new String(datagramPacket2.getData(),0, datagramPacket2.getLength()));
datagramSocket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
服务端，Test25receive类：
//服务端，Test25receive类
public class Test25receive {
public static void main(String[] args) {
try {
DatagramSocket datagramSocket = new DatagramSocket(9999);
byte[] bytes = new byte[1024];//创建容器，留作数据
System.out.println("成功创建容器，监听9999端口");
DatagramPacket datagramPacket = new DatagramPacket(bytes, bytes.length);
datagramSocket.receive(datagramPacket);
//若无客户端访问9999端口，程序就会阻塞在此;若有客户端访问9999端口，程序继续向下执行。
String s = new String(datagramPacket.getData(), 0, datagramPacket.getLength());//拆包后的数据
DatagramPacket datagramPacket2;
byte[] b;
if("四大名著是哪些？".equals(s)) {
b = "四大名著有。。。。".getBytes();
} else {
b = "what?".getBytes();
}
datagramPacket2 = new DatagramPacket(b, b.length, InetAddress.getByName("localhost"), 9988);
datagramSocket.send(datagramPacket2);
datagramSocket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
程序运行结果：
