java nio 中的 datagramchannel 用于实现无连接的 udp 通信，核心做法是调用 bind() 绑定本地端口，使用 send() 发送数据并指定目标地址，通过 receive() 接收数据并填充缓冲区以获取来源地址。由于 udp 不保证可靠传输且可能截断超长报文，建议在应用层处理分包或重传逻辑，同时注意 receive() 在阻塞模式下会挂起线程直到有数据到达。
DatagramChannel 如何绑定与初始化
初始化 DatagramChannel 后必须显式绑定本地端口才能进行通信，通常使用 bind() 方法将通道关联到指定的 InetSocketAddress。这一步骤确保了操作系统内核知道要将发往该端口的数据包交付给哪个文件描述符，未绑定的通道无法接收数据，但可以在某些场景下仅作为发送方使用（由系统自动分配临时端口）。
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.DatagramChannel;
public class UdpInitDemo {
public static void main(String[] args) throws Exception {
// 打开 DatagramChannel
DatagramChannel channel = DatagramChannel.open();
// 绑定本地端口 9090
InetSocketAddress localAddr = new InetSocketAddress(9090);
channel.bind(localAddr);
System.out.println("Channel bound to: " + channel.getLocalAddress());
// 关闭资源
channel.close();
}
}
DatagramChannel 发送与接收数据的流程
发送数据需构建包含字节内容的 ByteBuffer 和目标 SocketAddress，调用 send() 方法完成单次发送；接收数据则准备一个空的 ByteBuffer 调用 receive()，该方法返回来源地址并将数据写入缓冲区。若缓冲区容量小于实际数据包大小，多余数据将被静默丢弃，因此缓冲区大小应至少等于最大预期报文长度。
立即学习“Java免费学习笔记（深入）”；
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.DatagramChannel;
public class UdpSendReceiveDemo {
public static void main(String[] args) throws Exception {
DatagramChannel channel = DatagramChannel.open();
channel.bind(new InetSocketAddress(9090));
// 发送数据
String msg = "Hello UDP";
ByteBuffer sendBuf = ByteBuffer.wrap(msg.getBytes());
InetSocketAddress target = new InetSocketAddress("localhost", 9091);
channel.send(sendBuf, target);
// 接收数据
ByteBuffer recvBuf = ByteBuffer.allocate(1024);
InetSocketAddress sender = (InetSocketAddress) channel.receive();
if (sender != null) {
recvBuf.flip();
byte[] data = new byte[recvBuf.remaining()];
recvBuf.get(data);
System.out.println("From: " + sender + ", Data: " + new String(data));
}
channel.close();
}
}
当 receive() 在没有数据时返回什么
在默认阻塞模式下，receive() 会一直等待直到收到数据包，此时不会返回 null 而是阻塞线程；只有当通道被关闭或处于非阻塞模式且无数据可用时，才会抛出 IllegalBlockingModeException 或返回 null。若需避免阻塞，应提前调用 configureBlocking(false) 切换为非阻塞模式，并在调用 receive() 前检查是否有数据就绪，否则直接返回 null 表示当前无数据。
