private final static int HEADER_SIZE = 4;

private byte[] mBuffer = null;
private byte[] mHeader = new byte[HEADER_SIZE];
private byte[] mPacket = null;
private boolean mNeedHeader=false;
private boolean mNeedPacket =false;
private int mLackBytes=0;

private void splitData(byte[] data, int receivedBytes){
		int offsetData=0;
		int packetSize=0;
		
		//Нужно восстановить заголовок
		if(mNeedHeader){
			//Если количество полученных данных достаточно для восстановления
			if(mLackBytes<=receivedBytes){
				System.arraycopy(data, 0, mBuffer, HEADER_SIZE-mLackBytes, mLackBytes);//Копируем недостающие данные
				mBuffer=new byte[toInt32(mBuffer)];//узнаем длинну пакета и создаем новый буфер равный длинне пакета
				offsetData+=mLackBytes;//смещаемся дальше
				mLackBytes=mBuffer.length;//Теперь требуемое количество равно длинне пакета
				mNeedHeader=false;//Заголовок уже не нужен
				mNeedPacket=true;//Теперь нужен пакет
			}else{
				//Восстанавливаем сколько можем
				System.arraycopy(data, 0, mBuffer, HEADER_SIZE-mLackBytes, receivedBytes);
				mLackBytes-=receivedBytes;//Уменьшаем требуемое количество
				return;//Выходим и ждем сл. итерации
			}
		}
		
		//Нужен пакет?
		if(mNeedPacket){
			//Если данных достаточно, то...
			if(mLackBytes<=receivedBytes){
				System.arraycopy(data, offsetData, mBuffer, mBuffer.length-mLackBytes, mLackBytes);//Копируем нужное количество
				offsetData+=mLackBytes;//смещаемся дальше
				mNeedPacket=false;//пакет восстановлен
				onPacket(mBuffer);//Вернем пакет!!!
			}else{
				System.arraycopy(data, offsetData, mBuffer, mBuffer.length-mLackBytes, receivedBytes-offsetData);//Восстанавливаем сколько возможно
				mLackBytes-=receivedBytes-offsetData;//Уменьшаем требуемое количество
				return;//Выходим и ждем сл. итерации
			}
		}
		
		//Двигаемся по массиву...
		while(offsetData!=receivedBytes){
			
			//Пытаемся получить заголовок пакета(4 байта)
			if(receivedBytes-offsetData>4){

				System.arraycopy(data, offsetData, mHeader, 0, HEADER_SIZE);//Копируем 4 байта в буфер
				packetSize=toInt32(mHeader);//Узнаем длинну данных в пакете
				offsetData+=HEADER_SIZE;//Смеещние на длинну заголовка
				
				//Пытаемся извлеч тело пакета
				if(offsetData+packetSize<=receivedBytes){
					mPacket=new byte[packetSize];
					System.arraycopy(data, offsetData, mPacket, 0, packetSize);
					offsetData+=packetSize;//Смещение на длинну пакета
					onPacket(mPacket);//Вернем пакет!!!
				}else{
					//Тело пакета выходит за пределы полученых данных. Сохраним в буфер сколько возможно
					mBuffer= new byte[packetSize];
					System.arraycopy(data, offsetData, mBuffer, 0, receivedBytes-offsetData);
					mLackBytes=packetSize-(receivedBytes-offsetData);//запоминаем сколько данных не хватает для полного пакета
					offsetData+=receivedBytes-offsetData;//Смещаемся до конца
					mNeedPacket=true;//При следующей итерации получения данных нужно восстановить пакет
				}
			}else{
				//Неполный заголовок! Сохраним в буфер сколько возможно
				mBuffer=new byte[HEADER_SIZE];
				System.arraycopy(data, offsetData, mBuffer, 0, receivedBytes-offsetData);
				mLackBytes=HEADER_SIZE-(receivedBytes-offsetData);//запоминаем сколько данных не хватает для полного заголовка
				mNeedHeader=true;//При следующей итерации получения данных нужно восстановить заголовок
				offsetData+=receivedBytes-offsetData;//Смещаемся до конца
			}
		}
		
	}