Java Socket循環(huán)接收數(shù)據(jù)readLine()阻塞的解決方案

更新時間：2024年08月13日 08:38:16 作者：曲幽

這篇文章主要介紹了Java Socket循環(huán)接收數(shù)據(jù)readLine()阻塞的解決方案,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教

寫在前面

只能說基礎不牢吧，代碼邏輯一切OK，就是接收不到服務器信息，發(fā)送沒問題。

因為服務器不是我能控制的，只能在客戶端想辦法解決，后來斷點知道了readLine()阻塞的情況，大無語呀，阻塞好是好，但你要換行符，我哪知道服務器給的是什么。

這里socket的連接之類的代碼很多，就不重復貼了，只放些解決方案供有同樣問題的朋友參考

解決方案一加換行符

就是上面提到的readLine()要換行符才知道傳送完成，所以這個只能是服務器端發(fā)送數(shù)據(jù)給客戶端時，結尾一定要加個\r或\n

又或者使用 println() 發(fā)送數(shù)據(jù)

如果服務器客戶端都是你維護，那這個解決方案最簡單高效。

以下代碼當個參考，m_clientSocket 即是服務端通信用Socket，非連接用的ServerSocket

 public void SendMessage(String msg) {
     new Thread(new Runnable() {
         @Override
         public void run() {
             try {
                 if (m_clientSocket.isConnected()) {
                     if (!m_clientSocket.isOutputShutdown()) {
                         PrintWriter printWriter = new PrintWriter(new OutputStreamWriter(m_clientSocket.getOutputStream()), true);
                         printWriter.println(msg);
                     }
                 }
             } catch (IOException e) {
                 log(e.getMessage());
             }
         }
     }).start();
 }

解決方案二使用Read() 方法

這里記得新開線程或用異步任務執(zhí)行接收數(shù)據(jù)的邏輯

private void WaitForData() {
    FutureTask<Void> futureTask = new FutureTask<>(new Callable<Void>() {
        @Override
        public Void call() throws Exception {
            try {
                String charset = "GBK";
                byte[] buffer = new byte[10240];
                String msg;
                int len;
                InputStream inputStream = m_clientSocket.getInputStream();
                BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream, charset));
                while (true) {
                    if (!m_clientSocket.isInputShutdown()) {
                        len = inputStream.read(buffer);
                        if (len == -1) break;
                        msg = new String(buffer, 0, len, charset);
                        log(msg);
                        // 拿到了接收到的數(shù)據(jù)msg后面就是自己的處理邏輯了，是打印還是其他了
                    }
                }
            } catch (Exception e) {
                log(e.getMessage());
            }
            return null;
        }
    });
    new Thread(futureTask).start();
}

解決方案三 DataInputStream

這種方法好是好，但沒有阻塞等待，會一直循環(huán)。（突然發(fā)現(xiàn)阻塞也是好東西呀）

一并貼出來供參考吧，看需要的朋友使用

private void WaitForData() {
    FutureTask<Void> futureTask = new FutureTask<>(new Callable<Void>() {
        @Override
        public Void call() throws Exception {
            int i = 0;
            while (true) {
                if (!client.isInputShutdown()) {
                    try {
                        DataInputStream inputStream = new DataInputStream(client.getInputStream());
                        byte[] buffer = new byte[inputStream.available()];
                        if(buffer.length != 0){
                            inputStream.read(buffer);
                            String msg = new String(buffer);
                            clientReceiveData.OnClientReceiveData(msg);
                        }
                        i++;
                        log(String.valueOf(i));
                    } catch (Exception ee) {
                        log(ee.getMessage());
                    }
                }
            }
        }
    });
    new Thread(futureTask).start();
}