Java에서 소켓을 사용하여 빠른 데이터 읽기를 만드는 방법은 무엇입니까?

Question

이 같은 하나의 연결에 SocketChannel를 사용하고

:

int sampleBufferSize = 50; 
StringBuilder data = new StringBuilder(); 
ByteBuffer bf = ByteBuffer.allocate(sampleBufferSize); 
SocketChannel sc = new SocketChannel(); 
while(true) 
    if(sc.read(bf) > 0){ 
     bf.flip(); 
     while(bf.hasRemaining()) 
      data.append((char) bf.get()); 
     bf.clear(); 
    }else{ 
     fireDataReceived(data.toString()); 
     data.delete(0, data.length()); 
    } 

이 코드는 매우 효율적 아니지만, 그것은 0.05 초에서 같은 PC에서의 HTTP POST 요청 1백30킬로바이트를 읽습니다. 이제 비슷한 기능을하지만 Socket을 사용하여 클래스를 작성하려고합니다. 여기에 코드입니다 :

private static final int TIMEOUT_MILLIS = 50; 
private boolean reading = false; 
private long readBeginTime = 0; 
private StringBuilder buffer = new StringBuilder(); 
private Thread thread = new Thread(){ 
    public void run(){ 
     while(!isInterrupted()){ 
      try { 
       int b = getInputStream().read(); 
       if(b == -1){ 
        if(reading) 
         fireDataReceived(); 
        close(); 
       }else{ 
        if(!reading){ 
         reading = true; 
         readBeginTime = System.currentTimeMillis(); 
         setSoTimeout(TIMEOUT_MILLIS); 
        } 
        buffer.append((char) b); 
       } 
      } catch (SocketTimeoutException e){ 
       fireDataReceived(); 
      } catch (IOException e) { 
       e.printStackTrace(); 
       if(reading) 
        fireDataReceived(); 
       close(); 
      } 
     } 
    } 
}; 
private void fireDataReceived(){ 
    BufferedSocketEvent e = new BufferedSocketEvent(this, System.currentTimeMillis() - readBeginTime, buffer.toString()); 
    buffer.setLength(0); 
    reading = false; 
    try { 
     setSoTimeout(0); 
    } catch (SocketException e1) { 
     e1.printStackTrace(); 
    } 
    for(BufferedSocketListener listener: listeners) 
     listener.dataReceived(e); 
} 

그리고 문제는이 같은 요청에 대해 0.4 초 걸린다 내가 그렇게 오랜 시간이 걸리지 않는 이유를 모르겠어요. 제 코드에 무엇이 잘못된 지 설명하십시오.

Answer 1

스트림 코드의 문제는 한 번에 한 바이트 씩 읽는 것입니다. 느리고 한 번에 하나씩 StringBuilder에 덧붙입니다. 시도해보십시오 :

BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()); 
char[] chars = new char[8192]; 
int count; 
while ((count = in.read(chars)) > 0) 
{ 
    buffer.append(chars, 0, count); 
    fireDataReceived(); 
} 

요청을 분리하는 수단으로 읽기 시간 제한을 사용하는 것은 올바르지 않습니다. 이를 위해 데이터를 구문 분석해야합니다. TCP는 메시지 경계가없는 스트리밍 프로토콜이며 별도로 수신되는 별도의 전송에 대한 보장이 없습니다.

Answer 2

readLine() 또는 이와 유사한 방법을 사용해야합니다. HTTP 헤더의 끝은 빈 줄로 표시됩니다. 선을 감지하지 못하면 데이터 읽기를 중단 할시기를 알 수 없습니다. 타임 아웃이나 TCP 프래그먼트에 의존하는 것은 올바른 해결책이 아닙니다. 요청에 새 줄이 포함되어 있지 않으면 하나가 나타나거나 연결이 종료되거나 시간이 초과 될 때까지 기다려야합니다. 최소한 2 초 정도 기다려야합니다.

나는 또한 그 청취자들을 제거 할 것이다. 단일 소켓에 대해 여러 리스너를 추가 할 수 있다는 것은 좋은 생각처럼 보일 수 있지만 HTTP 헤더로 처리하는 것이 현명한 방법은이를 파싱하는 것입니다. 파서는 또한 독자에게 독서를 중단 할 때 알려야합니다.

ServerSocket serverSocket = new ServerSocket(8888); 
Socket clientSocket = serverSocket.accept(); 
BufferedReader reader = new BufferedReader(new InputStreamReader(clientSocket.getInputStream(), "ASCII")); 
String[] r = reader.readLine().split(" "); 
String type = r[0]; 
String resource = r[1]; 
String version = r[2]; 
Map<String, String> headers = new HashMap<String,String>(); 
while(true) { 
    String line = reader.readLine(); 
    if(line.isEmpty()) { 
     break; 
    } 
    String headerLine[] = line.split(":",2); 
    headers.put(headerLine[0],headerLine[1].trim()); 
} 
processHeader(type, resource, version, headers);