Socket Java设置超时时间

深碍√TFBOYSˉ_ 2022-07-14 12:17 364阅读 0赞

\#Socket Java设置超时时间

Socket Client Example

// File Name GreetingClient.java
    import java.net.*;
    import java.io.*;
    
    public class GreetingClient {
    
       public static void main(String [] args) {
          String serverName = args[0];
          int port = Integer.parseInt(args[1]);
          try {
             System.out.println("Connecting to " + serverName + " on port " + port);
             Socket client = new Socket(serverName, port);
             
             System.out.println("Just connected to " + client.getRemoteSocketAddress());
             OutputStream outToServer = client.getOutputStream();
             DataOutputStream out = new DataOutputStream(outToServer);
             
             out.writeUTF("Hello from " + client.getLocalSocketAddress());
             InputStream inFromServer = client.getInputStream();
             DataInputStream in = new DataInputStream(inFromServer);
             
             System.out.println("Server says " + in.readUTF());
             client.close();
          }catch(IOException e) {
             e.printStackTrace();
          }
       }
    }

Socket Server Example  
连接端口自定义，通过arg设置

// File Name GreetingServer.java
    import java.net.*;
    import java.io.*;
    
    public class GreetingServer extends Thread {
       private ServerSocket serverSocket;
       
       public GreetingServer(int port) throws IOException {
          serverSocket = new ServerSocket(port);
          serverSocket.setSoTimeout(10000);
       }
    
       public void run() {
          while(true) {
             try {
                System.out.println("Waiting for client on port " + 
                   serverSocket.getLocalPort() + "...");
                Socket server = serverSocket.accept();
                
                System.out.println("Just connected to " + server.getRemoteSocketAddress());
                DataInputStream in = new DataInputStream(server.getInputStream());
                
                System.out.println(in.readUTF());
                DataOutputStream out = new DataOutputStream(server.getOutputStream());
                out.writeUTF("Thank you for connecting to " + server.getLocalSocketAddress()
                   + "\nGoodbye!");
                server.close();
                
             }catch(SocketTimeoutException s) {
                System.out.println("Socket timed out!");
                break;
             }catch(IOException e) {
                e.printStackTrace();
                break;
             }
          }
       }
       
       public static void main(String [] args) {
          int port = Integer.parseInt(args[0]);
          try {
             Thread t = new GreetingServer(port);
             t.start();
          }catch(IOException e) {
             e.printStackTrace();
          }
       }
    }

设置超时  
1.设置连接请求超时时间，如果连接无响应，则抛出超时异常  
2.设置读操作超时时长，如过读取数据流时间超时，则抛出异常

Socket socket = new Socket();
    socket.connect(new InetSocketAddress(ipAddress, port), 1000);//设置连接请求超时时间1 s
    socket.setSoTimeout(30000);//设置读操作超时时间30 s

注意：socket.setSoTimeout必须在connect之后设置，不然将不会生效。读操作将永远不会超时。

--------------------

参考：  
https://www.tutorialspoint.com/java/java\_networking.htm  
http://stackoverflow.com/questions/4969760/set-timeout-for-socket  
http://docs.oracle.com/javase/7/docs/api/java/net/Socket.html