如何在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請求130 KB。現在我正在嘗試編寫一個類似功能但使用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

您的流代碼的問題在於，您一次只讀一個字節，速度很慢，並且一次只能追加一個字節，同上。試試這個：

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片段不是一個正確的解決方案。如果請求不包含新行，則需要等到出現一個或連接終止/超時。你應該等待至少幾秒鐘。

我也擺脫了那些聽衆。能夠爲單個套接字添加多個偵聽器似乎是一個好主意，但使用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);