Intgen Server Java code example - Click here to copy ->>>

Can't find what you're looking for? Try our search:

Really working examples categorized by API, package, class. You can compile and run our examples right away! Not from source code for Java projects - only working examples! Copy, compile and run!

Code:



 

import java.nio.*;

import java.nio.channels.*;

import java.net.*;

import java.util.*;

import java.io.IOException;



public class IntgenServer {



  public static int DEFAULT_PORT = 1919;



  public static void main(String[] args) {



    int port;

    try {

      port = Integer.parseInt(args[0]);

    }

    catch (Exception ex) {

      port = DEFAULT_PORT;

    }

    System.out.println("Listening for connections on port " + port);



    ServerSocketChannel serverChannel;

    Selector selector;

    try {

      serverChannel = ServerSocketChannel.open();

      ServerSocket ss = serverChannel.socket();

      InetSocketAddress address = new InetSocketAddress(port);

      ss.bind(address);

      serverChannel.configureBlocking(false);

      selector = Selector.open();

      serverChannel.register(selector, SelectionKey.OP_ACCEPT);

    }

    catch (IOException ex) {

      ex.printStackTrace();

      return;

    }



    while (true) {



      try {

        selector.select();

      }

      catch (IOException ex) {

        ex.printStackTrace();

        break;

      }



      Set readyKeys = selector.selectedKeys();

      Iterator iterator = readyKeys.iterator();

      while (iterator.hasNext()) {



        SelectionKey key = (SelectionKey) iterator.next();

        iterator.remove();

        try {

          if (key.isAcceptable()) {

            ServerSocketChannel server = (ServerSocketChannel ) key.channel();

            SocketChannel client = server.accept();

            System.out.println("Accepted connection from " + client);

            client.configureBlocking(false);

            SelectionKey key2 = client.register(selector, SelectionKey.OP_WRITE);

            ByteBuffer output = ByteBuffer.allocate(4);

            output.putInt(0);

            output.flip();

            key2.attach(output);

          }

          else if (key.isWritable()) {

            SocketChannel client = (SocketChannel) key.channel();

            ByteBuffer output = (ByteBuffer) key.attachment();

            if (! output.hasRemaining()) {

              output.rewind();

              int value = output.getInt();

              output.clear();

              output.putInt(value+1);

              output.flip();

            }

            client.write(output);

          }

        }

        catch (IOException ex) {

          key.cancel();

          try {

            key.channel().close();

          }

          catch (IOException cex) {}

        }



      }



    }



  }



}



   /**

   *   Java Network Programming, Third Edition

   *   By Elliotte Rusty Harold

   *   Third Edition October 2004

   *   ISBN: 0-596-00721-3

   */