인코딩 된 오디오를 안드로이드에 버퍼링하기위한 데이터 구조

Question

소켓을 통해 오디오 (인코딩 된) 데이터를 수신 한 TCP 클라이언트가 있습니다. 일부 버퍼에 수신 된 데이터를 보관하고 디코더 청크에서 청크로 요청할 때 디코더에 제공해야합니다. 데이터는 바이트 []이고 배열 크기는 다를 수 있습니다. 받은 byte [] 청크를 유지하기 위해 버퍼로 사용해야하는 것은 무엇입니까? BlockingQueue에 대해 알고 있지만 byte []의 N 크기를 추가 및 검색하는 것은 제공되지 않습니다.

합니까 자바는 우리의 ByteBuffer를 사용할 수 있습니다,이 목적을 위해 모든 데이터 구조를 제공?

Answer 1

클라이언트가 바이트 배열 크기가 어떻게 다른지 알고 있습니까? 잘 알려진 방법 (서버 측에서도 이것을 관리해야합니다)은 다음 필드를 사용하여 패킷 내에 데이터를 캡슐화하는 것입니다. | TYPE | SIZE | DATA | 이렇게 클라이언트에 소켓 연결이 있고 DataInputStream (dataInputStream = new DataInputStream(socket.getInputStream()))을 인스턴스화한다고 가정하면 위한

@Override 
public void run() { 
    while(running) { 

     int pckType = readPacketType(); 

     int pckSize = readPacketSize(); 

     byte[] data = readPacketContent(pckSize); 

     // do something with data 
     // you can use Semaphore instances in order to maintains a set of permits if needed 
    } 
} 

private int readPacketType() { 
    int result = -1; 
    byte[] array = new byte[1]; 
    try { 
     dataInputStream.read(array); 
     result = (int)array[0]; 
    } catch (IOException ex) { 
     return -1; 
    } 
    return result; 
} 

private int readPacketSize() { 
    int result = -1; 
    byte[] array = new byte[4]; 
    try { 
     dataInputStream.read(array); 
     result = ByteBuffer.wrap(array).getInt(); 
    } catch (IOException ex) { 
     return -1; 
    } 
    return result; 
} 

private byte[] readPacketContent(int contentSize) { 
    byte[] result = new byte[contentSize]; 
    try { 
     dataInputStream.read(result); 
    } catch (IOException ex) {} 
    return result; 
} 

내가 예를 들어, 할당 된 것을주의

의 TYPE 필드에 1 바이트, 4 바이트 : 클라이언트 run 방법이 같은 어떤 스레드의 데이터를 읽을 수있다 SIZE fi ELD

편집 : 당신은 LinkedBlockingQueue 등과 같은 인터페이스 BlockingQueue 인터페이스의 구현을 사용할 수 있습니다 . 다른 크기의 byte []를 넣고 일관되게 검색 할 수 있습니다 (순서와 크기 유지). 쉽게 확인하십시오;)

LinkedBlockingQueue<byte[]> lbq = new LinkedBlockingQueue<byte[]>(); 
String str1 = "blablabla"; 
String str2 = "blabla"; 
try { 
    lbq.put(str1.getBytes()); 
    lbq.put(str2.getBytes()); 
    lbq.put(str1.getBytes()); 
} catch (InterruptedException e) { 
    e.printStackTrace(); 
} 
byte[] b = null; 
int size = lbq.size(); 
for(int i=0; i<size; i++) { 
    try { 
     b = lbq.take(); 
    } catch (InterruptedException e) { 
     e.printStackTrace(); 
    } 
    System.out.println(b.length); 
}