Протокол обмена текстовыми данными через сеть

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.SocketException;
import java.nio.ByteBuffer;
 
public class StandardProtocol {
 
    public StandardProtocol(Socket socket) {
 
        super.socket = socket;
    
        try {
            socket.setTcpNoDelay(true);
        } catch (SocketException e1) {
            // TODO Auto-generated catch block
            e1.printStackTrace();
        }
        
        try {
            out = new PrintWriter(socket.getOutputStream());
            in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    
    /**
     * Отправить строку через Socket
     * @param data Информация, которую нужно отправить
     */
    @Override
    public void sendString(String data) {
    
        byte[] formatBytes = this.getFormatBytes(data.getBytes());
    
        sendBytes(formatBytes);
    }
    
    /**
     * Принять строку через Socket
     * @param maxLen Максимальная длина в символах (принимаемой информации)
     * @return Информация в строковом виде
     * @throws IOException
     */
    @Override
    public String receiveString(int maxLen) throws IOException {
        
        byte[] data = receiveBytes(maxLen * 2);
 
        if(data != null) {
            return new String(data);
        } else {
            return null;
        }
    }
    
    private byte[] receiveBytes(int bufferLength) throws IOException {
        
        
        byte[] byteBuffer = new byte[bufferLength];
        
        int len = 0;
        int c = 0;
        
        int intLength = -1;
        int beginIndex = -1;
        
        while(true) {
            c = socket.getInputStream().read();
            
            if(c == (int) 129) {
 
                byte[] length = new byte[4];
                
                for(int i=0; i<4; i++) {
                    length[i] = (byte) socket.getInputStream().read();
                }
                
                intLength = ByteBuffer.wrap(length).getInt();
 
                beginIndex = 5;
 
                break;
            }
        }
        
        len = socket.getInputStream().read(byteBuffer, beginIndex, intLength);
    
        if(len != -1) {
 
            byte[] message = new byte[intLength];
            int pos = 0;
            
            for(int i=beginIndex; i<intLength+beginIndex; i++) {
                message[pos++] = byteBuffer[i];
            }
 
            return message;
        }
        
        return null;
    }
    
    private void sendBytes(byte[] data) {
        try {
            socket.getOutputStream().write(data);
            socket.getOutputStream().flush();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    
    private byte[] getFormatBytes(byte[] data) {
 
        byte[] finalBytes = new byte[1 + 4 + data.length];
        
        finalBytes[0] = (byte) 129;
        finalBytes[1] = (byte) (data.length >>> 24);
        finalBytes[2] = (byte) (data.length >>> 16);
        finalBytes[3] = (byte) (data.length >>> 8);
        finalBytes[4] = (byte) data.length;
        
        int count = 0;
        
        for(int i=5; i<data.length+5; i++) {
            finalBytes[i] = data[count++];
        }
 
        return finalBytes;
    }
 
}

try {
    while((data = inetProtocol.receiveString(4096)) != null) {
            System.out.println(data);
    }
 
} catch (IOException e) {
 
    clientSessionDestroy();
    e.printStackTrace();
    System.out.println("Соединение разорвано!");
} catch(NullPointerException e2) {
    clientSessionDestroy();
}