바이트 스트림을 관리하고 스트림을 닫는 방법

Question

java.lang.OutOfMemoryError : 코드를 실행할 때마다 Java 힙 공간이 발생합니다. 그러나 특정 인스턴스에서 스트림을 닫으면 오류가 사라지지만 스트림이 너무 빨리 닫히기 때문에 데이터가 누락됩니다.

저는 Java에 익숙하지 않아 스트림을 관리하는 방법을 분명히 이해하지 못했습니다. 언제 어떻게 스트림을 닫아야합니까?

private void handleFile(File source) 
{ 
    FileInputStream fis = null; 

    try 
    { 
     if(source.isFile()) 
     { 
      fis = new FileInputStream(source); 
      handleFile(source.getAbsolutePath(), fis); 
     } 
     else if(source.isDirectory()) 
     { 
      for(File file:source.listFiles()) 
      { 
       if(file.isFile()) 
       { 
        fis = new FileInputStream(file); 
        handleFile(file, fis); 
       } 
       else 
       { 
        handleFile(file); 
       } 
      } 
     } 
    } 
    catch(IOException ioe) 
    { 
     ioe.printStackTrace(); 
    } 
    finally 
    { 
     try 
     { 
      if(fis != null) { fis.close(); } 
     } 
     catch(IOException ioe) { ioe.printStackTrace(); } 
    } 
} 

private handleFile(String fileName, InputStream inputStream) 
{ 
    try 
    { 
     byte[] initialBytes = isToByteArray(inputStream); 
     byte[] finalBytes = initialBytes; 

     if(initialBytes.length == 0) return; 

     if(isBytesTypeB(initialBytes)) 
     { 
      finalBytes = getBytesTypeB(startingBytes); 
     } 
     // Other similar method checks 
     // ..... 

     map.put(fileName, finalBytes); 
    } 
    catch(IOException ioe) 
    { 
     ioe.printStackTrace(); 
    } 
} 

private byte[] isToByteArray(InputStream inputStream) 
{ 
    ByteArrayOutputStream baos = new ByteArrayOutputStream(); 
    byte[] buffer = new byte[1024]; 

    int nRead; 
    while((nRead = inputStream.read(buffer)) != -1) 
    { 
     baos.write(buffer, 0, nRead); 
    } 
    return baos.toByteArray(); 
} 

private boolean isBytesTypeB(byte[] fileBytes) 
{ 
    // Checks if these bytes match a particular type 
    if(BytesMatcher.matches(fileBytes, fileBytes.length)) 
    { 
     return true; 
    } 
    return false; 
} 

private byte[] getBytesTypeB(byte[] fileBytes) 
{ 
    //decompress bytes 

    return decompressedBytes; 
} 

Answer 1

우선 메모리의 전체 스트림을 읽지 마십시오. 읽고 쓸 때 버퍼를 사용하십시오.

매우 작은 스트림 (일부 작업을 위해 다시 사용해야하는 데이터)을 읽었을 것으로 확신하는 경우에만 ByteArrayInputStream 및 ByteArrayInputStream을 사용하고 데이터를 메모리에 보관하는 것이 좋습니다. 그렇지 않으면 신속하게 (또는 예기치 않게) 메모리가 부족합니다.

try-catch 블록 외부의 스트림을 정의하고 finally 블록에서 스트림을 닫습니다 (null이 아닌 경우). 예를 들면 다음과 같습니다.

void doSomeIOStuff() throws IOException 
{ 
    InputStream is = null; 

    try 
    { 
     is = new MyInputStream(...); 
     // Do stuff 
    } 
    catch (IOException ioExc) 
    { 
     // Either just inform (poor decision, but good for illustration): 
     ioExc.printStackTrace(); 
     // Or re-throw to delegate further on: 
     throw new IOException(ioExc); 
    } 
    finally 
    { 
     if (is != null) 
     { 
      is.close(); 
     } 
    } 
} 

이렇게하면 사용 후 리소스가 항상 올바르게 닫힙니다.

호기심에서 벗어나서 handleFile(...) 방법은 실제로 무엇을 수행해야합니까?