

详解Tomcat配置参数connectionTimeout意义

Spring全家桶实战案例

2023-09-01

导读：Tomcat配置参数connectionTimeout意义

环境：springboot2.5.12

application.yml配置

server:  port: 8081  tomcat:    maxThreads: 10    maxConnections: 10    acceptCount: 1      connectionTimeout: 3000

测试1：

在controller中休眠10s>connectionTimeout

@RestController@RequestMapping("/test")public class TestController {
  @GetMapping("/index")  public Object index() {    try {      System.out.println(Thread.currentThread().getName()) ;      TimeUnit.SECONDS.sleep(10) ;    } catch (InterruptedException e) {      e.printStackTrace();    }    return "success" ;  }  }

发现程序能正常地响应。

结论：connectionTimeout参数与具体的请求响应时间是没有关系的。

测试2：

通过HttpURLConnection发送请求

public class HttpURLConnectionDemo {    public static void main(String[] args) throws Exception {    HttpURLConnection con = (HttpURLConnection) new URL("http://localhost:8081/test/index").openConnection() ;    con.setDoInput(true) ;    con.setDoOutput(true) ;    long start = System.currentTimeMillis() ;    InputStream is = con.getInputStream() ;    Scanner scan = new Scanner(is) ;    while(scan.hasNext()) {      System.out.println("接收到内容：" + scan.next() + "\n耗时：" + (System.currentTimeMillis() - start)) ;    }    scan.close() ;    con.disconnect() ;    con = null ;  }  }

结果：

结论：connectionTimeout参数与什么样的客户端做连接请求没关系。

测试3：

通过Socket建立连接

public class TomcatConnectionTimeoutDemo {    public static void main(String[] args) throws Exception {    Socket socket = new Socket("127.0.0.1", 8081) ;    long start = System.currentTimeMillis() ;    InputStream is = socket.getInputStream() ;    is.read() ;    System.out.println(System.currentTimeMillis() - start ) ;  }  }

运行结果：

差不多3s后程序结束了，也就是连接断开了。接着测试：

public class TomcatConnectionTimeoutDemo {    public static void main(String[] args) throws Exception {    Socket socket = new Socket("127.0.0.1", 8081) ;    long start = System.currentTimeMillis() ;    final OutputStream os = socket.getOutputStream() ;    new Thread(() -> {      Scanner scan = new Scanner(System.in) ;      while(scan.hasNext()) {        String content = scan.next() ;        System.out.println("准备发送：" + content) ;        try {          os.write(content.getBytes()) ;          os.flush() ;        } catch (IOException e) {          e.printStackTrace() ;        }      }    }).start() ;    InputStream is = socket.getInputStream() ;    is.read() ;    System.out.println(System.currentTimeMillis() - start ) ;  }  }