我们有一个类通过套接字与另一个主机通信,它看起来像这样:
SocketChannel sc = SocketChannel.open(new InetSocketAddress(HOST, PORT));
sc.configureBlocking(true);
...
sc.write(...)
sc.read(...)
这个类工作得很好,除非主机关闭,然后 SocketChannel.open 永远阻塞。我尝试通过执行以下操作来超时:
SocketChannel = SocketChannel.open();
sc.configureBlocking(false);
boolean result = socketChannel.connect(new InetSocketAddress(HOST, PORT));
if (!result) {
long startTime = System.currentTimeMillis();
while (!socketChannel.finishConnect()) {
if (System.currentTimeMillis() - startTime< 1000) {
// keep trying
Thread.sleep(100);
} else {
// FAILED!
enabled = false;
return;
}
}
}
// SUCCESS!
socketChannel.configureBlocking(true);
enabled = true
由于某种原因,finishConnect() 永远阻塞,而我本希望它根本不会阻塞。有什么想法吗?
最佳答案
你做错了。
- 创建一个未连接的
SocketChannel
并在阻塞模式下执行定时连接。
或者
- 在非阻塞模式下使用
选择器
。注册OP_CONNECT
的 channel 并选择。当它变为可连接时,调用finishConnect(),
,如果返回 true,则取消注册OP_CONNECT
并继续进行 I/O。如果返回 false,则继续选择。如果抛出异常,放弃连接,则失败。使用选择超时。不是旋转循环。
关于java - 使用 NIO SocketChannel 连接到套接字时超时,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/16369146/