Specify connection timeout in java.nio

2020-02-11 04:32发布

Using non-blocking I/O, the code for connecting to a remote address looks something like:

SocketChannel channel = SelectorProvider.provider().openSocketChannel();
channel.configureBlocking(false);
channel.connect(address);

The connection process will then have to be finished by invoking finishConnect() on the channel when some selector says the corresponding key isConnectable().

Is there a way to specify the connection timeout when using this idiom?

2条回答
Melony?
2楼-- · 2020-02-11 05:10

Interesting question. I'm not sure that nio itself provides a solution.

In my experience, I've run a Callable to attempt the connection, and then used the Future to poll for a response, using 'interval' and 'timeout' variables to loop and Thread.sleep() for a response.

Hopefully that points you in a useful direction ...

Also, I suggest you take a look at Apache Mina (you could describe Mina as an nio framework). It handles a lot of this kind of stuff for you, for example in the StreamIoHandler http://mina.apache.org/report/trunk/apidocs/org/apache/mina/handler/stream/StreamIoHandler.html

查看更多
Bombasti
3楼-- · 2020-02-11 05:34

The question doesn't really make sense. Timeouts are for blocking mode. If you want that, leave the channel in blocking mode and call channel.socket().connect(address, timeout);. If you want non-blocking mode, use your current code; then create a Selector; register the channel for OP_CONNECT; when you get it call finishConnect(), and if that returns true deregister OP_CONNECT and continue with the rest of your code.

查看更多
登录 后发表回答