快捷導(dǎo)航

Java-readLine()阻塞問(wèn)題及解決過(guò)程

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

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

socket編程中readLine()阻塞問(wèn)題

readLine()的API說(shuō)明

public String readLIne() throws IOException

中文版：

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

遇到的問(wèn)題：

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

第一種情況

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

//用戶發(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ā)來(lái)自每個(gè)用戶的消息到聊天室時(shí)，如果就用一個(gè)"轉(zhuǎn)發(fā)消息"方法也會(huì)出現(xiàn)問(wèn)題，就是使用了readLine()的阻塞
思考：一個(gè)客戶都應(yīng)有一個(gè)自己”轉(zhuǎn)發(fā)消息“通道（線程），不和其他客戶共用一個(gè)”轉(zhuǎn)發(fā)通道“（會(huì)導(dǎo)致阻塞
解決，用一個(gè)線程來(lái)做轉(zhuǎn)發(fā)

//內(nèi)置線程類用于接收消息，并廣播
    class AcceptMessage extends Thread{
        private Socket clientsocket;
        private BufferedReader br;
        AcceptMessage(Socket clientsocket){
            this.clientsocket = clientsocket;
        }
        /**
         * 服務(wù)器將所有接收的消息廣播（顯示在每一個(gè)客戶的聊天窗口中
         * 注意：如果這里不用線程，會(huì)出現(xiàn)問(wèn)題，思考---其實(shí)就是readLine()阻塞的問(wèn)題
         */
        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)容廣播到每一個(gè)客戶接口
                Iterator<Socket> it = list.iterator();
                while (it.hasNext()){
                    Socket socket2 = it.next();
                    //對(duì)自己就不要廣播了
                    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);
            }
        }
    }