Java - Programación multihilo con sockets

package psp_t04_servidor_sockets;

import java.io.BufferedReader;

import java.io.*;

import java.net.*;

import java.util.logging.Level;

import java.util.logging.Logger;

/**

 *

 * @author  <your.name at your.org>

 */

public class PSP_T04_servidor_sockets {

    public static void main(String[] args) {

        try {

            //Mantener conexión mientras salir sea false

            boolean salir = false;

            int puerto = 9090;

            //Creamos un ServerSocket a la escucha que acepta como parámetro el puerto a conectar

            ServerSocket servidor = new ServerSocket(puerto);

            System.out.println("Esperando conexión del cliente...");

            //Creamos un objeto de la clase socket que aceptará una conexión cliente entrante

            Socket cliente = servidor.accept();

            //Creamos flujo de entrada para recibir información del cliente

            BufferedReader recibir = new BufferedReader(new InputStreamReader(cliente.getInputStream()));

            //Creamos un flujo de salida

            PrintWriter enviar = new PrintWriter(cliente.getOutputStream(),true);

            while(!salir){

                //Esperar a recibir informacion por el flujo de entrada

                String comando = recibir.readLine();

                System.out.println("Comando recibido: " + comando);

                //Switch para los comandos que teclee el cliente

                switch(comando){

                    case "salir":

                        salir = true;

                        break;

                    default:

                        enviar.println("Comando no reconocido.");

                        System.out.println("Comando no reconocido.");

                        break;

                }

            }

            cliente.close();

            servidor.close();

        } catch (IOException ex) {

            Logger.getLogger(PSP_T04_servidor_sockets.class.getName()).log(Level.SEVERE, null, ex);

        }

    }

}

package psp_t04_cliente_sockets;

import java.io.*;

import java.net.*;

import java.util.logging.Level;

import java.util.logging.Logger;

/**

 *

 * @author  <your.name at your.org>

 */

public class PSP_T04_cliente_sockets {

    public static void main(String[] args) {

        try {

            //Creamos una variable para los comandos a introducir

            String comando = "";

            String direccionIp ="127.0.0.1";

            int puerto =9090;

            //Creamos un flujo de entrada de datos para teclado

            BufferedReader lectorDeComandos = new BufferedReader(new InputStreamReader(System.in));

            //El cliente debe conocer la dirección ip y el puerto de conexión

            //Hay que solicitarla para establecer la conexión

            System.out.println("Introduzca la dirección ip del servidor: [127.0.0.1]");

            comando = lectorDeComandos.readLine();

            if (!comando.equalsIgnoreCase("")){

                direccionIp = comando;

            }

            System.out.println("Introduzca el puerto al que conectarse: [9090]");

            comando = lectorDeComandos.readLine();

            if(!comando.equalsIgnoreCase("")){

                puerto = Integer.parseInt(comando);

            }

            //Pasamos la ip y el puerto al socket

            Socket cliente = new Socket(direccionIp, puerto);

            System.out.println("Conexión establecida.");

            //Flujo salida para poder enviar informacion al servidor

            PrintWriter enviar = new PrintWriter(cliente.getOutputStream(), true);

            //Flujo entrada para recibir la información del servidor

            BufferedReader recibir = new BufferedReader(new InputStreamReader(cliente.getInputStream()));

            while(!comando.equalsIgnoreCase("salir")){

                System.out.println("");

                System.out.println("Por favor, introduzca un comando: ");

                comando = lectorDeComandos.readLine();

                enviar.println(comando);

                System.out.println(recibir.readLine());

            }

        } catch (IOException ex) {

            Logger.getLogger(PSP_T04_cliente_sockets.class.getName()).log(Level.SEVERE, null, ex);

        }

    }

}

public class ServerAlmacen {

	private int stock;

	private final ServerSocket ss;

	private volatile boolean cancel = false;

	/* */

	private ServerAlmacen(int stock) throws IOException {

		this.stock = stock;

		ss = new ServerSocket(9090, 2, InetAddress.getByName("loghost"));

	}

	/* */

	private void open() throws IOException {

		BufferedReader cin = new BufferedReader(new InputStreamReader(System.in));

		String local;

		Thread client = new Thread() {

			public void run() {

				boolean stop = false;

				int req;

				try {

					while(!cancel) {

						Socket cs = ss.accept();

						final ObjectOutputStream os = new ObjectOutputStream(cs.getOutputStream());

						final ObjectInputStream is = new ObjectInputStream(cs.getInputStream());

						while(!stop) {

							String cmd = is.readUTF();

							switch(cmd) {

							case "estado":

								os.writeInt(stock);

								break;

							case "salida":

								req = is.readInt();

								os.writeInt(changeStock(-req));

								break;

							case "cerrar":

								stop = true;

								os.writeInt(0);

								cs.close();

								break;

							default:

								os.writeInt(-1);

							}

						}

					}

				} catch(IOException ex) {

					if(!cancel) {

						Logger.getLogger(ServerAlmacen.class.getName()).log(Level.SEVERE, null, ex);

					}

				}

			}

		};

		System.out.println("Server accepting requests on port 9090");

		client.start();

		while(!cancel) {

			local = cin.readLine();

			switch(local) {

			case "estado":

				System.out.printf("Stock: %d\n", stock);

				break;

			case "cerrar":

				cancel = true;

				client.interrupt();

				break;

			default:

				System.out.println("Don't grok!");

			}

		}

		System.exit(0);

	}

	/* */

	private synchronized int changeStock(int amount) {

		if((stock + amount) < 0) {

			return -1;

		}

		stock += amount;

		return stock;

	}

	/* */

	public static void main(String args[]) throws IOException {

		new ServerAlmacen(123).open();

	}

}