Java-Gaming.org    
Featured games (79)
games approved by the League of Dukes
Games in Showcase (477)
Games in Android Showcase (109)
games submitted by our members
Games in WIP (536)
games currently in development
News: Read the Java Gaming Resources, or peek at the official Java tutorials
 
    Home     Help   Search   Login   Register   
Pages: [1]
  ignore  |  Print  
  Misc NIO questions  (Read 1098 times)
0 Members and 1 Guest are viewing this topic.
Offline johtib

Senior Newbie





« Posted 2004-04-27 20:06:51 »

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
Offline Rob Grzywinski

Junior Member




Reality Interactive


« Reply #1 - Posted 2004-08-20 14:26:54 »

I don't have the time to check through the code for your first question, sorry.  There are many NIO tutorials out there.  Get comfy and start pouring over them  Smiley

As for the "unbind" -- you just close the channel.  Also, look into ServerSocketChannel.getSocket().setReuseAddress().  It may be useful in your case.
Pages: [1]
  ignore  |  Print  
 
 
You cannot reply to this message, because it is very, very old.

 

Add your game by posting it in the WIP section,
or publish it in Showcase.

The first screenshot will be displayed as a thumbnail.

CogWheelz (18 views)
2014-07-30 21:08:39

Riven (26 views)
2014-07-29 18:09:19

Riven (15 views)
2014-07-29 18:08:52

Dwinin (13 views)
2014-07-29 10:59:34

E.R. Fleming (34 views)
2014-07-29 03:07:13

E.R. Fleming (12 views)
2014-07-29 03:06:25

pw (44 views)
2014-07-24 01:59:36

Riven (44 views)
2014-07-23 21:16:32

Riven (30 views)
2014-07-23 21:07:15

Riven (31 views)
2014-07-23 20:56:16
List of Learning Resources
by SilverTiger
2014-07-31 18:29:50

List of Learning Resources
by SilverTiger
2014-07-31 18:26:06

List of Learning Resources
by SilverTiger
2014-07-31 13:54:12

HotSpot Options
by dleskov
2014-07-08 03:59:08

Java and Game Development Tutorials
by SwordsMiner
2014-06-14 00:58:24

Java and Game Development Tutorials
by SwordsMiner
2014-06-14 00:47:22

How do I start Java Game Development?
by ra4king
2014-05-17 11:13:37

HotSpot Options
by Roquen
2014-05-15 09:59:54
java-gaming.org is not responsible for the content posted by its members, including references to external websites, and other references that may or may not have a relation with our primarily gaming and game production oriented community. inquiries and complaints can be sent via email to the info‑account of the company managing the website of java‑gaming.org
Powered by MySQL Powered by PHP Powered by SMF 1.1.18 | SMF © 2013, Simple Machines | Managed by Enhanced Four Valid XHTML 1.0! Valid CSS!