Spring Boot:部署到外部服务器时如何设置异步超时

问题描述 投票:0回答:1

在使用嵌入式 tomcat 部署我的 Spring Boot 应用程序时,我设置异步超时如下:

@Bean
public EmbeddedServletContainerFactory servletContainer() {
    TomcatEmbeddedServletContainerFactory factory = new TomcatEmbeddedServletContainerFactory();
    factory.addConnectorCustomizers(new TomcatConnectorCustomizer() {

        @Override
        public void customize(Connector connector) {
            connector.setAsyncTimeout(60000);
        }
    });
    return factory;
}

但是,部署到外部服务器(例如 websphere)时如何实现相同的效果?

尝试使用该属性:

spring.mvc.async.request-timeout=600000

但这并没有任何效果。

编辑:

我曾尝试按照 Andrei 的建议实现 AsyncConfigurer 。但它并没有按预期工作。下面是我的配置类:

@SpringBootApplication
@EnableAsync
 public class Application implements AsyncConfigurer {

public static void main(String[] args) {
    SpringApplication.run(Application.class, args);
}

@Override
public Executor getAsyncExecutor() {
    Executor executor = new ThreadPoolExecutor(10, 20, 60, TimeUnit.SECONDS, new ArrayBlockingQueue<>(10),
            new ThreadPoolExecutor.AbortPolicy());
    return executor;
}

@Override
public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
    // TODO Auto-generated method stub
    return new SimpleAsyncUncaughtExceptionHandler();
}
 }

我将超时设置为 60 秒,但是在尝试此配置时,请求在 30 秒后超时。正在使用 RestClient。

我有什么遗漏的吗?

java spring asynchronous spring-boot
1个回答
0
投票

在 SpringApplication (首先实现名为

AsyncConfigurer
的接口)类中,我将创建自定义 AsyncExeuctor,如下所示:

    @Override
    public Executor getAsyncExecutor() {
        Executor executor = new ThreadPoolExecutor(
                poolSize,
                maxSize,
                keepAlive, 
                TimeUnit.SECONDS, // <--- TIMEOUT IN SECONDS 
                new ArrayBlockingQueue<>(qSize),
                new ThreadPoolExecutor.AbortPolicy() // <-- It will abort if timeout exceeds
        );
        return executor;
    }

你可以在application.properties文件中配置

poolSize
maxSize
等,然后使用@Value注解“注入”它们。

© www.soinside.com 2019 - 2024. All rights reserved.