快捷導(dǎo)航

Java-readLine()阻塞問題及解決過程

更新時間：2026年05月07日 08:30:36 作者：昫灬

文章主要討論了socket編程中readLine()方法的阻塞問題,在使用readLine()接收消息時,如果沒有換行符,則會一直阻塞,解決方法是在發(fā)送消息時添加換行符,或者為每個客戶端創(chuàng)建獨立的轉(zhuǎn)發(fā)線程

socket編程中readLine()阻塞問題

readLine()的API說明

public String readLIne() throws IOException

中文版：

讀一行文字。一行被視為由換行符（’\ n’），回車符（’\ r’）中的任何一個或隨后的換行符終止。
返回：包含行的內(nèi)容的字符串，不包含任何行終止字符，如果到達流末尾，則為null

英文版：

Reads a line of text. A line is considered to be terminated by any one of a line feed (’\n’), a carriage return (’\r’), or a carriage return followed immediately by a linefeed.
Returns:
A String containing the contents of the line, not including any line-termination characters, or null if the end of the stream has been reached

遇到的問題：

當(dāng)使用socket寫一個雙向通信的服務(wù)端時，總是接收不到來自用戶的消息，和書上比對才發(fā)現(xiàn)是readLine()的問題，
還有就是客戶端和服務(wù)端的初始狀態(tài)問題（一個為初始為“發(fā)送”，一個為“接收”）

第一種情況

一個客戶端，一個服務(wù)端。當(dāng)服務(wù)端使用readLine()讀消息時，需要讀到一個換行符（‘\n’,或’\r’）才會結(jié)束。否則回一直阻塞，主線程就掛在這兒了
解決方法：在客戶端發(fā)送消息的時候，外加一個換行符

//用戶發(fā)送消息的線程
class SentMessage extends Thread{
        private Socket socket;
        private BufferedWriter bw;
        private BufferedReader mysc;
        SentMessage(Socket socket){
            this.socket = socket;
            try {
                bw = new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));
                mysc = new BufferedReader(new InputStreamReader(System.in));
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        @Override
        public void run(){
            try{
                while (true){
                    String mymessage = mysc.readLine();
                    bw.write(mymessage+"\n");
                    bw.flush();
                    if("bye".equals(mymessage)){
                        break;
                    }
                }
            }catch (IOException e){
                e.printStackTrace();
            }finally {
                try{
                    if(mysc!=null){
                        mysc.close();
                    }
                    if(bw!=null){
                        bw.close();
                    }
                }catch (IOException e){
                    e.printStackTrace();
                }
            }
        }
    }

第二種

當(dāng)用服務(wù)器轉(zhuǎn)發(fā)來自每個用戶的消息到聊天室時，如果就用一個"轉(zhuǎn)發(fā)消息"方法也會出現(xiàn)問題，就是使用了readLine()的阻塞
思考：一個客戶都應(yīng)有一個自己”轉(zhuǎn)發(fā)消息“通道（線程），不和其他客戶共用一個”轉(zhuǎn)發(fā)通道“（會導(dǎo)致阻塞
解決，用一個線程來做轉(zhuǎn)發(fā)

//內(nèi)置線程類用于接收消息，并廣播
    class AcceptMessage extends Thread{
        private Socket clientsocket;
        private BufferedReader br;
        AcceptMessage(Socket clientsocket){
            this.clientsocket = clientsocket;
        }
        /**
         * 服務(wù)器將所有接收的消息廣播（顯示在每一個客戶的聊天窗口中
         * 注意：如果這里不用線程，會出現(xiàn)問題，思考---其實就是readLine()阻塞的問題
         */
        private void tellEveryone(Socket socket){
            try{
                //先從發(fā)送消息的客戶讀內(nèi)容
                br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                String message = br.readLine();
                chatArea.append("用戶"+socket.getPort()+": "+message+"\n");
                //然后將內(nèi)容廣播到每一個客戶接口
                Iterator<Socket> it = list.iterator();
                while (it.hasNext()){
                    Socket socket2 = it.next();
                    //對自己就不要廣播了
                    if(socket!=socket2){
                        bw = new BufferedWriter(new OutputStreamWriter(socket2.getOutputStream()));
                        bw.write(socket2.getInetAddress().getHostAddress()+": "+message+"\n");
                        bw.flush();
                    }
                }
            }catch (IOException e){
                e.printStackTrace();
            }
        }
        @Override
        public void run(){
            while (true){
                //接收并廣播
                tellEveryone(clientsocket);
            }
        }
    }