/**

* @author Daniele Bufalo

* @version 1.0

*/

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.net.ServerSocket;

import java.net.Socket;

// TODO: Auto-generated Javadoc

/**

* The Class SocketServer.

*/

public class SocketServer extends Thread {

/** The Constant PORT_NUMBER. */

public static final int PORT_NUMBER = 8081;

/** The socket. */

protected Socket socket;

/**

* Instantiates a new socket server.

*

* @param socket the socket

*/

private SocketServer(Socket socket) {

this.socket = socket;

System.out.println("New client connected from " + socket.getInetAddress().getHostAddress());

start();

}

/* (non-Javadoc)

* @see java.lang.Thread#run()

*/

public void run() {

InputStream in = null;

OutputStream out = null;

try {

in = socket.getInputStream();

out = socket.getOutputStream();

BufferedReader br = new BufferedReader(new InputStreamReader(in));

String request;

while ((request = br.readLine()) != null) {

System.out.println("Message received:" + request);

request += '\n';

out.write(request.getBytes());

}

} catch (IOException ex) {

System.out.println("Unable to get streams from client");

} finally {

try {

in.close();

out.close();

socket.close();

} catch (IOException ex) {

ex.printStackTrace();

}

}

}

/**

* The main method.

*

* @param args the arguments

*/

public static void main(String[] args) {

System.out.println("SocketServer Example");

ServerSocket server = null;

try {

server = new ServerSocket(PORT_NUMBER);

while (true) {

/**

* create a new {@link SocketServer} object for each connection

* this will allow multiple client connections

*/

new SocketServer(server.accept());

}

} catch (IOException ex) {

System.out.println("Unable to start server.");

} finally {

try {

if (server != null)

server.close();

} catch (IOException ex) {

ex.printStackTrace();

}

}

}

}