Java - Aplicacion Sockets Tienda

public class ServidorAlmacen {

        private int stock;

	private final ServerSocket servidor;

	private volatile boolean cancel = false;

	public ServidorAlmacen(int stock) throws IOException {

		this.stock = stock;

		servidor = new ServerSocket(5037);

	}

	public void iniciar() throws IOException {

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

		String local;

		Thread client = new Thread() {

			public void run() {

				boolean stop = false;

				int req=2;

				try {

					while(!cancel) {

						Socket socket = servidor.accept();

						 ObjectOutputStream os = new ObjectOutputStream(socket.getOutputStream());

						 ObjectInputStream is = new ObjectInputStream(socket.getInputStream());

						while(!stop) {

							String cmd = is.readUTF();

							switch(cmd) {

							case "consultar":

								os.writeInt(stock);

								break;

							case "retirar":

								req = is.readInt();

								os.writeInt(cambiarStock(-req));

								break;

							case "cerrar":

								stop = true;

								os.writeInt(0);

								socket.close();

								break;

							default:

								os.writeInt(-1);

							}

						}

					}

				} catch(IOException ex) {

					if(!cancel) {

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

					}

				}

			}

		};

		System.out.println("Servidor aceptando peticiones en puerto 5037");

		client.start();

		while(!cancel) {

			local = cin.readLine();

			switch(local) {

			case "consultar":

				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 cambiarStock(int cantidad) {

		if((stock + cantidad) < 0) {

			return -1;

		}

		stock += cantidad;

		return stock;

	}

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

            Scanner sc=new Scanner(System.in);

            System.out.println("Introduzca el stock inicial de chirimoyas: ");

            int numero=sc.nextInt();

		new ServidorAlmacen(numero).iniciar();

	}

public class ClienteAlmacen {

    public static void main(String[] args) {

        ClienteAlmacen cliente = new ClienteAlmacen();

        cliente.iniciar();

    }

    public void iniciar() {

        try {

            //Creamos una variable para los comandos a introducir

            String comando = "";

            String direccionIp = "127.0.0.1";

            String puerto = "5037";

            //Creamos un flujo de entrada de datos para teclado

            // Variable para leer los comando del usuario

            BufferedReader buffer = new BufferedReader(

                    new InputStreamReader(System.in));

            System.out.print(

                    "Introduce la dirección ip del servidor [127.0.0.1]: ");

            direccionIp = buffer.readLine();

            if (direccionIp.equals("")) {

                direccionIp = "127.0.0.1";

            }

            System.out.print("Introduce el puerto al que conectarse [5037]: ");

            puerto = buffer.readLine();

            if (puerto.equals("")) {

                puerto = "5037";

            }

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

            //Hay que solicitarla para establecer la conexión

            //Pasamos la ip y el puerto al socket

            Socket cliente = new Socket(direccionIp, parseInt(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()));

            System.out.println("Conexion establecida con el servidor.");

        } catch (IOException e) {

            System.out.println(e.getMessage());

        }

    }