SocketTimeoutException：读取超时

  • Z时代
  • 2024-01-10
  • 分类：问答

这是一个基于客户端/服务器的简单ping / pong程序。不幸的是，IT无法正常工作并显示以下错误消息：

java.net.SocketTimeoutException: Read timed out
    at java.net.SocketInputStream.socketRead0(Native Method)
    at java.net.SocketInputStream.read(Unknown Source)
    at java.net.SocketInputStream.read(Unknown Source)
    at sun.nio.cs.StreamDecoder.readBytes(Unknown Source)
    at sun.nio.cs.StreamDecoder.implRead(Unknown Source)
    at sun.nio.cs.StreamDecoder.read(Unknown Source)
    at java.io.InputStreamReader.read(Unknown Source)

它停止在CLIENT TASK 30行，实际上，客户端不读取服务器已发送的内容。这里的代码：

回答：

package serverClient;
import java.net.*;
import java.io.*;
import java.util.concurrent.*;
public class Server {
    public static void main(String[]args){
        ExecutorService esp= Executors.newFixedThreadPool(50);
        try(ServerSocket ss= new ServerSocket(1027)){
            while(true){
                try{
                    Socket s=ss.accept();
                    Callable<Void> task=new ServerTask(s);
                    esp.submit(task);
                }
                catch(BindException be){}
                catch(ConnectException ce){}
                catch(NoRouteToHostException nrthe){}
                catch(IOException ioe){ioe.printStackTrace();}
            }
        }
        catch(Exception e){e.printStackTrace();}
    }
}

回答：

package serverClient;
import java.util.concurrent.*;
import java.net.*;
import java.io.*;
public class ServerTask implements Callable <Void> {
    Socket s;
    ServerTask(Socket s){
        this.s=s;
    }
    public Void call(){
        BufferedWriter writer=null;
        BufferedReader reader=null;
        try{
            reader=new BufferedReader(new InputStreamReader(s.getInputStream()));
            writer=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
            int i=0;
            StringBuilder sb=new StringBuilder();
            while((i=reader.read())!=-1){
                sb.append((char)i);
            }
            System.out.println("The client sends: "+sb);
            writer.write("pong");
            writer.flush();
        }   
        catch(IOException ioe){ioe.printStackTrace();}
        finally{
                try {
                    writer.close();
                } 
                catch (IOException ioe) {ioe.printStackTrace();}
            if(reader!=null){
                try{
                    reader.close();
                }
                catch(IOException ioe){ioe.printStackTrace();}
            }
            try{
                s.close();
            }
            catch(IOException ioe){ioe.printStackTrace();}
        }
        return null;
    }
}

回答：

package serverClient;
import java.io.IOException;
import java.net.*;
import java.util.concurrent.*;
public class Client {
    public static void main(String[] args) {
        ExecutorService es= Executors.newSingleThreadExecutor();
        try {
            Socket s= new Socket(InetAddress.getLocalHost(),1027);
            try {
                s.setSoTimeout(50000);
            } 
            catch(SocketException se){se.printStackTrace();}
            Callable<Void> task=new ClientTask(s);
            es.submit(task);
        } 
        catch (UnknownHostException uhe) {uhe.printStackTrace();} 
        catch (IOException ioe) {ioe.printStackTrace();}
    }
}

回答：

package serverClient;
import java.util.concurrent.*;
import java.net.*;
import java.io.*;
public class ClientTask implements Callable <Void>{
    Socket s;
    ClientTask(Socket s){
        this.s=s;
    }
    public Void call(){
        BufferedWriter writer=null;
        BufferedReader reader=null;
        try{
            writer=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
            reader=new BufferedReader(new InputStreamReader(s.getInputStream()));
            writer.write("ping");
            writer.flush();
            int i=0;
            StringBuilder sb=new StringBuilder();
            while((i=reader.read())!=-1){
                System.out.println("I'm reading.");
                sb.append((char)i);
            }
            System.out.println("The server sends: "+sb);
        }
        catch(IOException ioe){ ioe.printStackTrace();}
        finally{
                try {
                    writer.close();
                } 
                catch (IOException ioe) {ioe.printStackTrace();}
            if(reader!=null){
                try{
                    reader.close();
                }
                catch(IOException ioe){ioe.printStackTrace();}
            }
            try{
                s.close();
            }
            catch(IOException ioe){ioe.printStackTrace();}
        }
        return null;
    }
}

回答：

问题出BufferedReader.read()在while循环内部的使用与从连接另一端处理套接字的方式之间的交互。

..read()仅当从其读取的流结束时才返回-1，这在本质上将意味着套接字已关闭。在关闭套接字之前，服务器只是阻塞read，等待客户端发送另一个字符。由于服务器处于阻塞状态read，因此永远无法将“

pong”发送回去。客户端自行阻止读取，但最终达到了超时。

TCP套接字用于处理数据流。如果要使用它发送离散消息，则需要在客户端和服务器之间强加一个协议，以便它们各自知道完整消息的到达时间。在这种情况下，客户端和服务器可以同意使用终止符，以指定消息已完成。例如，他们可以同意\n在每个消息之后发送一个作为终止符的消息。

因此，例如，在您的客户端中，相关代码如下所示：

writer.write("ping");
writer.write('\n');
writer.flush();
int i=0;
StringBuilder sb=new StringBuilder();
while((i=reader.read())!=-1){
    char c = (char)i;
    if(c == '\n')
        break;
    sb.append(c);
}
System.out.println("The server sends: "+sb);

以上是 SocketTimeoutException：读取超时 的全部内容， 来源链接： utcz.com/qa/421863.html

回到顶部