Hur får man bra flyt på socket programmering - Blocking read ?

Server & Klient
--------------------------------
Start      -------------------
Lyssna    Start
Acceptera    Acceptera
------------   Skicka
------------ -----------------
------------ -----------------
Läs          -----------------
------------  Läs

socket = new Socket(ip, port);
inputStream = socket.getInputStream();
bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
outputStream = this.socket.getOutputStream();
bufferedWriter = new BufferedWriter(new OutputStreamWriter(outputStream));

inputStream = socket.getInputStream();
bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
outputStream = socket.getOutputStream();
bufferedWriter = new BufferedWriter(new OutputStreamWriter(outputStream));

public class Main {
	
	private static Scanner scanner;
	private static ListenConnections listenThread;
 
    public static void main(String[] args) throws NumberFormatException, IOException {
    	
    	/*
    	 * Enter a port of this server
    	 */
    	scanner = new Scanner(System.in);  
        System.out.print("Enter a port number above 1024 for this server: ");
        String port = scanner.nextLine(); 
        
        /*
         * Run the threads now. New accept means new thread
         */
        
        listenThread = new ListenConnections(Integer.parseInt(port));
        listenThread.start();
        

    }
}

public class ListenConnections extends Thread {
	
	/*
	 * Fields
	 */
	private ServerSocket serverSocket;
	private Socket socket;
	private Storage storage;
	private Connection connection;
	
	/*
	 * Constructor
	 */
	public ListenConnections(int port) throws IOException {

		/*
		 * Create the server socket and a storage class 
		 */
		serverSocket = new ServerSocket(port);
		storage = new Storage();
	}

	/*
	 * This will listen after new connections(non-Javadoc)
	 * @see java.lang.Thread#run()
	 */
	@Override
	public void run() {
		while(true) {
			/*
			 * Wait until we get a connection with a client.
			 * Then we include the socket and also a storage class
			 */
			try {
				socket = serverSocket.accept();
				System.out.println("New connection from " + socket.getInetAddress().getHostAddress() + ":" + socket.getPort());
				connection = new Connection(socket, storage);
				connection.start();
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
}

public class Connection extends Thread {

	/*
	 * Private fields
	 */
	private Socket socket;
	private Storage storage;
	private InputStream inputStream;
	private BufferedReader bufferedReader;
	private OutputStream outputStream;
	private BufferedWriter bufferedWriter;
	private String clientIp;
	private int clientPort;
	private boolean connected;

	public Connection(Socket socket, Storage storage) throws IOException {
		this.socket = socket;
		this.storage = storage;

		/*
		 * Save the ID of the client
		 */
		clientIp = this.socket.getInetAddress().getHostAddress();
		clientPort = this.socket.getPort();

		/*
		 * Input and output streams
		 */
		inputStream = this.socket.getInputStream();
		bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
		outputStream = this.socket.getOutputStream();
		bufferedWriter = new BufferedWriter(new OutputStreamWriter(outputStream));
		
		/*
		 * Connected
		 */
		connected = true;
	}

	@Override
	public void run() {
		/*
		 * As long we have connection with our client, run this while loop
		 */
		try {
			/*
			 * Loop as long we have connection
			 */
			while (connected) {

				/*
				 * Read the command
				 */
				System.out.println("Read...");
				String command = bufferedReader.readLine(); // Blocking
				System.out.println("Result: " + command);

				/*
				 * Split the command with "#"
				 */
				String[] commands;
				try {
					commands = command.split("#");
				}catch(NullPointerException e) {
					/*
					 * If we get a null pointer exception here, that means we have lost connection with our client
					 */
					disconnect();
					return; // End the run() - End this loop
				}
				
				/*
				 * What should we do - GET or SET?
				 */
				String send = null;
				switch (commands[0]) {
				case "GET_OCTAVE":
					/*
					 * Get the values from the storage class to GNU OCtave
					 */
					send = storage.getSampleTime() + "#"
							+ storage.getPwmStartSignal() + "#"
							+ storage.getReferencePoint() + "#" 
							+ storage.getHorizon() + "#"
							+ storage.getSensorSlope() + "#"
							+ storage.getSensorOffset() + "#" 
							+ storage.getRunning();

					/*
					 * Send now to our client
					 */
					System.out.println(send);
					bufferedWriter.write(send.length()); // We first send length
					bufferedWriter.write(send);
					break;
					
				case "SET_OCTAVE":
					/*
					 * Set the values from the storage class from GNU Octave
					 */
					storage.setInputSignal(commands[1]);
					storage.setOutputSignal(commands[2]);
					storage.setTime(commands[3]);
					System.out.println("From Octave - Time : " + commands[3]);
					break;
					
				case "GET_ANDROID":
					/*
					 * Get the values from the storage class to Android app
					 */
					send = storage.getInputSignal() + "#"
								+ storage.getOutputSignal() + "#"
								+ storage.getTime();
					
					/*
					 * Send now to our client
					 */
					System.out.println(send);
					bufferedWriter.write(send);
					break;
					
				case "SET_ANDROID":
					/*
					 * Set the values to the storage class from Android app
					 */
					storage.setSampleTime(commands[1]);
					storage.setPwmStartSignal(commands[2]);
					storage.setReferencePoint(commands[3]);
					storage.setHorizon(commands[4]);
					storage.setSensorSlope(commands[5]);
					storage.setSensorOffset(commands[6]);
					storage.setRunning(commands[7]);
					System.out.println("From android - Sample Time: "+ commands[1]);
					break;

				default:
					break;

				}

			}

		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

	/*
	 * Connection closed
	 */
	private void disconnect() {
		
		System.out.println("Disconnection from " + clientIp + ":" + clientPort);
		try {
			socket.close();
		} catch (IOException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
		}
		connected = false;
		
	}
}