Java中如何通过DatagramSocket实现UDP通信的入门级教程？

本文共计1019个文字，预计阅读时间需要5分钟。

由于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免费学习笔记（深入）”；

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