Giriş
Şu satırı dahil
ederiz.
import java.nio.channels.SelectionKey;
Bu sınıf soyuttur (abstract) ve
Selector ilgilidir.
attach metodu
Attaches the given object to this key. An attached object may later be retrieved via the attachment method. Only one object may be attached at a time; invoking this method causes any previous attachment to be discarded. The current attachment may be discarded by attaching null."
Örnek
try {
Selector selector = Selector.open();
ServerSocketChannel serverSocket = ServerSocketChannel.open();
serverSocket.bind(new InetSocketAddress("localhost", 10_000));
serverSocket.configureBlocking(false);
HashMap<String, Object> attr = ...;
SelectionKey selectionKey = serverSocket.register(selector, SelectionKey.OP_ACCEPT);
// attach a object
selectionKey.attach(attr);
while (true) {
selector.selectNow();
Set<SelectionKey> selectionKeySet = selector.selectedKeys();
Iterator<SelectionKey> iter = selectionKeySet.iterator();
while (iter.hasNext()) {
selectionKey = iter.next();
// Get the attachment object again from selectionKey
HashMap attr = (HashMap)selectionKey.attachment();
if(selectionKey.isAcceptable()){
...
}
iter.remove();
}
}
}
catch(Exception e) {...}
cancel metodu
Bu sınıf ile Selector arasındaki ilişkiyi koparmak istersek şöyle
yaparız.
SelectionKey key = channel.register(mySelector,
SelectionKey.OP_READ | SelectionKey.OP_WRITE);
...
key.cancel();
channel metodu
SelectableChannel döndürür. Eğer isAcceptable() true dönerse şöyle
yaparız.
ServerSocketChannel ssc = (ServerSocketChannel) key.channel();
Eğer isConnectable true dönerse şöyle yaparız
if (key.isConnectable()) {
SocketChannel sc = (SocketChannel) key.channel();
...
}
Eğer isReadable true dönerse şöyle
yaparız
if (key.isReadable()) {
SocketChannel sc = (SocketChannel) key.channel();
...
}
Eğer isWritable true dönerse şöyle yaparız
if (key.isWritable()) {
SocketChannel sc = (SocketChannel) key.channel();
...
}
isAcceptable metodu
Şöyle
yaparız.
if (key.isAcceptable()) {
...
}
Sunucu socketimiz yeni bir bağlantı almıştır.
isConnectable metodu
Şöyle yaparız.
if (key.isConnectable()) {
...
}
İstemci socketimiz bağlanmıştır.
isReadable metodu
Şöyle yaparız.
if (key.isReadable()) {
...
}
Socketimize veri gelmiştir. Burada gıcık bir durum var. key.channel() ile doğru socket tipini elde edemiyoruz. Açıklaması
şöyle
SelectionKey.channel() always returns a SelectableChannel. The assigned type of the channel is not really relevant at this point, so you'll have to cast it.
TCP istemcisi ise şöyle
yaparız
SocketChannel sc = (SocketChannel) key.channel();
...
TCP istemcisinden okumak için şöyle yaparız. Hata varsa socket kapatılır.
if (sc.read(myByteBuffer) == -1)
close(key);
Kapatma işlemi şöyledir.
private void close(SelectionKey key) throws IOException {
key.cancel();
key.channel().close();
}
isValid metodu
Şöyle
yaparız.
SelectionKey key = ...;
if (!key.isValid())
continue;
isWritable metodu
Şöyle yaparız.
if (key.isWritable()) {
...
}
Socketimiz yazmak için müsaittir.
