Java NIO系列教程（十） Java NIO DatagramChannel

╰+攻爆jí腚メ 2022-05-23 11:10 403阅读 0赞

Java NIO中的DatagramChannel是一个能收发UDP包的通道。因为UDP是无连接的网络协议，所以不能像其它通道那样读取和写入。它发送和接收的是数据包。

### 打开 DatagramChannel ###

下面是 DatagramChannel 的打开方式：

<table style="margin:0px;padding:0px;width:auto;border:0px;background:none;float:none;vertical-align:baseline;height:auto;line-height:1.1em;font-size:1em;"> 
 <tbody style="margin:0px;padding:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-size:1em;"> 
  <tr style="margin:0px;padding:0px;border-top:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-size:1em;"> 
   <td style="border-width:0px;padding:0px;margin:0px;background-image:none;float:none;vertical-align:top;height:auto;width:3em;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;color:rgb(120,120,120);"><code style="margin:0px;padding:0px .3em 0px 0px;border:0px;background:none;text-align:right;float:none;vertical-align:baseline;height:auto;width:2.7em;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;">2</code></td> 
   <td style="border-top:0px;border-right:0px;border-bottom:0px;border-left-color:rgb(212,208,200);padding:0px 0px 0px .5em;margin:0px;background:none;float:none;vertical-align:top;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;color:rgb(0,0,0);"><code style="margin:0px;padding:0px;border:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;color:rgb(0,0,0);">channel.socket().bind(</code><code style="margin:0px;padding:0px;border:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-weight:bold;font-size:1em;color:rgb(127,0,85);">new</code>&nbsp;<code style="margin:0px;padding:0px;border:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;color:rgb(0,0,0);">InetSocketAddress(</code><code style="margin:0px;padding:0px;border:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;color:rgb(0,153,0);">9999</code><code style="margin:0px;padding:0px;border:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;color:rgb(0,0,0);">));</code></td> 
  </tr> 
 </tbody> 
</table>

这个例子打开的 DatagramChannel可以在UDP端口9999上接收数据包。

### 接收数据 ###

通过receive()方法从DatagramChannel接收数据，如：

receive()方法会将接收到的数据包内容复制到指定的Buffer. 如果Buffer容不下收到的数据，多出的数据将被丢弃。

### 发送数据 ###

通过send()方法从DatagramChannel发送数据，如:

<table style="margin:0px;padding:0px;width:auto;border:0px;background:none;float:none;vertical-align:baseline;height:auto;line-height:1.1em;font-size:1em;"> 
 <tbody style="margin:0px;padding:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-size:1em;"> 
  <tr style="margin:0px;padding:0px;border-top:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-size:1em;"> 
   <td style="border-width:0px;padding:0px;margin:0px;background-image:none;float:none;vertical-align:top;height:auto;width:3em;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;color:rgb(120,120,120);"><code style="margin:0px;padding:0px .3em 0px 0px;border:0px;background:none;text-align:right;float:none;vertical-align:baseline;height:auto;width:2.7em;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;">8</code></td> 
   <td style="border-top:0px;border-right:0px;border-bottom:0px;border-left-color:rgb(212,208,200);padding:0px 0px 0px .5em;margin:0px;background:none;float:none;vertical-align:top;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;color:rgb(0,0,0);"><code style="margin:0px;padding:0px;border:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-weight:bold;font-size:1em;color:rgb(127,0,85);">int</code>&nbsp;<code style="margin:0px;padding:0px;border:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;color:rgb(0,0,0);">bytesSent = channel.send(buf,&nbsp;</code><code style="margin:0px;padding:0px;border:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-weight:bold;font-size:1em;color:rgb(127,0,85);">new</code>&nbsp;<code style="margin:0px;padding:0px;border:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;color:rgb(0,0,0);">InetSocketAddress(</code><code style="margin:0px;padding:0px;border:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;color:rgb(42,0,255);">"jenkov.com"</code><code style="margin:0px;padding:0px;border:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;color:rgb(0,0,0);">,&nbsp;</code><code style="margin:0px;padding:0px;border:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;color:rgb(0,153,0);">80</code><code style="margin:0px;padding:0px;border:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;color:rgb(0,0,0);">));</code></td> 
  </tr> 
 </tbody> 
</table>

这个例子发送一串字符到”jenkov.com”服务器的UDP端口80。 因为服务端并没有监控这个端口，所以什么也不会发生。也不会通知你发出的数据包是否已收到，因为UDP在数据传送方面没有任何保证。

### 连接到特定的地址 ###

可以将DatagramChannel“连接”到网络中的特定地址的。由于UDP是无连接的，连接到特定地址并不会像TCP通道那样创建一个真正的连接。而是锁住DatagramChannel ，让其只能从特定地址收发数据。

这里有个例子:

<table style="margin:0px;padding:0px;width:auto;border:0px;background:none;float:none;vertical-align:baseline;height:auto;line-height:1.1em;font-size:1em;"> 
 <tbody style="margin:0px;padding:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-size:1em;"> 
  <tr style="margin:0px;padding:0px;border-top:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-size:1em;"> 
   <td style="border-width:0px;padding:0px;margin:0px;background-image:none;float:none;vertical-align:top;height:auto;width:3em;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;color:rgb(120,120,120);"><code style="margin:0px;padding:0px .3em 0px 0px;border:0px;background:none;text-align:right;float:none;vertical-align:baseline;height:auto;width:2.7em;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;">1</code></td> 
   <td style="border-top:0px;border-right:0px;border-bottom:0px;border-left-color:rgb(212,208,200);padding:0px 0px 0px .5em;margin:0px;background:none;float:none;vertical-align:top;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;color:rgb(0,0,0);"><code style="margin:0px;padding:0px;border:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;color:rgb(0,0,0);">channel.connect(</code><code style="margin:0px;padding:0px;border:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-weight:bold;font-size:1em;color:rgb(127,0,85);">new</code>&nbsp;<code style="margin:0px;padding:0px;border:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;color:rgb(0,0,0);">InetSocketAddress(</code><code style="margin:0px;padding:0px;border:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;color:rgb(42,0,255);">"jenkov.com"</code><code style="margin:0px;padding:0px;border:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;color:rgb(0,0,0);">,&nbsp;</code><code style="margin:0px;padding:0px;border:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;color:rgb(0,153,0);">80</code><code style="margin:0px;padding:0px;border:0px;background:none;float:none;vertical-align:baseline;height:auto;width:auto;line-height:1.1em;font-family:Consolas, 'Bitstream Vera Sans Mono', 'Courier New', Courier, monospace;font-size:1em;color:rgb(0,0,0);">));</code></td> 
  </tr> 
 </tbody> 
</table>

当连接后，也可以使用read()和write()方法，就像在用传统的通道一样。只是在数据传送方面没有任何保证。这里有几个例子：

[view source][]

[print][] [?][Link 1]

[view source]: http://ifeve.com/datagram-channel/#viewSource
[print]: http://ifeve.com/datagram-channel/#printSource
[Link 1]: http://ifeve.com/datagram-channel/#about