2

我正在实施一个发现过程：

  • 打开 UDP 套接字以侦听给定端口上的广播响应
  • 发送一些请求（并期待稍后的响应）
  • 在给定时间后关闭 UDP 套接字

第一个电话有效。但其他调用得到一个绑定错误。地址已被使用：bind

我正在运行 Windows 7。我做了一些测试，发现在 channel.close(); Netstat 仍然给出：

netstat -a -b -sp udp | grep 55224

UDP 0.0.0.0:55224 ：

所以 udp 端口​​还是在 OS 级别打开的

我在网上搜索，它可能是操作系统级别的泄漏：Some java Datagram Socket questions

我运行了 2 个测试，一个使用 NIO 通道，一个不使用（来自网络上的测试）。我用 NIO 版本重现了我的错误，但如果我不使用 NIO，它就可以工作。

我任何人都可以指出我如何使它与 NIO 一起工作。目标平台是 Android，我不t wan总是收听广播，而是只收听重复的时间段。

测试插座

    public void testConnectCloseWithSocket() {
    long tCumulative = 0;
    int errAt = -1;
    System.out.println("start...");
    for (int i = 0; i < 4000; i++) {
        try {
            errAt = i;
            DatagramSocket result = new DatagramSocket(null);
            result.bind(new InetSocketAddress(InetAddress.getLocalHost(), 9005));
            result.close();

            //success at last
            tCumulative = 0;

        } catch (Exception e) {
            System.out.println("Error (at="+errAt+") (waited="+tCumulative+"ms): " + e.getMessage());

            tCumulative+=50;
            try {
                Thread.sleep(50);
            } catch (InterruptedException e1) {


            }
            i--;
        }
    }
    System.out.println("end...");

}

结果插座<

开始...错误（at=1319）（等待=0ms）：地址已在使用中：无法绑定

错误（at=1438）（等待=0ms）：地址已在使用中：无法绑定

错误（at=1587）（等待=0ms）：地址已在使用中：无法绑定

错误（at=1740）（等待=0ms）：地址已在使用中：无法绑定

结尾...

我确实遇到了一些错误，但是套接字正确关闭了……这对我的需要来说是可以的

使用频道测试

    public void testConnectCloseWithChannel() {
    long tCumulative = 0;
    int errAt = -1;
    System.out.println("start...");
    for (int i = 0; i < 4000; i++) {
        try {
            errAt = i;
            Selector selector = Selector.open();
            DatagramChannel channel = DatagramChannel.open();
            channel.configureBlocking(true);
            channel.socket().bind(new InetSocketAddress(InetAddress.getLocalHost(), 9005));
            SelectionKey clientKey = channel.register(selector, SelectionKey.OP_READ);
            clientKey.cancel();
            channel.close();

            //success at last
            tCumulative = 0;

        } catch (Exception e) {
            System.out.println("Error (at="+errAt+") (waited="+tCumulative+"ms): " + e.getMessage());

            tCumulative+=50;
            try {
                Thread.sleep(tCumulative);
            } catch (InterruptedException e1) {


            }
            i--;
        }
    }
    System.out.println("end...");

}

注意：如果 channel.register 被评论测试工作..

结果与频道

开始... 错误 (at=0) (waited=0ms): null 错误 (at=0) (waited=50ms): 地址已在使用中：绑定

错误（at=0）（等待=100ms）：地址已在使用：绑定

错误（at=0）（等待=150ms）：地址已在使用中：绑定...

谢谢你的帮助

4

2 回答 2

3

我确实遇到了一些错误，但是套接字正确关闭了……这对我的需要来说是可以的

不，如果您遇到错误，您的频道未正确关闭。

你必须在你的块close的finally子句中做。try

Selector selector = Selector.open();
try
{
  DatagramChannel channel = DatagramChannel.open();

  try
  {
    channel.configureBlocking(true);
    channel.socket().bind(
      new InetSocketAddress(InetAddress.getLocalHost(), 9005)
    );
    SelectionKey clientKey = channel.register(selector, SelectionKey.OP_READ);
    clientKey.cancel();
  }
  finally
  {
    channel.close();
  }
}
finally
{
  selector.close( )
}
于 2012-10-19T15:14:16.327 回答
0

如果通道已使用 Selector 注册，则通道关闭的某些部分将推迟到下一个 select()。它记录在 Selector、AbstractSelector、SelectorSpi、SelectableChannel、AbstractSelectableChannel 的森林中的某个地方，当我需要它时，我永远找不到它。如果您在关闭通道时处于选择循环和线程中，则可以通过调用 selectNow() 使其立即生效。

于 2012-10-19T21:17:21.460 回答