如何在Java中以非常快的速度從文件中檢索數據

Question

我遇到類似情況，我提供了一個由字符串組成的日誌文件。我需要做的是，我需要從文件中檢索每個字符串並通過一個Socket，當文件結束時它必須再次返回到文件的開頭並再次發送字符串。我用一個發送字符串的無限線程寫了一個簡單的代碼，當EOF到來時，我正在關閉文件，並使用新的BufferedReader對象再次打開文件。我也給了少量的5毫秒線程睡眠，但一段時間後，我的進程進入暫停狀態（如死鎖）。無論如何提高轉移的速度？否則我可以消除暫停狀態。

下面是我的簡單代碼：

public class Write extends Thread{ 

private static final String FileName = "Messages.txt"; 
private static final int port = 8080; 
private final int time = 5; 
ServerSocket serverSocket; 
Socket writeSocket; 

@Override 
    public void run() 
    { 
    try 
    { 
      serverSocket = new ServerSocket(port); 
      System.out.println("Server listening on port " + port+ " ..."); 
      Socket writeSocket = serverSocket.accept(); 
      System.out.println("Connected to Client : "+ writeSocket.getLocalSocketAddress()); 

      OutputStream outStream = writeSocket.getOutputStream(); 
      PrintWriter out = new PrintWriter(outStream, true); 
      BufferedReader input = new BufferedReader(new FileReader(FileName)); 
      String str = ""; 
      while(true) 
      { 
       str = input.readLine(); 

       if(str==null){ 
       input.close(); 
       input = new BufferedReader(new FileReader(FileName)); 
      } 

       else{ 
       System.out.println("Outgoing Message>>"+str); 
       out.println(str); 
       Thread.sleep(time); 
       } 
      } 

    } 
    catch(IOException e) {System.out.println(e); } catch (InterruptedException ex) { 
     Logger.getLogger(Write.class.getName()).log(Level.SEVERE, null, ex); 
    } 
    } 

} 

讓我給你一個簡單的解釋。考慮上面的代碼是在一個服務器代碼中。當我在同一臺PC上運行客戶端計算機時，我可以以某種（高）速度發送消息，但在某段時間後，客戶端和服務器都進入暫停狀態。我覺得這就像死鎖。客戶端顯示爲「服務器已斷開連接並再次連接」。當我關閉客戶端時，再次服務器啓動。誰能告訴我有沒有辦法以非常高的速度處理琴絃？

Answer 1

重新程序阻塞，我建議：

1. 把out.println()前System.out.print("A")和System.out.print("B")後。如果它用輸出中的最後一條消息「A」阻塞，那麼問題出現在客戶端（它們沒有使用數據，最終導致發送方阻塞）。
2. 如果以前的情況發生，編寫你自己的簡單的客戶端，它只是從套接字讀取數據並拋出，所以你可以證明問題在另一端。

重新加速，想要刪除sleep和System.out.println。

Answer 2

爲什麼不使用java nio來讀取所有行？ https://docs.oracle.com/javase/8/docs/api/java/nio/file/Files.html#readAllLines-java.nio.file.Path-java.nio.charset.Charset- 或者文件太大，無法做到這一點？

Answer 3

你的代碼讀取日誌文件就好了。不需要加快速度。見下文（我評論的代碼與插座應對零件和代碼運行良好，在多次讀取日誌文件沒有放緩的跡象或死鎖。）：

import java.io.BufferedReader; 
import java.io.FileReader; 
import java.io.IOException; 
import java.net.ServerSocket; 
import java.net.Socket; 
import java.util.logging.Level; 
import java.util.logging.Logger; 

public class Write extends Thread { 

    private static final String FileName = "/tmp/Messages.txt"; 
    private static final int port = 8080; 
    private final int time = 5; 
    ServerSocket serverSocket; 
    Socket writeSocket; 

    public static void main(String[] args) { 
     Write write = new Write(); 

     Thread thread = new Thread(new Write()); 
     thread.start(); 

    } 

    @Override 
    public void run() { 
     try { 
//   serverSocket = new ServerSocket(port); 
//   System.out.println("Server listening on port " + port + " ..."); 
//   Socket writeSocket = serverSocket.accept(); 
//   System.out.println("Connected to Client : " + writeSocket.getLocalSocketAddress()); 
// 
//   OutputStream outStream = writeSocket.getOutputStream(); 
//   PrintWriter out = new PrintWriter(outStream, true); 
      BufferedReader input = new BufferedReader(new FileReader(FileName)); 
      String str = ""; 
      while (true) { 
       str = input.readLine(); 

       if (str == null) { 
        input.close(); 
        input = new BufferedReader(new FileReader(FileName)); 
       } else { 
        System.out.println("Outgoing Message>>" + str); 
        //out.println(str); 
        Thread.sleep(time); 
       } 
      } 

     } catch (IOException e) { 
      System.out.println(e); 
     } catch (InterruptedException ex) { 
      Logger.getLogger(Write.class.getName()).log(Level.SEVERE, null, ex); 
     } 
    } 

}