如何在 Java 中使用 DatagramSocket 实现基础的 UDP 通信-java教程-PHP中文网

udp不能“连接后收发”因为datagramsocket不维护连接状态，所有数据必须封装进datagrampacket并每次指定目标地址端口；发送需注意编码、长度限制与复用socket；接收须bind、设超时、管理缓冲区；多线程下需安全关闭。

如何在 java 中使用 datagramsocket 实现基础的 udp 通信

UDP 通信为什么不能像 TCP 那样“连接后收发”

因为 DatagramSocket 本身不维护连接状态，它只负责把 DatagramPacket 发出去，或从任意来源接收包。你无法调用 socket.getOutputStream() 或类似方法——这些在 UDP 里根本不存在。所有数据都必须封装进 DatagramPacket，连目标 IP 和端口都要每次指定（除非用 connect() 预设）。

常见错误现象：SocketException: socket closed —— 多线程中没同步关闭；IOException: Message too long —— UDP 单包超 65507 字节（IPv4）；收不到包却无报错——防火墙、端口被占、没绑定本地端口或 receive() 前没调用 setSoTimeout() 导致线程永久阻塞。

发送方不需要 bind()，但若想接收响应，通常也得绑一个端口（否则系统随机分配，对方难回）
接收方必须显式 bind() 到具体端口，且该端口未被其他进程占用
connect() 不建立连接，只是限制后续 send() 只能发给指定地址，并让 receive() 只接收来自该地址的包（提升安全性，也避免误收）

如何正确构造 DatagramPacket 发送字节数组

DatagramPacket 的构造函数参数顺序容易搞反：是 new DatagramPacket(byte[], length, InetAddress, port)，不是“先地址后字节数组”。而且 length 必须是实际要发送的字节数，不是整个数组长度——如果数组复用，写多了会发脏数据，写少了会截断。

示例：

Java JDK 25

Java JDK 25 来自 OpenJDK 官方归档，版本为 JDK 25，本条下载地址已指向官方 Windows x64 zip 安装包直链，适合调试旧项目或兼容旧版 Java 运行环境。

下载

String msg = "hello";
byte[] data = msg.getBytes(StandardCharsets.UTF_8);
InetAddress addr = InetAddress.getByName("127.0.0.1");
DatagramPacket packet = new DatagramPacket(data, data.length, addr, 8080);

务必用 StandardCharsets.UTF_8 显式指定编码，避免平台默认编码不一致导致乱码
发送前检查 data.length ，否则抛 <code>IOException
如果反复发送不同内容到同一地址端口，建议复用 DatagramSocket 实例，不要每发一次就 new 一个

接收端为什么调用 receive() 后线程卡住不动

因为 DatagramSocket.receive() 是阻塞调用，且默认无限等待。一旦网络不通、发端没发、或包被中间设备丢弃，线程就挂在那里，既不报错也不返回。这不是 bug，是 UDP 的设计使然。

必须在 receive() 前调用 socket.setSoTimeout(5000)（单位毫秒），超时后抛 SocketTimeoutException，可捕获后重试或退出
接收缓冲区大小影响性能：socket.setReceiveBufferSize(65536) 可减少丢包（尤其高并发场景），但不能超过系统上限
DatagramPacket 的 byte 数组必须预先分配足够空间（如 new byte[8192]），receive() 会覆写其中内容并更新 getLength() 返回实际接收字节数

多线程下 DatagramSocket 关闭时的典型竞态问题

最常见的坑是：主线程刚调用 socket.close()，另一个线程还在执行 socket.receive()，结果抛 SocketException: socket closed。这不是异常处理没写好，而是关闭时机不对。

不要在 finally 块里无条件 close()，应加 if (socket != null && !socket.isClosed()) 判断
推荐用 AtomicBoolean running = new AtomicBoolean(true) 控制接收循环，关闭前先设为 false，再中断线程（thread.interrupt()），最后 close
如果使用 connect() 后又想收其他地址的包，必须先 disconnect()，否则 receive() 会直接丢弃非目标地址的数据

UDP 的“简单”是表象，真正落地时，超时控制、缓冲区管理、线程安全、编码一致性这四点，漏掉任何一个都可能让程序在压测或跨网段时突然失效。