datagramchannel 是 java nio 中实现非阻塞 udp 通信的核心类,需配置非阻塞、绑定端口、注册 selector 读事件,配合直接缓冲区循环接收,send() 直接异步发送,selector 轮询处理就绪通道。

在 Java NIO 中,DatagramChannel 是实现非阻塞 UDP 通信的核心类,它支持单线程管理大量 UDP 连接,避免传统 DatagramSocket 的线程模型瓶颈。关键在于结合 Selector 实现事件驱动、零拷贝(配合 ByteBuffer)、以及合理缓冲区管理。
绑定与非阻塞配置
创建 DatagramChannel 后必须显式设为非阻塞,并绑定本地地址。UDP 无连接,绑定仅用于接收;发送目标地址在 send() 时指定。
- 调用
DatagramChannel.open()获取通道 - 执行
configureBlocking(false),否则无法注册到Selector - 用
bind(new InetSocketAddress(port))指定监听端口(可设0让系统分配) - 调用
register(selector, SelectionKey.OP_READ)注册读事件
高效接收:使用直接缓冲区 + 循环读取
UDP 数据报大小不确定,一次 receive() 只能读一个完整包。为减少 GC 压力和提升吞吐,推荐复用直接缓冲区(ByteBuffer.allocateDirect()),并注意处理截断与丢包。
- 预分配足够大的缓冲区(如 64KB),避免频繁扩容
-
receive(ByteBuffer)返回SocketAddress,即发送方地址,需保存用于回包 - 若缓冲区不足,数据被截断,
receive()仍返回实际长度,但内容不完整——应用层需检查并丢弃该包 - 建议每次
receive()前调用buffer.clear(),确保写入位置重置
异步发送:无需注册 OP_WRITE,直接 send() 即可
UDP 发送不涉及连接建立或流量控制,send() 总是立即返回(除非内核发送队列满,此时抛 IOException)。因此无需监听 OP_WRITE,也不用像 TCP 那样处理写就绪。
- 调用
send(buffer, remoteAddress),buffer 必须已 flip(limit 设为有效数据长度) - 发送失败通常因目标不可达或本地路由问题,异常类型多为
IOException或其子类(如PortUnreachableException) - 高并发场景下,可将待发数据暂存队列,由单独 I/O 线程批量调用
send(),避免主线程阻塞在系统调用
Selector 轮询与事件处理模式
一个 Selector 可管理成百上千个 DatagramChannel,轮询时只处理就绪通道,避免空转。典型循环结构为:select() → 遍历就绪集 → 分发读事件 → 清理 key(若需取消)。
-
selectNow()适合低延迟场景;select(timeout)更省电,适合长连接服务 - 每个
SelectionKey关联一个DatagramChannel和附件(如自定义上下文对象),便于状态传递 - 读取后务必调用
buffer.flip()再解析,否则 position/limit 错误导致数据读错 - 不建议在 handler 中执行耗时操作(如反序列化、DB 查询),应交由业务线程池处理
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南











