java UDP 通信记录
java UDP 通信记录
1. UDP和TCP通信的区别
- TCP面向连接（如打电话要先拨号建立连接）;UDP是无连接的，即发送数据之前不需要建立连接。
- TCP提供可靠的服务。也就是说，通过TCP连接传送的数据，无差错，不丢失，不重复，且按序到达;UDP尽最大努力交付，即不保证可靠交付。
- TCP面向字节流，实际上是TCP把数据看成一连串无结构的字节流;UDP是面向报文的。UDP没有拥塞控制，因此网络出现拥塞不会使源主机的发送速率降低（对实时应用很有用，如IP电话，实时视频会议等）
- 每一条TCP连接只能是点到点的;UDP支持一对一，一对多，多对一和多对多的交互通信。
- TCP首部开销20字节;UDP的首部开销小，只有8个字节
- TCP的逻辑通信信道是全双工的可靠信道，UDP则是不可靠信道。
2. UDP通信的优势
- 网速的提升给udp的稳定性提供了可靠的网络保障。丢包率很低，如果使用应用层重传，能够确保传输的可靠性。
- udp协议设计简单，传输速度快。tcp设计过于冗余，速度难以进一步提升。
3.java UDP通信的相关介绍
-
**DatagramSocket类：**此类表示用来发送和接收数据报包的套接字。 数据报套接字是包投递服务的发送或接收点。
构造方法：
DatagramSocket():表示创建一个默认的套接字，并绑定到本地地址和一个随机的端口号
DatagramSocket(int port) 创建数据报套接字并将其绑定到本地主机上的指定端口。
DatagramSocket(int port, InetAddress iad):表示创建一个套接字，绑定到特定的端口号及指定地址
DatagramSocket(SocketAddress sad); 表示创建一个套接字，绑定到特定的套接字地址
基本方法：
recevie(DatagramPacket dp): 接受数据报
send(DatagramPacket dp): 发送数据报
close():关闭套接字
bind(SocketAddress addr) 将此 DatagramSocket 绑定到特定的地址和端口。
connect(InetAddress address, int port) 将套接字连接到此套接字的远程地址。
connect(SocketAddress addr) 将此套接字连接到远程套接字地址（IP 地址 + 端口号）。
disconnect() 断开套接字的连接。
getInetAddress() 返回此套接字连接的地址。
InetAddress getLocalAddress()；获取套接字绑定的本地地址。
-
**DatagramPacket类：**如果把DatagramSocket比作创建的港口码头，那么DatagramPacket就是发送和接收数据的集装箱。
常用方法：
DatagramPacket(byte[] buf, int length)?):构造方法，用来接受长度为length的buf数据(即数据存于字节数组buf中)
DatagramPacket(byte[] buf, int length, InetAddress address, int port);将length长的buf数据发送到指定的地址的端口号处
DatagramPacket(byte[] buf, int length, SocketAddress address);将length长的buf数据发送到指定的套接字地址处
getAddress() 返回接收或发送此数据报文的机器的 IP 地址。
getData() 返回接收的数据或发送出的数据。
getLength()；返回发送出的或接收到的数据的长度。
getPort() 返回接收或发送该数据报文的远程主机端口号
-
InetAddress类：InetAddress用于表示计算机IP地址的一个类，而在日常应用中的IP地址用"192.168.0.1","WWW.it315.org"等字符串格式表示的。
常用的方法有：
getByName方法
getHostAddress方法
UDP 通信示例
- 发送方代码：
public class UDPSender {
public static void main(String[] args) {
try {
// 创建发送方的套接字，IP默认为本地，端口号随机
DatagramSocket sendSocket = new DatagramSocket();
//设置要发送的消息
String message = "你好！接收方！";
//由于数据报的数据 是以字符数组的形式存储的，所以要把数据格式转换成这种格式。
byte[] buf = message.getBytes();
//确定发送方的IP地址及端口号，地址为本地机器地址
int port = 8888;
InetAddress ip = InetAddress.getLocalHost();
DatagramPacket sendPacket = new DatagramPacket(buf, buf.length, ip, port);
//通过套接字来发送数据
sendSocket.send(sendPacket);
// 确定接受反馈数据的缓冲存储器，即存储数据的字节数组
byte[] getBuf = new byte[1024];
//创建接受类型的数据报
DatagramPacket getPacket = new DatagramPacket(getBuf, getBuf.length);
// 通过套接字来接收返回的数据
sendSocket.receive(getPacket);
// 解析反馈的数据
String backStr = new String(getBuf, 0, getPacket.getLength());
System.out.println(backStr);
sendSocket.close();
} catch (SocketException e) {
e.printStackTrace();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}
- 接收方代码
import java.io.IOException;
import java.net.*;
public class UDPReceiver {
public static void main(String[] args) {
try {
//确定接受方的IP和端口号
InetAddress ip = InetAddress.getLocalHost();
int port = 8888;
DatagramSocket getSocket = new DatagramSocket(port,ip);
byte[] buf = new byte[1024];
DatagramPacket getPacket = new DatagramPacket(buf, buf.length);
getSocket.receive(getPacket);
String getMes = new String(buf, 0, getPacket.getLength());
System.out.println(getMes);
//通过数据报得到发送方的IP和端口号
InetAddress sendIp = getPacket.getAddress();
int sendPort = getPacket.getPort();
System.out.println("sendIp " + sendIp);
System.out.println("sendPort "+ sendPort);
//通过数据报等到发送方的地址
SocketAddress sendAddress = getPacket.getSocketAddress();
System.out.println("sendAddress" + sendAddress);
String feedbak = "发送方，你的消息我收到了";
byte[] bakbuf = feedbak.getBytes();
DatagramPacket sendpacket = new DatagramPacket(bakbuf, bakbuf.length, sendAddress);
getSocket.send(sendpacket);
getSocket.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (SocketException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}
测试时先启动接收方代码，再启动发送方代码。
参考文章：