Springboot TomcatEmbeddedServletContainer KeepAliveTimeout不起作用

看来您想关闭移动设备上可能发生的废弃HTTP连接。

@RestController@SpringBootApplicationpublic class DemoApplication {    public static void main(String[] args) {        SpringApplication.run(DemoApplication.class, args);    }    @Bean    public EmbeddedServletContainerFactory getEmbeddedServletContainerFactory() {        TomcatEmbeddedServletContainerFactory containerFactory = new TomcatEmbeddedServletContainerFactory();        containerFactory     .addConnectorCustomizers(new TomcatConnectorCustomizer() {         @Override         public void customize(Connector connector) {  ((AbstractProtocol) connector.getProtocolHandler()).setConnectionTimeout(100);         }     });        return containerFactory;    }    @RequestMapping    public String echo(@RequestBody String body) {        return body;    }}

连接超时已设置为100毫秒，以便快速运行测试。数据按块发送。在每个块之间，正在运行的线程被挂起x毫秒。

@RunWith(SpringJUnit4ClassRunner.class)@SpringApplicationConfiguration(classes = DemoApplication.class)@WebIntegrationTest("server.port:19000")public class DemoApplicationTests {    private static final int CHUNK_SIZE = 1;    private static final String HOST = "http://localhost:19000/echo";    @Rule    public ExpectedException expectedException = ExpectedException.none();    @Test    public void slowConnection() throws Exception {        final HttpURLConnection connection = openChunkedConnection();        OutputStreamWriter out = new OutputStreamWriter(connection.getOutputStream());        writeAndWait(500, out, "chunk1");        writeAndWait(1, out, "chunk2");        out.close();        expectedException.expect(IOException.class);        expectedException.expectMessage("Server returned HTTP response pre: 400 for URL: " + HOST);        assertResponse("chunk1chunk2=", connection);    }    @Test    public void fastConnection() throws Exception {        final HttpURLConnection connection = openChunkedConnection();        OutputStreamWriter out = new OutputStreamWriter(connection.getOutputStream());        writeAndWait(1, out, "chunk1");        writeAndWait(1, out, "chunk2");        out.close();        assertResponse("chunk1chunk2=", connection);    }    private void assertResponse(String expected, HttpURLConnection connection) throws IOException {        Scanner scanner = new Scanner(connection.getInputStream()).useDelimiter("\A");        Assert.assertEquals(expected, scanner.next());    }    private void writeAndWait(int millis, OutputStreamWriter out, String body) throws IOException, InterruptedException {        out.write(body);        Thread.sleep(millis);    }    private HttpURLConnection openChunkedConnection() throws IOException {        final URL url = new URL(HOST);        final HttpURLConnection  connection = (HttpURLConnection) url.openConnection();        connection.setDoOutput(true);        connection.setChunkedStreamingMode(CHUNK_SIZE);        return connection;    }}

将包的日志级别设置

org.apache.catalina.core

DEBUG

logging.level.org.apache.catalina.core=DEBUG

您会看到一个

SocketTimeoutException

slowConnection

我不知道为什么要使用HTTP状态代码502作为错误响应状态。HTTP
502
说：

502（错误的网关）状态代码表示服务器充当网关或代理时，从尝试执行请求的过程中访问的入站服务器收到无效响应。

客户端

Postman

如果您只是将问题压缩到最低限度，而实际上您想自己构建一个代理，则可以考虑使用Netflix
Zuul
。

2016年3月23日更新：

这是OP关于Stackoverflow的问题的根本原因：

我对longpolling所做的事情是，从服务apihibernate线程一段时间，然后将其唤醒，然后一次又一次地执行直到直到某些数据库状态完成为止。

该实现实际上阻止了Tomcat工作线程处理新的HTTP请求。因此，每增加一个长时间运行的操作，您的请求吞吐量就会降低。

我建议将长时间运行的操作卸载到单独的线程中。客户端（浏览器）启动一个新请求以获取结果。根据处理状态，服务器将返回结果或通知/错误/警告/。

这是一个非常简单的示例：

import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.http.ResponseEntity;import org.springframework.web.bind.annotation.PathVariable;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RequestMethod;import org.springframework.web.bind.annotation.RestController;import java.util.Map;import java.util.concurrent.ConcurrentHashMap;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import static org.springframework.http.HttpStatus.CREATED;import static org.springframework.http.HttpStatus.NOT_FOUND;import static org.springframework.http.HttpStatus.OK;@RestController@SpringBootApplicationpublic class DemoApplication {    public static void main(String[] args) {        SpringApplication.run(DemoApplication.class, args);    }    private ExecutorService executorService = Executors.newFixedThreadPool(10);    private Map<String, String> results = new ConcurrentHashMap<>();    @RequestMapping(path = "put/{key}", method = RequestMethod.POST)    public ResponseEntity<Void> put(@PathVariable String key) {        executorService.submit(() -> { try {     //simulate a long running process     Thread.sleep(10000);     results.put(key, "success"); } catch (InterruptedException e) {     results.put(key, "error " + e.getMessage());     Thread.currentThread().interrupt(); }        });        return new ResponseEntity<>(CREATED);    }    @RequestMapping(path = "get/{key}", method = RequestMethod.GET)    public ResponseEntity<String> get(@PathVariable String key) {        final String result = results.get(key);        return new ResponseEntity<>(result, result == null ? NOT_FOUND : OK);    }}