Misc NIO questions - Java-Gaming.org

I need som help with my run() method. How should I accept and register the connections from the clients? I want to both read from the and write to them. How can I detect if the client "hang up" on me (now the server crashes when the client does)?

One more thing, how to unbind a socket if I want to reuse the same port later (i.e. rebooting the server)?

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.nio.charset.Charset;
import java.nio.charset.CharsetEncoder;
import java.util.Iterator;

public class ServerController implements Runnable
{
      // Network fields.
      private static final int DEFAULT_PORT = 1337;
      private ByteBuffer buffer = ByteBuffer.allocateDirect(1024);
      private Charset ascii = Charset.forName("us-ascii");
      private CharsetEncoder asciiEncoder = ascii.newEncoder();
      private Selector selector;
      private ServerSocketChannel ssChannel;

      private void start()
      {
            try
            {
                  selector = Selector.open();
                  
                  ssChannel = ServerSocketChannel.open();
                  ssChannel.configureBlocking(false);
                  ssChannel.socket().bind(new InetSocketAddress(DEFAULT_PORT));
                  ssChannel.register(selector, SelectionKey.OP_ACCEPT);
            }
            catch (IOException e)
            {
                  e.printStackTrace();
            }
      }

      public void run()
      {
            while (running)
            {
                  try
                  {
                        selector.select();
                        
                        Iterator it = selector.selectedKeys().iterator();
                        while (it.hasNext())
                        {
                              SelectionKey sk = (SelectionKey) it.next();
                              it.remove();
                              
                              if (sk.isAcceptable())
                              {
                                    ServerSocketChannel acceptChannel = (ServerSocketChannel) sk.channel();
                                    SocketChannel sChannel = acceptChannel.accept();
                                    sChannel.register(selector, SelectionKey.OP_READ);
                              }
                              else if (sk.isReadable())
                              {
                                    SocketChannel sChannel = (SocketChannel) sk.channel();
                                    if (sChannel.read(buffer) == -1)
                                    {
                                          sk.cancel();
                                    }
                              }
                        }
                        
                        Thread.sleep(1000);
                  }
                  catch (InterruptedException e)
                  {
                        System.err.println("Server interrupted during sleep.");
                        System.exit(-1);
                  }
                  catch (IOException ioe)
                  {
                        ioe.printStackTrace();
                  }
            }
      }

      public static void main(String[] args)
      {
            new ServerController();
      }
}

Thanks!

- Johan