바이트 수가 정의되지 않은 SocketChannel에서 TCP를 통한 스트림 읽기

Question

바이트 수를 정의하지 않고 SocketChannel에서 스트림을 읽으려고합니다.

내가 생각한 대체 솔루션은 미리 정의 된 크기의 다른 ByteBuffers를 목록에 저장하여 나중에 수신 된 크기의 새 ByteBuffer를 할당하고 결과를 내부에 넣을 수있게하는 것입니다.

문제

차단 모드에 내가 있다는 것입니다 및 코드 확인 내가 읽기 방법에 따라 만들어진 루프를 떠나 유효한 상태를 찾을 수 없습니다 :

public static final Charset charsetUTF8 = Charset.forName("UTF-8"); 
public static final int BUFFER_SIZE = 1024; 

public static String getUnbounded(String st, SocketAddress address) throws IOException { 
    SocketChannel sc = SocketChannel.open(address); 
    sc.write(charsetUTF8.encode(st)); 
    List<ByteBuffer> listBuffers = new ArrayList<>(); 
    ByteBuffer buff = ByteBuffer.allocate(BUFFER_SIZE); 
    while(sc.read(buff) > -1){ 
     if(buff.remaining() == 0){ 
      listBuffers.add(buff); 
      buff.clear(); 
     } 
    } 

    listBuffers.add(buff); 
    ByteBuffer finalBuffer = ByteBuffer.allocate(BUFFER_SIZE * listBuffers.size()); 
    for(ByteBuffer tempBuff: listBuffers){ 
    finalBuffer.put(tempBuff); 
     tempBuff.clear(); 
    } 
    finalBuffer.flip(); 

    return charsetUTF8.decode(finalBuffer).toString(); 
} 

이 문제를 해결하는 방법에 대한 어떤 생각을?

Answer 1

해결책은 루프의 벗어나고 난 호출했다 :

판독 스트림을 닫지 않고 기입 스트림을 닫고 sc.read (광)

를 -1로 설정

sc.shutdownOutput(); 

Answer 2

그냥 clear() 바이트 버퍼 일 수는 없습니다. 새 것을 할당해야합니다. 그렇지 않으면 동일한 버퍼가 listBuffers에 반복적으로 추가됩니다.

ByteBuffer buff = ByteBuffer.allocate(BUFFER_SIZE); 
while(sc.read(buff) > -1){ 
    if(buff.remaining() == 0){ 
     listBuffers.add(buff); 
     buff = ByteBuffer.allocate(BUFFER_SIZE); 
    } 
} 
if (buff.position() > 0) { 
    listBuffers.add(buff); 
} 

마지막 버퍼 (아마되지 않습니다) 가득, 당신은 계정에이 복용 finalBuffer 크기를 계산해야하지 않을 수도 있기 때문이다.

Answer 3

HTTP 응답 스트림의 바이트 수가 '정의되지 않음'입니다. RFC을 참조하십시오. 그것은 하나에 의해 정의된다 :

1. EOS를 폐쇄 연결의 경우 (HTTP 1.0 연결 닫기)
2. 콘텐츠 길이 헤더 또는
3. 청크를 복호화 한 결과를 인코딩 형식.

이러한 방법 중 하나에서 정의해야하며, HTTP 영구 연결이 작동 할 수 있도록 나머지가있을 수도 있습니다.이 경우 다른 응답이있을 수 있습니다.

HttpURLConnection 클래스가 이미 존재하는 이유와이 모든 것을 올바르게 구현 한 다양한 타사 HTTP 클라이언트 및 기타 많은 것들을 알고 싶습니다.